Merge remote-tracking branch 'origin/asyncio' into server-sync

.travis.yml

 language: python
 sudo: false
-cache:
-  pip
-  directories:
-    - eggs
 matrix:
     include:
         - os: linux
@@ -28,8 +24,11 @@ matrix:
           python: 3.5
           env: ZEO4_SERVER=1
 install:
-    - pip install -U zc.buildout
+    - pip install zc.buildout
     - buildout
+cache:
+  directories:
+    - eggs
 script:
     - bin/test -v1j99
 notifications:

src/ZEO/tests/forker.py

@@ -166,9 +166,16 @@ def runner(config, qin, qout, timeout=None,
             ZEO.asyncio.server.best_protocol_version = old_protocol
             ZEO.asyncio.server.ServerProtocol.protocols = old_protocols
 
-def stop_runner(thread, config, qin, qout, stop_timeout=9, pid=None):
+def stop_runner(thread, config, qin, qout, stop_timeout=19, pid=None):
     qin.put('stop')
+    try:
         dirty = qout.get(timeout=stop_timeout)
+    except Empty:
+        print("WARNING Couldn't stop server", file=sys.stderr)
+        if hasattr(thread, 'terminate'):
+            thread.terminate()
+            os.waitpid(thread.pid, 0)
+    else:
         if dirty:
             print("WARNING SERVER DIDN'T STOP CLEANLY", file=sys.stderr)
 
@@ -176,13 +183,11 @@ def stop_runner(thread, config, qin, qout, stop_timeout=9, pid=None):
             # give it some time to exit
             if hasattr(thread, 'pid') and thread.pid:
                 os.waitpid(thread.pid, 0)
-        else:
-            # Gaaaa, force gc in hopes of maybe getting the unclosed
-            # sockets to get GCed
-            gc.collect()
 
     thread.join(stop_timeout)
 
+    gc.collect()
+
 def start_zeo_server(storage_conf=None, zeo_conf=None, port=None, keep=False,
                      path='Data.fs', protocol=None, blob_dir=None,
                      suicide=True, debug=False,