code: async def _cleanup_old_connections(self):
          
  
          retval = await self._command_task.future_command(['_query_systemstate'])
  
          for conn in retval['active_connections']:
              self._logger.info("Forcible disconnecting connection %d", conn)
              await self._command_task.future_command(['_disconnect', conn])
docs: Remove all active connections and query the maximum number of supported connections