Changeset 7
- Timestamp:
- 04/05/06 09:31:51 (3 years ago)
- Files:
-
- trunk/jsonrpc/__init__.py (modified) (2 diffs)
- trunk/jsonrpc/proxy.py (modified) (3 diffs)
- trunk/jsonrpc/socketserver.py (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/jsonrpc/__init__.py
r5 r7 65 65 66 66 67 class Simple ConnectionHandler:67 class SimpleMessageHandler: 68 68 def __init__(self, DecoderClass=JSONDecoder, EncoderClass=JSONRPCEncoder, messageDelimiter=""): 69 69 self.decoder = DecoderClass() … … 188 188 189 189 190 class SimpleServiceHandler(Simple ConnectionHandler):190 class SimpleServiceHandler(SimpleMessageHandler): 191 191 def __init__(self, service, DecoderClass=JSONDecoder, EncoderClass=JSONRPCEncoder, messageDelimiter=""): 192 192 self.service = service 193 Simple ConnectionHandler.__init__(self, DecoderClass, EncoderClass, messageDelimiter)193 SimpleMessageHandler.__init__(self, DecoderClass, EncoderClass, messageDelimiter) 194 194 try: 195 195 service._newConnection(self) trunk/jsonrpc/proxy.py
r5 r7 53 53 m = re.match(r"^jsonrpc:\/\/(.*):(\d*)$", url) 54 54 if m: 55 from jsonrpc.socketserver import Socket ConnectionHandler55 from jsonrpc.socketserver import SocketServiceHandler 56 56 import socket 57 57 from threading import Thread … … 61 61 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 62 62 s.connect((host, port)) 63 conn = Socket ConnectionHandler(s, localService,messageDelimiter=messageDelimiter)63 conn = SocketServiceHandler(s, localService,messageDelimiter=messageDelimiter) 64 64 PeerProxy.__init__(self, conn) 65 65 … … 71 71 conn= HTTPClientConnectionHandler(url, localService,messageDelimiter=messageDelimiter) 72 72 PeerProxy.__init__(self, conn) 73 74 def disconnect(self): 75 import socket 76 self._conn.close() 73 77 74 78 75 trunk/jsonrpc/socketserver.py
r5 r7 23 23 from threading import Thread 24 24 25 class SocketConnectionHandler(SimpleServiceHandler): 25 26 class SocketServiceHandler(SimpleServiceHandler): 26 27 def __init__(self, socket, service, messageDelimiter=""): 27 28 self.socket = socket … … 57 58 58 59 class TCPServiceServer: 59 def __init__(self, service, ConnectionHandler = Socket ConnectionHandler, messageDelimiter=""):60 def __init__(self, service, ConnectionHandler = SocketServiceHandler, messageDelimiter=""): 60 61 self.service = service 61 62 self.ConnectionHandler = ConnectionHandler