PTV/ptvp35
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases 4 Wiki Activity

prevent impossible deadlock

Browse Source
This commit is contained in:
AF 2022-11-17 15:01:50 +00:00
parent f7c167f120
commit 6262dd28e9
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ptvp35/__init__.py
View File

@ -162,7 +162,7 @@ class DbConnection:
await self._dump_buffer() await self._dump_buffer()
request.set_result(None) request.set_result(None)
else: else:
await self.__queue.put(DumpRequest(request.future)) self.__queue.put_nowait(DumpRequest(request.future))
async def _write(self, line: str, request: Request): async def _write(self, line: str, request: Request):
self.__buffer.write(line) self.__buffer.write(line)