LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-08-28 16:01:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

transaction lock

Browse source
This commit is contained in:
ecdsa 2013-03-24 07:34:28 +01:00
parent 3dc9677822
commit 29b9ffac4a
1 changed files with 25 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

52
lib/wallet.py
View file

@ -113,6 +113,7 @@ class Wallet:
self.up_to_date = False self.up_to_date = False
self.lock = threading.Lock() self.lock = threading.Lock()
self.transaction_lock = threading.Lock()
self.tx_event = threading.Event() self.tx_event = threading.Event()
if self.seed_version != SEED_VERSION: if self.seed_version != SEED_VERSION:
@ -432,8 +433,7 @@ class Wallet:
for item in tx.outputs: for item in tx.outputs:
addr, value = item addr, value = item
key = tx_hash+ ':%d'%i key = tx_hash+ ':%d'%i
with self.lock: self.prevout_values[key] = value
self.prevout_values[key] = value
i += 1 i += 1
for item in tx.inputs: for item in tx.inputs:
@ -607,19 +607,17 @@ class Wallet:
def receive_tx_callback(self, tx_hash, tx, tx_height): def receive_tx_callback(self, tx_hash, tx, tx_height):
if not self.check_new_tx(tx_hash, tx): if not self.check_new_tx(tx_hash, tx):
# may happen due to pruning # may happen due to pruning
print_error("received transaction that is no longer referenced in history", tx_hash) print_error("received transaction that is no longer referenced in history", tx_hash)
return return
with self.lock: with self.transaction_lock:
self.transactions[tx_hash] = tx self.transactions[tx_hash] = tx
if self.verifier and tx_height>0:
#tx_height = tx.get('height') self.verifier.add(tx_hash, tx_height)
if self.verifier and tx_height>0: self.update_tx_outputs(tx_hash)
self.verifier.add(tx_hash, tx_height)
self.update_tx_outputs(tx_hash)
self.save() self.save()
@ -641,29 +639,29 @@ class Wallet:
def get_tx_history(self): def get_tx_history(self):
with self.lock: with self.transaction_lock:
history = self.transactions.items() history = self.transactions.items()
history.sort(key = lambda x: self.verifier.verified_tx.get(x[0]) if self.verifier.verified_tx.get(x[0]) else (1e12,0,0)) history.sort(key = lambda x: self.verifier.verified_tx.get(x[0]) if self.verifier.verified_tx.get(x[0]) else (1e12,0,0))
result = [] result = []
balance = 0 balance = 0
for tx_hash, tx in history: for tx_hash, tx in history:
is_mine, v, fee = self.get_tx_value(tx) is_mine, v, fee = self.get_tx_value(tx)
if v is not None: balance += v if v is not None: balance += v
c, u = self.get_balance() c, u = self.get_balance()
if balance != c+u: if balance != c+u:
v_str = format_satoshis( c+u - balance, True, self.num_zeros) v_str = format_satoshis( c+u - balance, True, self.num_zeros)
result.append( ('', 1000, 0, c+u-balance, None, c+u-balance, None ) ) result.append( ('', 1000, 0, c+u-balance, None, c+u-balance, None ) )
balance = c + u - balance balance = c + u - balance
for tx_hash, tx in history: for tx_hash, tx in history:
conf, timestamp = self.verifier.get_confirmations(tx_hash) if self.verifier else (None, None) conf, timestamp = self.verifier.get_confirmations(tx_hash) if self.verifier else (None, None)
is_mine, value, fee = self.get_tx_value(tx) is_mine, value, fee = self.get_tx_value(tx)
if value is not None: if value is not None:
balance += value balance += value
result.append( (tx_hash, conf, is_mine, value, fee, balance, timestamp) ) result.append( (tx_hash, conf, is_mine, value, fee, balance, timestamp) )
return result return result