print_log('initializing database')
self.height = 0
self.last_hash = '000000000019d6689c085ae165831e934ff763ae46a2a6c172b3f1b60a8ce26f'
+ db_version = self.db_version
# check version
if self.db_version != db_version:
shared.stop()
sys.exit(0)
- print_log("blockchain is up to date.")
+ print_log("Blockchain is up to date.")
+ self.memorypool_update()
+ print_log("Memory pool initialized.")
threading.Timer(10, self.main_iteration).start()
for i in range(l-1, -1, -1):
item = serialized_hist[80*i:80*(i+1)]
item_height = int(rev_hex(item[36:39].encode('hex')), 16)
- if item_height < tx_height:
+ if item_height <= tx_height:
serialized_hist = serialized_hist[0:80*(i+1)] + s + serialized_hist[80*(i+1):]
break
else:
serialized_hist = serialized_hist[0:80*i] + new_item + serialized_hist[80*(i+1):]
break
else:
+ self.shared.stop()
hist = self.deserialize(serialized_hist)
raise BaseException("prevout not found", addr, hist, txi.encode('hex'))
for txi in block_inputs:
try:
addr = self.db.Get(txi)
- except:
- # print "addr not in db", txi.encode('hex')
+ except KeyError:
# the input could come from the same block
continue
+ except:
+ traceback.print_exc(file=sys.stdout)
+ self.shared.stop()
+ raise
+
self.batch_txio[txi] = addr
addr_to_read.append(addr)
for addr in addr_to_read:
try:
self.batch_list[addr] = self.db.Get(addr)
- except:
+ except KeyError:
self.batch_list[addr] = ''
+ except:
+ traceback.print_exc(file=sys.stdout)
+ self.shared.stop()
+ raise
# process
def memorypool_update(self):
mempool_hashes = self.bitcoind('getrawmempool')
+ touched_addresses = []
for tx_hash in mempool_hashes:
if tx_hash in self.mempool_hashes:
continue
try:
addr = self.db.Get(txi)
except:
- continue
+ tx_prev = self.get_mempool_transaction(x.get('prevout_hash'))
+ try:
+ addr = tx_prev['outputs'][x.get('prevout_n')]['address']
+ if not addr: continue
+ except:
+ continue
l = self.mempool_addresses.get(tx_hash, [])
if addr not in l:
l.append(addr)
self.mempool_addresses[tx_hash] = l
+ #if addr not in touched_addresses:
+ touched_addresses.append(addr)
for x in tx.get('outputs'):
addr = x.get('address')
if addr not in l:
l.append(addr)
self.mempool_addresses[tx_hash] = l
+ #if addr not in touched_addresses:
+ touched_addresses.append(addr)
self.mempool_hashes.append(tx_hash)
for tx_hash, addresses in self.mempool_addresses.items():
if tx_hash not in self.mempool_hashes:
self.mempool_addresses.pop(tx_hash)
+ for addr in addresses:
+ #if addr not in touched_addresses:
+ touched_addresses.append(addr)
# rebuild mempool histories
new_mempool_hist = {}
h.append(tx_hash)
new_mempool_hist[addr] = h
- # invalidate cache for mempool addresses whose mempool history has changed
- new_mempool_hist_keys = new_mempool_hist.keys()
- self_mempool_hist_keys = self.mempool_hist.keys()
-
- for addr in new_mempool_hist_keys:
- if addr in self_mempool_hist_keys:
- if self.mempool_hist[addr] != new_mempool_hist[addr]:
- self.invalidate_cache(addr)
- else:
- self.invalidate_cache(addr)
-
- # invalidate cache for addresses that are removed from mempool ?
- # this should not be necessary if they go into a block, but they might not
- for addr in self_mempool_hist_keys:
- if addr not in new_mempool_hist_keys:
- self.invalidate_cache(addr)
-
-
with self.mempool_lock:
self.mempool_hist = new_mempool_hist
+ # invalidate cache for touched addresses
+ for addr in touched_addresses:
+ self.invalidate_cache(addr)
+
+
def invalidate_cache(self, address):
with self.cache_lock:
if address in self.history_cache:
self.history_cache.pop(address)
if address in self.watched_addresses:
+ # TODO: update cache here. if new value equals cached value, do not send notification
self.address_queue.put(address)
def main_iteration(self):
t2 = time.time()
self.memorypool_update()
- t3 = time.time()
- # print "mempool:", len(self.mempool_addresses), len(self.mempool_hist), "%.3fs"%(t3 - t2)
if self.sent_height != self.height:
self.sent_height = self.height