Fix multi-threading bugs. Now Session related objects create an Loop per thread.

Author: repeatedly

msgpackrpc/client.py

@@ -1,4 +1,4 @@
-from msgpackrpc import loop
+from msgpackrpc import Loop
 from msgpackrpc import session
 from msgpackrpc.transport import tcp
 
@@ -7,7 +7,8 @@ class Client(session.Session):
     Client is usaful for MessagePack RPC API.
     """
 
-    def __init__(self, address, timeout=10, loop=loop.Loop(), builder=tcp):
+    def __init__(self, address, timeout=10, loop=None, builder=tcp):
+        loop = loop or Loop()
         session.Session.__init__(self, address, timeout, loop, builder)
 
         if timeout:

msgpackrpc/server.py

@@ -2,7 +2,7 @@
 
 from msgpackrpc import inPy3k
 from msgpackrpc import error
-from msgpackrpc import loop
+from msgpackrpc import Loop
 from msgpackrpc import message
 from msgpackrpc import session
 from msgpackrpc.transport import tcp
@@ -12,8 +12,8 @@ class Server(session.Session):
     Server is usaful for MessagePack RPC Server.
     """
 
-    def __init__(self, dispatcher, loop=loop.Loop(), builder=tcp):
-        self._loop = loop
+    def __init__(self, dispatcher, loop=None, builder=tcp):
+        self._loop = loop or Loop()
         self._builder = builder
         self._listeners = []
         self._dispatcher = dispatcher

msgpackrpc/session.py

@@ -1,7 +1,7 @@
 import msgpack
 
 from msgpackrpc import inPy3k
-from msgpackrpc import loop
+from msgpackrpc import Loop
 from msgpackrpc import message
 from msgpackrpc.error import RPCError
 from msgpackrpc.future import Future
@@ -21,14 +21,14 @@ class Session(object):
     result to the corresponding future.
     """
 
-    def __init__(self, address, timeout, loop=loop.Loop(), builder=tcp):
+    def __init__(self, address, timeout, loop=None, builder=tcp):
         """\
         :param address: address of the server.
         :param loop:    context object.
         :param builder: builder for creating transport layer
         """
 
-        self._loop = loop
+        self._loop = loop or Loop()
         self._address = address
         self._timeout = timeout
         self._transport = builder.build_transport(self)