From 274b9a2c182e9946d2494b0a647aec78608e321b Mon Sep 17 00:00:00 2001 From: Romuald Juchnowicz-Bierbasz Date: Thu, 28 Nov 2019 13:10:58 +0100 Subject: [PATCH] Do not wait for drain --- src/galaxy/api/jsonrpc.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/src/galaxy/api/jsonrpc.py b/src/galaxy/api/jsonrpc.py index 7861242..d828ef8 100644 --- a/src/galaxy/api/jsonrpc.py +++ b/src/galaxy/api/jsonrpc.py @@ -93,7 +93,6 @@ class Connection(): self._methods = {} self._notifications = {} self._task_manager = TaskManager("jsonrpc server") - self._write_lock = asyncio.Lock() self._last_request_id = 0 self._requests_futures = {} @@ -301,16 +300,11 @@ class Connection(): raise InvalidRequest() def _send(self, data): - async def send_task(data_): - async with self._write_lock: - self._writer.write(data_) - await self._writer.drain() - try: line = self._encoder.encode(data) data = (line + "\n").encode("utf-8") logger.debug("Sending %d byte of data", len(data)) - self._task_manager.create_task(send_task(data), "send") + self._writer.write(data) except TypeError as error: logger.error(str(error))