Mercurial > traipse_dev
diff orpg/networking/mplay_messaging.py @ 227:81d0bfd5e800 alpha
Traipse Alpha 'OpenRPG' {100612-00}
Traipse is a distribution of OpenRPG that is designed to be easy to setup and go. Traipse also makes it easy for
developers to work on code without fear of sacrifice. 'Ornery-Orc' continues the trend of 'Grumpy' and adds fixes to
the code. 'Ornery-Orc's main goal is to offer more advanced features and enhance the productivity of the user.
Update Summary (Preparing to close updates)
New Features:
New to Map, can re-order Grid, Miniatures, and Whiteboard layer draw order
Fixes:
Fix to InterParse that was causing an Infernal Loop with Namespace Internal
Fix to XML data, removed old Minidom and switched to Element Tree
Fix to Server that was causing eternal attempt to find a Server ID, in Register Rooms thread
Fix to metaservers.xml file not being created
author | sirebral |
---|---|
date | Sat, 12 Jun 2010 03:50:37 -0500 |
parents | 06f10429eedc |
children |
line wrap: on
line diff
--- a/orpg/networking/mplay_messaging.py Fri Jan 15 22:45:51 2010 -0600 +++ b/orpg/networking/mplay_messaging.py Sat Jun 12 03:50:37 2010 -0500 @@ -21,24 +21,20 @@ # Author: Dj Gilcrease # Maintainer: # Version: -# $Id: mplay_messaging.py,v 1.5 2007/05/06 16:42:59 digitalxero Exp $ +# $Id: mplay_messaging.py,v Traipse 'Ornery-Orc' prof.ebral Exp $ # # Description: This file contains the code for the client / server messaging # -__version__ = "$Id: mplay_messaging.py,v 1.5 2007/05/06 16:42:59 digitalxero Exp $" +__version__ = "$Id: mplay_messaging.py,v Traipse 'Ornery-Orc' prof.ebral Exp $" -import socket -import Queue -import thread -import traceback +import socket, Queue, thread, traceback, os, time + from threading import Event, Lock from xml.sax.saxutils import escape from struct import pack, unpack, calcsize from string import * from orpg.orpg_version import VERSION, PROTOCOL_VERSION, CLIENT_STRING, SERVER_MIN_CLIENT_VERSION -import os -import time from orpg.tools.orpg_log import logger from orpg.orpgCore import component @@ -91,20 +87,6 @@ self.players = {} self.groups = {} - #Setup Stuff from the Server - """ - if kwargs.has_key('inbox'): self.inbox = kwargs['inbox'] - if kwargs.has_key('sock'): self.sock = kwargs['sock'] - if kwargs.has_key('ip'): self.ip = kwargs['ip'] - if kwargs.has_key('role'): self.role = kwargs['role'] - if kwargs.has_key('id'): self.id = kwargs['id'] - if kwargs.has_key('group_id'): self.group_id = kwargs['group_id'] - if kwargs.has_key('name'): self.name = kwargs['name'] - if kwargs.has_key('version'): self.version = kwargs['version'] - if kwargs.has_key('protocol_version'): self.protocol_version = kwargs['protocol_version'] - if kwargs.has_key('client_string'): self.client_string = kwargs['client_string'] - """ - ### Alpha ### self.inbox = kwargs['inbox'] or pass self.sock = kwargs['sock'] or pass @@ -207,7 +189,6 @@ def __str__(self): return "%s(%s)\nIP:%s\ngroup_id:%s\n%s (%s)" % (self.name, self.id, self.ip, self.group_id, self.idle_time(), self.connected_time()) - # idle time functions added by snowdog 3/31/04 def update_idle_time(self): self.lastmessagetime = time.time() @@ -326,7 +307,6 @@ #Message Action thread expires and closes here. return - #Privet functions def sendThread( self, arg ): "Sending thread. This thread reads from the data queue and writes to the socket." # Wait to be told it's okay to start running @@ -352,11 +332,7 @@ def sendMsg( self, sock, msg ): """Very simple function that will properly encode and send a message to te remote on the specified socket.""" - - # Calculate our message length length = len( msg ) - - # Encode the message length into network byte order lp = pack( 'i', socket.htonl( length ) ) try: @@ -434,13 +410,11 @@ msgData = "" try: lenData = self.recvData( sock, self.lensize ) - # Now, convert to a usable form (length,) = unpack( 'i', lenData ) length = socket.ntohl( length ) # Read exactly the remaining amount of data msgData = self.recvData( sock, length ) - if self.isServer: logger.debug("('data_recv', " + str(length+4) + ")") except: logger.exception("Exception: messenger->recvMsg():\n" + traceback.format_exc()) return msgData @@ -448,3 +422,4 @@ if __name__ == "__main__": test = messenger(None) print test.build_message('hello', "This is a test message", attrib1="hello world", attrib2="hello world2", attrib3="hello world3") +