home *** CD-ROM | disk | FTP | other *** search
- # Source Generated with Decompyle++
- # File: in.pyo (Python 2.5)
-
- import logging
- log = logging.getLogger('myspace.sock')
- from common import socket
- from MySpaceUtil import msmsg
-
- class myspace_socket(socket):
-
- def __init__(self, proto):
- socket.__init__(self)
- self.proto = proto
- self.buffer = ''
- self.set_terminator('\\final\\')
- log.info('socket created')
-
-
- def found_terminator(self):
- log.debug_s('in : %r %r', self.buffer, self.terminator)
- self.proto.cmd(self, msmsg(self.buffer + self.terminator))
- self.buffer = ''
- self.set_terminator(self.terminator)
-
-
- def collect_incoming_data(self, data):
- self.buffer += data
-
-
- def send_msg(self, msg):
-
- try:
- msg = str(msg)
- log.debug_s('out: %r', msg)
- socket.push(self, msg)
- except Exception:
- e = None
- self.handle_error(e)
- log.error('Error while trying to send this message: %r', msg)
-
-
-
- def handle_close(self):
- log.warning('socket closed for %r', self.proto)
- self.close()
-
-
- def handle_error(self, e = None):
- socket.handle_error(self, e)
- log.warning('error in socket for %r: %r', self.proto, e)
- self.close()
-
-
- def close(self):
- if getattr(self, 'proto', None) is not None:
- self.proto.socket_error(self)
- self.proto = None
-
- socket.close(self)
-
-
-