xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-16 20:57:53 +00:00
Code Issues Projects Releases Wiki Activity

Persist the transactioncount

Browse Source 
Needed for eventually ascertaining the viability in selecting leader.
This commit is contained in:
Jarrod Johnson 2018-05-11 11:53:45 -04:00
parent e98ecd9867
commit 7fa431dbc9
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
confluent_server/confluent/config/configmanager.py
View File

@ -446,7 +446,7 @@ def add_collective_member(name, address, fingerprint):
ConfigManager._bg_sync_to_file()
def list_collective():
return iter(_cfgstore['collective'])
return iter(_cfgstore.get('collective', ()))
def get_collective_member(name):
return _cfgstore['collective'][name]
@ -1651,8 +1651,14 @@ class ConfigManager(object):
@classmethod
def _read_from_path(cls):
global _cfgstore
global _txcount
_cfgstore = {}
rootpath = cls._cfgdir
try:
with open(os.path.join(rootpath, 'transactioncount', 'r')) as f:
_txcount = struct.unpack('!Q', f.read())[0]
except IOError:
pass
_load_dict_from_dbm(['collective'], os.path.join(rootpath,
"collective"))
_load_dict_from_dbm(['globals'], os.path.join(rootpath, "globals"))
@ -1697,6 +1703,8 @@ class ConfigManager(object):
def _sync_to_file(cls):
if statelessmode:
return
with open(os.path.join(cls._cfgdir, 'transactioncount'), 'w') as f:
f.write(struct.pack('!Q', _txcount))
if 'dirtyglobals' in _cfgstore:
with _dirtylock:
dirtyglobals = copy.deepcopy(_cfgstore['dirtyglobals'])