WIP: pypy

.travis.yml

@@ -7,6 +7,7 @@ python:
   - 3.7
   - 3.6
   - 3.5
+  - pypy3.5
 
 matrix:
   include:

osbrain/agent.py

@@ -333,11 +333,11 @@ def _loopback_reqrep(self, socket, data_to_send):
         try:
             loopback.connect(socket)
             loopback.send_pyobj(data_to_send)
-            return loopback.recv_pyobj()
-        except zmq.error.ContextTerminated:
-            pass
-        finally:
+            received = loopback.recv_pyobj()
             loopback.close(linger=0)
+        except zmq.error.ContextTerminated:
+            return None
+        return received
 
     def _loopback(self, header, data=None):
         """
@@ -1872,7 +1872,10 @@ def _close_socket(self, socket, linger):
             self._poller.unregister(socket)
 
         linger = get_linger(linger)
-        socket.close(linger=linger)
+        try:
+            socket.close(linger=linger)
+        except zmq.error.ContextTerminated:
+            pass
         address = self._address[socket]
         if address.transport == 'ipc':
             self._cleanup_ipc_socket_files(address)

osbrain/proxy.py

@@ -40,7 +40,8 @@ def locate_ns(nsaddr, timeout=3.0):
     time0 = time.time()
     while True:
         try:
-            Pyro4.locateNS(host, port)
+            ns = Pyro4.locateNS(host, port)
+            ns._pyroRelease()
             return nsaddr
         except NamingError:
             if time.time() - time0 < timeout:

setup.py

@@ -37,6 +37,7 @@
     keywords='osbrain multi-agent system',
     packages=['osbrain'],
     install_requires=[
+        'pathlib',
         'Pyro4>=4.48',
         'pyzmq>=15.2.0',
         'dill>=0.2.0,!=0.2.7',

tox.ini

@@ -5,6 +5,7 @@ envlist =
     py37
     py36
     py35
+    pypy3
     lint
     docs