Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
637ead1a38
|
||
|
|
412018fc64
|
||
|
|
95663621bc
|
||
|
|
0726f7a730
|
@@ -1,3 +1,9 @@
|
|||||||
|
* 0.4.8
|
||||||
|
- Add unlock action description to info loglevel for unlock tool
|
||||||
|
* 0.4.7
|
||||||
|
- Upgrade shep to avoid sync in persist set
|
||||||
|
* 0.4.6
|
||||||
|
- Upgrade shep to handle filesystem list exception
|
||||||
* 0.4.5
|
* 0.4.5
|
||||||
- Upgrade chainlib
|
- Upgrade chainlib
|
||||||
- Upgrade shep to guarantee atomic state locks
|
- Upgrade shep to guarantee atomic state locks
|
||||||
|
|||||||
@@ -329,7 +329,8 @@ class SyncStore:
|
|||||||
if locked_item_key == None:
|
if locked_item_key == None:
|
||||||
return False
|
return False
|
||||||
locked_item = self.get(locked_item_key)
|
locked_item = self.get(locked_item_key)
|
||||||
locked_state = self.filter_state.state(locked_item_key) - self.filter_state.state_store.LOCK
|
state = self.filter_state.state(locked_item_key)
|
||||||
|
locked_state = state - self.filter_state.state_store.LOCK
|
||||||
locked_state_name = self.filter_state.name(locked_state)
|
locked_state_name = self.filter_state.name(locked_state)
|
||||||
|
|
||||||
logg.debug('found locked item {} in state {}'.format(locked_item, locked_state))
|
logg.debug('found locked item {} in state {}'.format(locked_item, locked_state))
|
||||||
@@ -339,10 +340,17 @@ class SyncStore:
|
|||||||
if i == -1:
|
if i == -1:
|
||||||
raise FilterInitializationError('locked state {} ({}) found for item {}, but matching filter has not been registered'.format(locked_state_name, locked_state, locked_item))
|
raise FilterInitializationError('locked state {} ({}) found for item {}, but matching filter has not been registered'.format(locked_state_name, locked_state, locked_item))
|
||||||
|
|
||||||
|
direction = None
|
||||||
if revert:
|
if revert:
|
||||||
self.__unlock_previous(locked_item, fltrs, i)
|
self.__unlock_previous(locked_item, fltrs, i)
|
||||||
|
new_state = self.filter_state.state(locked_item_key)
|
||||||
|
direction = 'previous'
|
||||||
else:
|
else:
|
||||||
self.__unlock_next(locked_item, fltrs, i)
|
self.__unlock_next(locked_item, fltrs, i)
|
||||||
|
new_state = self.filter_state.state(locked_item_key)
|
||||||
|
direction = 'next'
|
||||||
|
|
||||||
|
logg.info('chainstate unlock to {} {} ({}) -> {} ({})'.format(direction, self.filter_state.name(state), state, self.filter_state.name(new_state), new_state))
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
|||||||
@@ -2,4 +2,4 @@ confini~=0.6.0
|
|||||||
semver==2.13.0
|
semver==2.13.0
|
||||||
hexathon~=0.1.6
|
hexathon~=0.1.6
|
||||||
chainlib~=0.1.2
|
chainlib~=0.1.2
|
||||||
shep~=0.2.6
|
shep~=0.2.8
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[metadata]
|
[metadata]
|
||||||
name = chainsyncer
|
name = chainsyncer
|
||||||
version = 0.4.5
|
version = 0.4.8
|
||||||
description = Generic blockchain syncer driver
|
description = Generic blockchain syncer driver
|
||||||
author = Louis Holbrook
|
author = Louis Holbrook
|
||||||
author_email = dev@holbrook.no
|
author_email = dev@holbrook.no
|
||||||
|
|||||||
Reference in New Issue
Block a user