Rename all 'async' to 'async_' for compatibility with Python 3.7.

Fixes #104.

I don't think any of those attributes were part of ZEO's public API.

CHANGES.rst

@@ -12,6 +12,10 @@ Changelog
   aren't supported on Windows. See `issue 107
   <https://github.com/zopefoundation/ZEO/issues/107>`_.
 
+- Renamed all ``async`` attributes to ``async_`` for compatibility
+  with Python 3.7. See `issue 104
+  <https://github.com/zopefoundation/ZEO/issues/104>`_.
+
 5.1.2 (2018-03-27)
 ------------------
 
@@ -21,7 +25,6 @@ Changelog
   necessary for compatibility with ZODB 5.4.0 on Python 2. See `issue
   107 <https://github.com/zopefoundation/ZEO/issues/107>`_.)
 
-
 5.1.1 (2017-12-18)
 ------------------
 

setup.py

@@ -33,6 +33,7 @@
     'random2',
     'mock',
     'msgpack-python',
+    'zope.testrunner',
 ]
 
 classifiers = """

src/ZEO/ClientStorage.py

@@ -271,7 +271,7 @@ def __init__(self, addr, storage='1', cache_size=20 * MB,
             credentials=credentials,
             )
         self._call = self._server.call
-        self._async = self._server.async
+        self._async = self._server.async_
         self._async_iter = self._server.async_iter
         self._wait = self._server.wait
 

src/ZEO/StorageServer.py

@@ -104,7 +104,7 @@ def notify_connected(self, conn):
         self.connected = True
         assert conn.protocol_version is not None
         self.log_label = _addr_label(conn.addr)
-        self.async = conn.async
+        self.async_ = conn.async_
         self.async_threadsafe = conn.async_threadsafe
 
     def notify_disconnected(self):
@@ -337,7 +337,7 @@ def tpc_finish(self, id):
 
         self.stats.commits += 1
         self.storage.tpc_finish(self.transaction, self._invalidate)
-        self.async('info', self.get_size_info())
+        self.async_('info', self.get_size_info())
         # Note that the tid is still current because we still hold the
         # commit lock. We'll relinquish it in _clear_transaction.
         tid = self.storage.lastTransaction()

src/ZEO/asyncio/client.py

@@ -203,10 +203,10 @@ def finish_connect(self, protocol_version):
 
     exception_type_type = type(Exception)
     def message_received(self, data):
-        msgid, async, name, args = self.decode(data)
+        msgid, async_, name, args = self.decode(data)
         if name == '.reply':
             future = self.futures.pop(msgid)
-            if (async): # ZEO 5 exception
+            if async_: # ZEO 5 exception
                 class_, args = args
                 factory = exc_factories.get(class_)
                 if factory:
@@ -231,7 +231,7 @@ def message_received(self, data):
             else:
                 future.set_result(args)
         else:
-            assert async # clients only get async calls
+            assert async_ # clients only get async calls
             if name in self.client_methods:
                 getattr(self.client, name)(*args)
             else:
@@ -770,7 +770,7 @@ def call_future(self, method, *args):
             self.call_threadsafe, result, True, method, args)
         return result
 
-    def async(self, method, *args):
+    def async_(self, method, *args):
         return self.__call(self.call_async_threadsafe, method, args)
 
     def async_iter(self, it):

src/ZEO/asyncio/server.py

@@ -86,7 +86,7 @@ def call_soon_threadsafe(self, func, *args):
 
     def message_received(self, message):
         try:
-            message_id, async, name, args = self.decode(message)
+            message_id, async_, name, args = self.decode(message)
         except Exception:
             logger.exception("Can't deserialize message")
             self.close()
@@ -104,13 +104,13 @@ def message_received(self, message):
         except Exception as exc:
             if not isinstance(exc, self.unlogged_exception_types):
                 logger.exception(
-                    "Bad %srequest, %r", 'async ' if async else '', name)
-            if async:
+                    "Bad %srequest, %r", 'async ' if async_ else '', name)
+            if async_:
                 return self.close() # No way to recover/cry for help
             else:
                 return self.send_error(message_id, exc)
 
-        if not async:
+        if not async_:
             self.send_reply(message_id, result)
 
     def send_reply(self, message_id, result, send_error=False, flag=0):
@@ -138,7 +138,7 @@ def send_error(self, message_id, exc, send_error=False):
         """
         self.send_reply(message_id, reduce_exception(exc), send_error, 2)
 
-    def async(self, method, *args):
+    def async_(self, method, *args):
         self.call_async(method, args)
 
     def async_threadsafe(self, method, *args):

src/ZEO/asyncio/testing.py

@@ -167,7 +167,10 @@ def start(self, wait=True):
     def call(self, method, *args, **kw):
         return getattr(self, method)(*args)
 
-    async = async_iter = call
+    async_ = async_iter = call
 
     def wait(self, timeout=None):
         pass
+
+    def close(self):
+        pass

src/ZEO/asyncio/tests.py

@@ -112,9 +112,9 @@ def start(self,
 
         return (wrapper, cache, self.loop, self.client, protocol, transport)
 
-    def respond(self, message_id, result, async=False):
+    def respond(self, message_id, result, async_=False):
         self.loop.protocol.data_received(
-            sized(self.encode(message_id, async, '.reply', result)))
+            sized(self.encode(message_id, async_, '.reply', result)))
 
     def wait_for_result(self, future, timeout):
         if future.done() and future.exception() is not None:
@@ -160,7 +160,7 @@ def testClientBasics(self):
         self.assertFalse(f1.done())
 
         # If we try to make an async call, we get an immediate error:
-        self.assertRaises(ClientDisconnected, self.async, 'bar', 3, 4)
+        self.assertRaises(ClientDisconnected, self.async_, 'bar', 3, 4)
 
         # The wrapper object (ClientStorage) hasn't been notified:
         self.assertFalse(wrapper.notify_connected.called)
@@ -191,7 +191,7 @@ def testClientBasics(self):
         self.assertEqual(f1.result(), 42)
 
         # Now we can make async calls:
-        f2 = self.async('bar', 3, 4)
+        f2 = self.async_('bar', 3, 4)
         self.assertTrue(f2.done() and f2.exception() is None)
         self.assertEqual(self.pop(), (0, True, 'bar', (3, 4)))
 
@@ -581,10 +581,10 @@ def test_flow_control(self):
 
         # Give the transport a small capacity:
         transport.capacity = 2
-        self.async('foo')
-        self.async('bar')
-        self.async('baz')
-        self.async('splat')
+        self.async_('foo')
+        self.async_('bar')
+        self.async_('baz')
+        self.async_('splat')
 
         # The first 2 were sent, but the remaining were queued.
         self.assertEqual(self.pop(),

src/ZEO/tests/ZEO4/zrpc/connection.py

@@ -543,7 +543,7 @@ def setSessionKey(self, key):
         else:
             self.__super_setSessionKey(key)
 
-    def send_call(self, method, args, async=False):
+    def send_call(self, method, args, async_=False):
         # send a message and return its msgid
         if async:
             msgid = 0

src/ZEO/tests/testConversionSupport.py

@@ -60,7 +60,7 @@ class FakeConnection(object):
     addr = 'test'
 
     call_soon_threadsafe = lambda f, *a: f(*a)
-    async = async_threadsafe = None
+    async_ = async_threadsafe = None
 
 def test_server_record_iternext():
     """
@@ -123,8 +123,6 @@ def test_client_record_iternext():
     ...
     ...        return oid, oid*8, 'data ' + oid, next
     ...
-    ...    def close(self):
-    ...        pass
 
     >>> client = ZEO.client(
     ...     '', wait=False, _client_factory=Client)

src/ZEO/tests/testTransactionBuffer.py

@@ -40,6 +40,7 @@ def checkTypicalUsage(self):
         store(tbuf)
         for o in tbuf:
             pass
+        tbuf.close()
 
     def checkOrderPreserved(self):
         tbuf = TransactionBuffer(0)

src/ZEO/tests/testZEO.py

@@ -801,11 +801,11 @@ class FauxConn(object):
     peer_protocol_version = protocol_version
 
     serials = []
-    def async(self, method, *args):
+    def async_(self, method, *args):
         if method == 'serialnos':
             self.serials.extend(args[0])
 
-    call_soon_threadsafe = async_threadsafe = async
+    call_soon_threadsafe = async_threadsafe = async_
 
 class StorageServerWrapper(object):
 

src/ZEO/tests/utils.py

@@ -25,10 +25,10 @@ def close(self):
     def call_soon_threadsafe(self, func, *args):
         func(*args)
 
-    def async(self, *args):
+    def async_(self, *args):
         self.calls.append(args)
 
-    async_threadsafe = async
+    async_threadsafe = async_
 
 class StorageServer(object):
     """Create a client interface to a StorageServer.