summaryrefslogtreecommitdiff
path: root/tools
diff options
context:
space:
mode:
authorYulia Portnova <yportnova@mirantis.com>2016-01-18 14:36:50 +0200
committerYulia Portnova <yportnova@mirantis.com>2016-01-18 14:36:50 +0200
commit39729e423d8b7ae9c99d8a22ae605f1079778107 (patch)
treee7573a044f09de41f2d73daf48f6cd1a717a2e13 /tools
parente9abc3e5da4813eb1f6afb9254644d157660c8a9 (diff)
downloadoslo-messaging-39729e423d8b7ae9c99d8a22ae605f1079778107.tar.gz
Logging rpc client/server targets
Change-Id: Ief8cb50af58bba886cb02c309b8254ffc685c5cc
Diffstat (limited to 'tools')
-rwxr-xr-xtools/simulator.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/tools/simulator.py b/tools/simulator.py
index 93a649c..779543f 100755
--- a/tools/simulator.py
+++ b/tools/simulator.py
@@ -230,6 +230,7 @@ def rpc_server(transport, target, wait_before_answer, executor, show_stats,
endpoints = [RpcEndpoint(wait_before_answer, show_stats)]
server = rpc.get_rpc_server(transport, target, endpoints,
executor=executor)
+ LOG.debug("starting RPC server for target %s", target)
server.start()
if duration:
start_t = time.time()
@@ -249,6 +250,7 @@ def spawn_rpc_clients(threads, transport, targets,
targets = itertools.cycle(targets)
for i in range(0, threads):
target = targets.next()
+ LOG.debug("starting RPC client for target %s", target)
p.spawn_n(send_msg, i, transport, target, *args, **kwargs)
p.waitall()