Fix ftests/parallel/test_remote.py.

The ssh-based remote procedure call was broken because of py3k compat.

.travis.yml

@@ -84,8 +84,7 @@ script:
   - cd ${TRAVIS_BUILD_DIR}
   - python setup.py build_ext --inplace
   - nosetests --with-doctest
-  - nosetests ftests/parallel/test_builtin.py
-  - nosetests ftests/parallel/test_rpc.py
+  - nosetests ftests/parallel/*
   # Package
   - cd ${TRAVIS_BUILD_DIR}
   - contrib/release.sh

contrib/release.sh

@@ -11,6 +11,6 @@ tar xfz SOLVCON-${SCVER}.tar.gz
 cd SOLVCON-${SCVER}
 python setup.py build_ext --inplace
 # test.
+PYTHONPATH=`pwd`
 nosetests --with-doctest
-nosetests ftests/parallel/test_builtin.py
-nosetests ftests/parallel/test_rpc.py
+nosetests ftests/parallel/*

solvcon/batch.py

@@ -332,12 +332,13 @@ def create_worker_ssh(self, node, authkey,
             raise IOError('remote port detection fails')
         # create remote worker objects and return.
         pdata = str(profiler_data).replace("'", '"')
+        authkeystr = authkey.decode("utf8")
         remote([
             'import os',
             'os.chdir("%s")' % os.path.abspath(os.getcwd()),
             'from solvcon.rpc import Worker',
             'wkr = Worker(None, profiler_data=%s)' % pdata,
-            'wkr.run(("%s", %d), "%s")' % (node.address, port, authkey),
+            'wkr.run(("%s", %d), b"%s")' % (node.address, port, authkeystr),
         ], envar=envar)
         return port
 

solvcon/connection.py

@@ -191,8 +191,8 @@ def Client(address, family=None, authkey=None):
     timeout = time.time() + CLIENT_TIMEOUT
     family = family or guess_family(address)
     # create socket.
-    skt = socket.socket(getattr(socket, family))
     while True:
+        skt = socket.socket(getattr(socket, family))
         try:
             skt.connect(address)
         except socket.error as e: