Remove unnecessary delta_count variable.
This commit is contained in:
parent
193b22b754
commit
57ca26867b
|
@ -95,7 +95,7 @@ def main():
|
||||||
if interrupted:
|
if interrupted:
|
||||||
print("Supply check was interrupted; supply delta evaluation incomplete.")
|
print("Supply check was interrupted; supply delta evaluation incomplete.")
|
||||||
else:
|
else:
|
||||||
print("Blocks with unclaimed balance: {}".format(deltas.delta_count))
|
print("Blocks with unclaimed balance: {}".format(len(deltas.delta_cache)))
|
||||||
print("Unclaimed total: {} ZEC".format(deltas.delta_total / COIN))
|
print("Unclaimed total: {} ZEC".format(deltas.delta_total / COIN))
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
|
|
|
@ -7,7 +7,6 @@ class SupplyDeltas:
|
||||||
self.fr_addrs = fr_addrs
|
self.fr_addrs = fr_addrs
|
||||||
self.miner_deltas = miner_deltas
|
self.miner_deltas = miner_deltas
|
||||||
|
|
||||||
self.delta_count = 0
|
|
||||||
self.delta_total = 0
|
self.delta_total = 0
|
||||||
self.delta_cache = []
|
self.delta_cache = []
|
||||||
self.flush_interval = flush_interval
|
self.flush_interval = flush_interval
|
||||||
|
@ -19,7 +18,6 @@ class SupplyDeltas:
|
||||||
def AddSupplyDelta(self, deltaHeight, delta):
|
def AddSupplyDelta(self, deltaHeight, delta):
|
||||||
assert len(self.delta_cache) == 0 or deltaHeight > self.delta_cache[-1][0]
|
assert len(self.delta_cache) == 0 or deltaHeight > self.delta_cache[-1][0]
|
||||||
|
|
||||||
self.delta_count += 1
|
|
||||||
self.delta_total += delta
|
self.delta_total += delta
|
||||||
self.delta_cache.append((deltaHeight, self.delta_total))
|
self.delta_cache.append((deltaHeight, self.delta_total))
|
||||||
|
|
||||||
|
@ -46,8 +44,8 @@ class SupplyDeltas:
|
||||||
if len(miner_addrs) > 0:
|
if len(miner_addrs) > 0:
|
||||||
self.miner_deltas.setdefault(",".join(sorted(miner_addrs)), []).append((height, delta))
|
self.miner_deltas.setdefault(",".join(sorted(miner_addrs)), []).append((height, delta))
|
||||||
self.AddSupplyDelta(height, delta)
|
self.AddSupplyDelta(height, delta)
|
||||||
if self.delta_count % 500 == 0:
|
if len(self.delta_cache) % 500 == 0:
|
||||||
with open("delta_cache.{}.out".format(self.delta_count), 'w', encoding="utf8") as f:
|
with open("delta_cache.{}.out".format(len(self.delta_cache)), 'w', encoding="utf8") as f:
|
||||||
pprint.pprint(self.miner_deltas, stream = f, indent = 4)
|
pprint.pprint(self.miner_deltas, stream = f, indent = 4)
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
|
Loading…
Reference in New Issue