chaintool/chainqueue
4
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Allow for sync skip in queue store instantiation

Browse Source
This commit is contained in:
lash 2022-05-04 05:44:47 +00:00
parent b63793fd9b
commit 3a8ec01588
Signed by: lash
GPG Key ID: 21D2E7BB88C2A746
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
chainqueue/store/base.py
View File

@ -29,7 +29,7 @@ all_local_errors = all_errors() - StatusBits.NETWORK_ERROR
re_u = r'^[^_][_A-Z]+$' re_u = r'^[^_][_A-Z]+$'
class Store: class Store:
def __init__(self, chain_spec, state_store, index_store, counter, cache=None): def __init__(self, chain_spec, state_store, index_store, counter, cache=None, sync=True):
self.chain_spec = chain_spec self.chain_spec = chain_spec
self.cache = cache self.cache = cache
self.state_store = state_store self.state_store = state_store
@ -51,6 +51,9 @@ class Store:
]: ]:
setattr(self, v, getattr(self.state_store, v)) setattr(self, v, getattr(self.state_store, v))
if not sync:
return
sync_err = None sync_err = None
try: try:
self.state_store.sync() self.state_store.sync()
@ -106,10 +109,12 @@ class Store:
if item_state & state != item_state: if item_state & state != item_state:
continue continue
logg.info('state {} {}'.format(ref, item_state))
if item_state & not_state > 0: if item_state & not_state > 0:
continue continue
item_state_str = self.state_store.name(item_state)
logg.info('state {} {} ({})'.format(ref, item_state_str, item_state))
if threshold != None: if threshold != None:
v = self.state_store.modified(ref) v = self.state_store.modified(ref)
if v > threshold: if v > threshold:

2
setup.cfg
View File

@ -1,6 +1,6 @@
[metadata] [metadata]
name = chainqueue name = chainqueue
version = 0.1.9 version = 0.1.10
description = Generic blockchain transaction queue control description = Generic blockchain transaction queue control
author = Louis Holbrook author = Louis Holbrook
author_email = dev@holbrook.no author_email = dev@holbrook.no