diff --git a/server/mempool.py b/server/mempool.py index 45bbba6..591a2aa 100644 --- a/server/mempool.py +++ b/server/mempool.py @@ -49,7 +49,7 @@ class MemPool(util.LoggedClass): initial mempool sync.''' self.prioritized.add(tx_hash) - def resync_daemon_hashes(self, unprocessed, unfetched): + def _resync_daemon_hashes(self, unprocessed, unfetched): '''Re-sync self.txs with the list of hashes in the daemon's mempool. Additionally, remove gone hashes from unprocessed and @@ -90,7 +90,7 @@ class MemPool(util.LoggedClass): unfetched = set() txs = self.txs fetch_size = 800 - process_some = self.async_process_some(unfetched, fetch_size // 2) + process_some = self._async_process_some(fetch_size // 2) await self.daemon.mempool_refresh_event.wait() self.logger.info('beginning processing of daemon mempool. ' @@ -122,7 +122,7 @@ class MemPool(util.LoggedClass): self.prioritized.clear() await self.daemon.mempool_refresh_event.wait() - self.resync_daemon_hashes(unprocessed, unfetched) + self._resync_daemon_hashes(unprocessed, unfetched) self.daemon.mempool_refresh_event.clear() if unfetched: @@ -139,7 +139,7 @@ class MemPool(util.LoggedClass): self.stop = True break - def async_process_some(self, unfetched, limit): + def _async_process_some(self, limit): pending = [] txs = self.txs