Changeset View
Changeset View
Standalone View
Standalone View
test/functional/abc_p2p_compactproofs.py
Show First 20 Lines • Show All 513 Lines • ▼ Show 20 Lines | def test_send_missing_proofs(self): | ||||
req = msg_avaproofsreq() | req = msg_avaproofsreq() | ||||
req.indices = range(numof_proof) | req.indices = range(numof_proof) | ||||
slow_peer.send_and_ping(req) | slow_peer.send_and_ping(req) | ||||
# Check we get no proof | # Check we get no proof | ||||
assert_equal(len(slow_peer.get_proofs()), 0) | assert_equal(len(slow_peer.get_proofs()), 0) | ||||
# The proof tree is cleaned up only once | |||||
for _ in range(3): | |||||
with node.assert_debug_log(["sending pong"], [f"Cleaning up timed out compact proofs from peer {slow_peer.nodeid}"]): | |||||
node.mockscheduler(AVALANCHE_MAX_PERIODIC_NETWORKING_INTERVAL) | |||||
slow_peer.sync_with_ping() | |||||
def test_compact_proofs_download_on_connect(self): | def test_compact_proofs_download_on_connect(self): | ||||
self.log.info( | self.log.info( | ||||
"Check the node get compact proofs upon avalanche outbound discovery") | "Check the node get compact proofs upon avalanche outbound discovery") | ||||
requestee = self.nodes[0] | requestee = self.nodes[0] | ||||
requester = self.nodes[1] | requester = self.nodes[1] | ||||
self.restart_node(0) | self.restart_node(0) | ||||
▲ Show 20 Lines • Show All 66 Lines • Show Last 20 Lines |