|
@@ -67,7 +67,7 @@ class StandardNode(Node):
|
|
self.current_topology.active_node_id = None
|
|
self.current_topology.active_node_id = None
|
|
download_progress = None
|
|
download_progress = None
|
|
if status_data.get("type", "") == "download_progress":
|
|
if status_data.get("type", "") == "download_progress":
|
|
- if DEBUG >= 5: print(f"Download progress from {status_data.get('node_id')}: {status_data.get('progress')}")
|
|
|
|
|
|
+ if DEBUG >= 8: print(f"Download progress from {status_data.get('node_id')}: {status_data.get('progress')}")
|
|
download_progress = RepoProgressEvent.from_dict(status_data.get('progress'))
|
|
download_progress = RepoProgressEvent.from_dict(status_data.get('progress'))
|
|
self.node_download_progress[status_data.get('node_id')] = download_progress
|
|
self.node_download_progress[status_data.get('node_id')] = download_progress
|
|
if self.topology_viz:
|
|
if self.topology_viz:
|
|
@@ -414,7 +414,7 @@ class StandardNode(Node):
|
|
await asyncio.gather(*[send_result_to_peer(peer) for peer in self.peers], return_exceptions=True)
|
|
await asyncio.gather(*[send_result_to_peer(peer) for peer in self.peers], return_exceptions=True)
|
|
|
|
|
|
async def broadcast_opaque_status(self, request_id: str, status: str) -> None:
|
|
async def broadcast_opaque_status(self, request_id: str, status: str) -> None:
|
|
- if DEBUG >= 5: print(f"Broadcasting opaque status: {request_id=} {status=}")
|
|
|
|
|
|
+ if DEBUG >= 8: print(f"Broadcasting opaque status: {request_id=} {status=}")
|
|
|
|
|
|
async def send_status_to_peer(peer):
|
|
async def send_status_to_peer(peer):
|
|
try:
|
|
try:
|