Require aiorpcX 0.13.6

electrumx/server/controller.py

@@ -82,8 +82,8 @@ class Controller(ServerBase):
         '''Start the RPC server and wait for the mempool to synchronize.  Then
         start serving external clients.
         '''
-        if not (0, 13, 5) <= aiorpcx_version < (0, 14):
-            raise RuntimeError('aiorpcX version 0.13.0, x>=5, is required')
+        if not (0, 13, 6) <= aiorpcx_version < (0, 14):
+            raise RuntimeError('aiorpcX version 0.13.0, x>=6, is required')
 
         env = self.env
         min_str, max_str = env.coin.SESSIONCLS.protocol_min_max_strings()

electrumx/server/session.py

@@ -678,7 +678,7 @@ class SessionBase(RPCSession):
             status += 'C'
         if self.log_me:
             status += 'L'
-        status += str(self._concurrency.max_concurrent)
+        status += str(self._incoming_concurrency.max_concurrent)
         return status
 
     def connection_made(self, transport):
@@ -697,7 +697,7 @@ class SessionBase(RPCSession):
         msg = ''
         if not self._can_send.is_set():
             msg += ' with full socket buffer'
-        if self._concurrency.max_concurrent != self.initial_concurrent:
+        if self._incoming_concurrency.max_concurrent != self.initial_concurrent:
             msg += ' whilst throttled'
         if self.send_size >= 1024*1024:
             msg += ('.  Sent {:,d} bytes in {:,d} messages'