kev/Onionr
1
0
Fork 0
Code Issues 24 Pull Requests Projects Releases 2 Wiki Activity

Fix diffuseblocks blocking the event loop

Browse Source
This commit is contained in:
Kevin F 2022-07-25 14:37:39 -05:00
parent e7daaf576f
commit 9b6d1f5dbd
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/gossip/server/diffuseblocks.py
View File

@ -6,7 +6,7 @@ doesn't apply for blocks in the gossip queue that are awaiting
descision to fluff or stem descision to fluff or stem
""" """
from asyncio import IncompleteReadError, wait_for, Queue from asyncio import IncompleteReadError, wait_for, Queue, sleep
import traceback import traceback
from typing import TYPE_CHECKING from typing import TYPE_CHECKING
@ -90,6 +90,7 @@ async def diffuse_blocks(reader: 'StreamReader', writer: 'StreamWriter'):
# Diffuse blocks stored since we started this stream # Diffuse blocks stored since we started this stream
while keep_writing: while keep_writing:
bls = blockdb.get_blocks_after_timestamp(time_offset) bls = blockdb.get_blocks_after_timestamp(time_offset)
await sleep(1) # Must be here to avoid blocking the event loop
for bl in bls: for bl in bls:
await _send_block(bl) await _send_block(bl)
try: try: