From 807853c417e7c06ed6108704ac30bcc6c29f3b05 Mon Sep 17 00:00:00 2001 From: Guilherme Salgado Date: Fri, 20 Jul 2018 11:14:38 +0100 Subject: [PATCH] p2p: Add some more logging statements to ChainSyncer To help debug sync issues --- p2p/chain.py | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/p2p/chain.py b/p2p/chain.py index b064421218..40c6463e17 100644 --- a/p2p/chain.py +++ b/p2p/chain.py @@ -415,6 +415,8 @@ async def _download_block_parts( download_queue.get(), timeout=self._reply_timeout) except TimeoutError: + self.logger.info( + "Timed out waiting for %d missing %s", len(missing), part_name) pending_replies = request_func(target_td, missing) continue @@ -427,9 +429,9 @@ async def _download_block_parts( pending_replies -= 1 if unexpected: - self.logger.debug("Got unexpected %s from %s: %s", part_name, peer, unexpected) + self.logger.debug("Got %d unexpected %s from %s", len(unexpected), part_name, peer) if duplicates: - self.logger.debug("Got duplicate %s from %s: %s", part_name, peer, duplicates) + self.logger.debug("Got %d duplicate %s from %s", len(duplicates), part_name, peer) missing = [ header @@ -454,11 +456,15 @@ def _request_block_parts( return len(batches) def _send_get_block_bodies(self, peer: ETHPeer, headers: List[BlockHeader]) -> None: - self.logger.debug("Requesting %d block bodies to %s", len(headers), peer) + block_numbers = ", ".join(str(h.block_number) for h in headers) + self.logger.debug( + "Requesting %d block bodies (%s) to %s", len(headers), block_numbers, peer) peer.sub_proto.send_get_block_bodies([header.hash for header in headers]) def _send_get_receipts(self, peer: ETHPeer, headers: List[BlockHeader]) -> None: - self.logger.debug("Requesting %d block receipts to %s", len(headers), peer) + block_numbers = ", ".join(str(h.block_number) for h in headers) + self.logger.debug( + "Requesting %d block receipts (%s) to %s", len(headers), block_numbers, peer) peer.sub_proto.send_get_receipts([header.hash for header in headers]) def request_bodies(self, target_td: int, headers: List[BlockHeader]) -> int: