aljaz/python-teos
1
0
Fork 0
mirror of https://github.com/aljazceru/python-teos.git synced 2026-02-12 10:04:41 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fixes bootstrap from backed up data

Browse Source
This commit is contained in:
Sergi Delgado Segura
2019-12-27 12:22:07 +01:00
parent 57d5aa4940
commit 5ce5936fc0
1 changed files with 28 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
pisa/pisad.py
View File

@@ -64,20 +64,37 @@ if __name__ == "__main__":
last_block_watcher = db_manager.load_last_block_hash_watcher() last_block_watcher = db_manager.load_last_block_hash_watcher()
last_block_responder = db_manager.load_last_block_hash_responder() last_block_responder = db_manager.load_last_block_hash_responder()
missed_blocks_watcher = block_processor.get_missed_blocks(last_block_watcher) # FIXME: 32-reorgs-offline dropped txs are not used at this point.
missed_blocks_responder = (
missed_blocks_watcher
if last_block_watcher == last_block_responder
else block_processor.get_missed_blocks(last_block_responder)
)
responder = Responder(db_manager) responder = Responder(db_manager)
responder.trackers, responder.tx_tracker_map = Builder.build_trackers(responder_trackers_data) last_common_ancestor_responder = None
responder.block_queue = Builder.build_block_queue(missed_blocks_responder) missed_blocks_responder = None
# Build Responder with backed up data if found
if last_block_responder is not None:
last_common_ancestor_responder, dropped_txs_responder = block_processor.find_last_common_ancestor(
last_block_responder
)
missed_blocks_responder = block_processor.get_missed_blocks(last_common_ancestor_responder)
responder.trackers, responder.tx_tracker_map = Builder.build_trackers(responder_trackers_data)
responder.block_queue = Builder.build_block_queue(missed_blocks_responder)
# Build Watcher with Responder and backed up data. If the blocks of both match we don't perform the
# search twice.
watcher.responder = responder watcher.responder = responder
watcher.appointments, watcher.locator_uuid_map = Builder.build_appointments(watcher_appointments_data) if last_block_watcher is not None:
watcher.block_queue = Builder.build_block_queue(missed_blocks_watcher) if last_block_watcher == last_block_responder:
missed_blocks_watcher = missed_blocks_responder
else:
last_common_ancestor_watcher, dropped_txs_watcher = block_processor.find_last_common_ancestor(
last_block_watcher
)
missed_blocks_watcher = block_processor.get_missed_blocks(last_common_ancestor_watcher)
watcher.appointments, watcher.locator_uuid_map = Builder.build_appointments(
watcher_appointments_data
)
watcher.block_queue = Builder.build_block_queue(missed_blocks_watcher)
# Fire the API # Fire the API
API(watcher).start() API(watcher).start()