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

Fix transaction count in collective

Browse Source 
Slave members were not persisting the value to disk
This commit is contained in:
Jarrod Johnson 2018-05-14 15:35:44 -04:00
parent 297513bba7
commit 7a912b31cb
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -408,6 +408,7 @@ def clear_configuration():
cfgleader = None
def follow_channel(channel):
global cfgleader
global _txcount
cfgleader = channel
msg = channel.recv(8)
while msg:
@ -420,10 +421,10 @@ def follow_channel(channel):
raise Exception('Truncated message error')
rpc += nrpc
rpc = cPickle.loads(rpc)
if 'function' in rpc:
globals()[rpc['function']](*rpc['args'])
if 'txcount' in rpc:
_txcount = rpc['txcount']
if 'function' in rpc:
globals()[rpc['function']](*rpc['args'])
if 'xid' in rpc and rpc['xid']:
_pendingchangesets[rpc['xid']].send()
msg = channel.recv(8)