openstack/oslo.messaging
Code Issues Proposed changes

Logging rpc client/server targets

Browse Source 
Change-Id: Ief8cb50af58bba886cb02c309b8254ffc685c5cc
This commit is contained in:
Yulia Portnova 2016-01-18 14:36:50 +02:00
parent e9abc3e5da
commit 39729e423d
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tools/simulator.py
View File

@ -230,6 +230,7 @@ def rpc_server(transport, target, wait_before_answer, executor, show_stats,
endpoints = [RpcEndpoint(wait_before_answer, show_stats)] endpoints = [RpcEndpoint(wait_before_answer, show_stats)]
server = rpc.get_rpc_server(transport, target, endpoints, server = rpc.get_rpc_server(transport, target, endpoints,
executor=executor) executor=executor)
LOG.debug("starting RPC server for target %s", target)
server.start() server.start()
if duration: if duration:
start_t = time.time() start_t = time.time()
@ -249,6 +250,7 @@ def spawn_rpc_clients(threads, transport, targets,
targets = itertools.cycle(targets) targets = itertools.cycle(targets)
for i in range(0, threads): for i in range(0, threads):
target = targets.next() target = targets.next()
LOG.debug("starting RPC client for target %s", target)
p.spawn_n(send_msg, i, transport, target, *args, **kwargs) p.spawn_n(send_msg, i, transport, target, *args, **kwargs)
p.waitall() p.waitall()