From 52e2038fdfff308a4d2d5d768b2f8cf25f1890b3 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 14 May 2018 15:35:44 -0400 Subject: [PATCH] Fix transaction count in collective Slave members were not persisting the value to disk --- confluent_server/confluent/config/configmanager.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 59c98d68..46e95100 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -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)