From 5a5f0169a7c30ff3e9ce55afa1a0601e057563a5 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 22 Jun 2018 15:46:41 -0400 Subject: [PATCH] Fix logic on null messages --- confluent_server/confluent/config/configmanager.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index e6374bcd..a2c31048 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -460,10 +460,10 @@ def relay_slaved_requests(name, listener): if not nrpc: raise Exception('Truncated client error') rpc += nrpc - rpc = cPickle.loads(rpc) - globals()[rpc['function']](*rpc['args']) - if 'xid' in rpc: - _push_rpc(listener, cPickle.dumps({'xid': rpc['xid']})) + rpc = cPickle.loads(rpc) + globals()[rpc['function']](*rpc['args']) + if 'xid' in rpc: + _push_rpc(listener, cPickle.dumps({'xid': rpc['xid']})) msg = listener.recv(8)