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
|
||||
- Upgrade chainlib
|
||||
- Upgrade shep to guarantee atomic state locks
|
||||
|
||||
@@ -329,7 +329,8 @@ class SyncStore:
|
||||
if locked_item_key == None:
|
||||
return False
|
||||
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)
|
||||
|
||||
logg.debug('found locked item {} in state {}'.format(locked_item, locked_state))
|
||||
@@ -339,10 +340,17 @@ class SyncStore:
|
||||
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))
|
||||
|
||||
direction = None
|
||||
if revert:
|
||||
self.__unlock_previous(locked_item, fltrs, i)
|
||||
new_state = self.filter_state.state(locked_item_key)
|
||||
direction = 'previous'
|
||||
else:
|
||||
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
|
||||
|
||||
|
||||
@@ -2,4 +2,4 @@ confini~=0.6.0
|
||||
semver==2.13.0
|
||||
hexathon~=0.1.6
|
||||
chainlib~=0.1.2
|
||||
shep~=0.2.6
|
||||
shep~=0.2.8
|
||||
|
||||
Reference in New Issue
Block a user