return block_number
+ def catch_up(store):
+ # if there is an exception, do rollback and then re-raise the exception
+ for dircfg in store.datadirs:
+ try:
+ store.catch_up_dir(dircfg)
+ except Exception, e:
+ store.log.exception("Failed to catch up %s", dircfg)
+ store.rollback()
+ raise e
+
+
+
+
from processor import Processor
class BlockchainProcessor(Processor):
if self.block_number != old_block_number:
old_block_number = self.block_number
+ print "block number:", self.block_number
self.push_response({ 'method':'blockchain.numblocks.subscribe', 'params':[self.block_number] })
while True: