From 96fe4ca9afc3450f69376518e44f129b971a6759 Mon Sep 17 00:00:00 2001 From: aitbc Date: Thu, 9 Apr 2026 14:05:54 +0200 Subject: [PATCH] feat: add mempool synchronization background task to P2P network service - Added mempool_sync_loop background task initialization in start() method - Registered mempool task in _background_tasks list for lifecycle management - Enables automatic mempool synchronization across P2P mesh network --- apps/blockchain-node/src/aitbc_chain/p2p_network.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/apps/blockchain-node/src/aitbc_chain/p2p_network.py b/apps/blockchain-node/src/aitbc_chain/p2p_network.py index 0a781cee..069e1475 100644 --- a/apps/blockchain-node/src/aitbc_chain/p2p_network.py +++ b/apps/blockchain-node/src/aitbc_chain/p2p_network.py @@ -60,6 +60,10 @@ class P2PNetworkService: # Start background task to broadcast pings to active peers ping_task = asyncio.create_task(self._ping_peers_loop()) self._background_tasks.append(ping_task) + + # Start background task to sync mempool + mempool_task = asyncio.create_task(self._mempool_sync_loop()) + self._background_tasks.append(mempool_task) try: await self._stop_event.wait()