From 882a8d75fb1be3ea4d4e534c4120d43a6dc057e7 Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Wed, 25 Jan 2017 09:21:18 +0000
Subject: [PATCH] Task #10057: log opening/closing rpc connections with address
and broker string
---
LCS/Messaging/python/messaging/RPC.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/LCS/Messaging/python/messaging/RPC.py b/LCS/Messaging/python/messaging/RPC.py
index 81a94cc05bc..ddacc0e6e25 100644
--- a/LCS/Messaging/python/messaging/RPC.py
+++ b/LCS/Messaging/python/messaging/RPC.py
@@ -96,7 +96,7 @@ class RPC():
self.Verbose = kwargs.pop("Verbose", False)
self.BusName = kwargs.pop("busname", None)
self.ServiceName = service
- self.broker = broker
+ self.broker = broker if broker else 'localhost'
if self.BusName is None:
self.Request = ToBus(self.ServiceName, broker=self.broker)
else:
@@ -306,6 +306,7 @@ class RPCWrapper(object):
def close(self):
'''Close all opened rpc connections'''
for rpc in self._serviceRPCs.values():
+ logger.info('closing rpc connection %s at %s', rpc.Request.address, rpc.broker)
rpc.close()
def __enter__(self):
@@ -333,6 +334,7 @@ class RPCWrapper(object):
# not in cache
# so, create RPC for this service method, open it, and cache it
rpc = RPC(service_method, busname=self.busname, broker=self.broker, ForwardExceptions=True, **rpckwargs)
+ logger.info('opening rpc connection %s at %s', rpc.Request.address, rpc.broker)
rpc.open()
self._serviceRPCs[service_method] = rpc
--
GitLab