From 3852b15c8960e322891b369f9278c954607acd67 Mon Sep 17 00:00:00 2001 From: Kevin F Date: Tue, 27 Sep 2022 00:49:25 +0000 Subject: [PATCH] Fix gossip server not closing connections --- src/gossip/server/__init__.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/gossip/server/__init__.py b/src/gossip/server/__init__.py index 8a361fb0..23012d8f 100644 --- a/src/gossip/server/__init__.py +++ b/src/gossip/server/__init__.py @@ -120,14 +120,13 @@ def gossip_server(): if blockdb.has_block(block_id): writer.write(int(0).to_bytes(1, 'big')) else: - writer.write(int(1).to_bytes(1, 'big')) await writer.drain() block_size = int(await asyncio.wait_for(reader.readexactly(constants.BLOCK_SIZE_LEN), 30)) block_data = await reader.readexactly(block_size) Thread( - target=add_block_to_db, + target=add_block_to_db, args=[ Block(block_id, block_data, auto_verify=True)] ).start() @@ -137,6 +136,7 @@ def gossip_server(): await writer.drain() except BrokenPipeError: pass + writer.close() async def main():