From 25ddab1b7178a598e3b81bdceb84c3988a5d2a37 Mon Sep 17 00:00:00 2001 From: Forrest Voight Date: Fri, 9 Dec 2011 17:47:43 -0500 Subject: [PATCH] added argument to HeightTracker for minimum distance back to track --- p2pool/bitcoin/p2p.py | 7 ++++--- 1 files changed, 4 insertions(+), 3 deletions(-) diff --git a/p2pool/bitcoin/p2p.py b/p2pool/bitcoin/p2p.py index b8a3b6a..e3b7e8e 100644 --- a/p2pool/bitcoin/p2p.py +++ b/p2pool/bitcoin/p2p.py @@ -299,9 +299,10 @@ class HeaderWrapper(object): class HeightTracker(object): '''Point this at a factory and let it take care of getting block heights''' - def __init__(self, rpc_proxy, factory): + def __init__(self, rpc_proxy, factory, backlog_needed=1000): self._rpc_proxy = rpc_proxy self._factory = factory + self._backlog_needed = backlog_needed self._tracker = forest.Tracker() @@ -324,7 +325,7 @@ class HeightTracker(object): if highest_head is None: return # wait for think2 height, last = self._tracker.get_height_and_last(highest_head) - if height < 1000: + if height < self._backlog_needed: self._request(last) @defer.inlineCallbacks @@ -345,7 +346,7 @@ class HeightTracker(object): self._think() if len(self._tracker.shares) >= self._last_notified_size + 100: - print 'Have %i/1000 block headers' % len(self._tracker.shares) + print 'Have %i/%i block headers' % (len(self._tracker.shares), self._backlog_needed) self._last_notified_size = len(self._tracker.shares) def _heard_block(self, block_hash): -- 1.7.1