diff --git a/FofbTool/Operation.py b/FofbTool/Operation.py index c33f7bbe98a0a24769794d956ff5ea7388ae1baa..d5a3f39245571af894dbac21993e43350767f4c5 100644 --- a/FofbTool/Operation.py +++ b/FofbTool/Operation.py @@ -127,8 +127,12 @@ def stop_ccn(node_tangopath, ccnif=[]): logger.info("Stopping CCN on {}".format(node_tangopath)) for n in ccnif: - prx["ccnpack{}_control".format(n)] = False - prx["ccnunpack{}_control".format(n)] = False + if 'central' in node_tangopath: + prx["ccnunpack{}_control".format(n)] = False + prx["ccnpack{}_control".format(n)] = False + else: + prx["ccnpack{}_control".format(n)] = False + prx["ccnunpack{}_control".format(n)] = False def reset_ccn(node_tangopath, ccnif=[]): """ @@ -195,8 +199,12 @@ def start_ccn(node_tangopath, ccnif=[]): ack_ccn(node_tangopath, ccnif) for n in ccnif: - prx["ccnpack{}_control".format(n)] = 1 - prx["ccnunpack{}_control".format(n)] = 1 + if 'central' in node_tangopath: + prx["ccnunpack{}_control".format(n)] = 1 + prx["ccnpack{}_control".format(n)] = 1 + else: + prx["ccnpack{}_control".format(n)] = 1 + prx["ccnunpack{}_control".format(n)] = 1 def ack_ccn(node_tangopath, ccnif=[]): """