tsave to disk the list of verified transactions - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 10d6db468ab6b9ed11cdc95f171d0adca1c0105f
DIR parent f4b95244c33f8422b05e9f1cfd16bb094ce02597
HTML Author: thomasv <thomasv@gitorious>
Date: Mon, 22 Oct 2012 15:40:39 +0200
save to disk the list of verified transactions
Diffstat:
M lib/wallet.py | 23 ++++++++++++++++-------
1 file changed, 16 insertions(+), 7 deletions(-)
---
DIR diff --git a/lib/wallet.py b/lib/wallet.py
t@@ -943,27 +943,36 @@ class WalletVerifier(threading.Thread):
def __init__(self, wallet, config):
threading.Thread.__init__(self)
self.daemon = True
+ self.config = config
self.wallet = wallet
self.interface = self.wallet.interface
self.interface.register_channel('verifier')
- self.validated = []
- self.merkle_roots = {}
- self.headers = {}
+ self.validated = config.get('verified_tx',[])
+ self.merkle_roots = config.get('merkle_roots',{})
+ self.headers = config.get('block_headers',{})
self.lock = threading.Lock()
+ self.saved = False
def run(self):
requested = []
while True:
txlist = self.wallet.get_tx_hashes()
+
for tx in txlist:
- if tx not in requested:
- requested.append(tx)
- self.request_merkle(tx)
- break
+ if tx not in self.validated:
+ if tx not in requested:
+ requested.append(tx)
+ self.request_merkle(tx)
+ break
+
try:
r = self.interface.get_response('verifier',timeout=1)
except Queue.Empty:
+ if len(self.validated) == len(txlist) and not self.saved:
+ print "verified %d transactions"%len(txlist)
+ self.config.set_key('verified_tx', self.validated, True)
+ self.saved = True
continue
# 3. handle response