diff options
| author | Yulia Portnova <yportnova@mirantis.com> | 2016-01-18 14:36:50 +0200 |
|---|---|---|
| committer | Yulia Portnova <yportnova@mirantis.com> | 2016-01-18 14:36:50 +0200 |
| commit | 39729e423d8b7ae9c99d8a22ae605f1079778107 (patch) | |
| tree | e7573a044f09de41f2d73daf48f6cd1a717a2e13 /tools/simulator.py | |
| parent | e9abc3e5da4813eb1f6afb9254644d157660c8a9 (diff) | |
| download | oslo-messaging-39729e423d8b7ae9c99d8a22ae605f1079778107.tar.gz | |
Logging rpc client/server targets
Change-Id: Ief8cb50af58bba886cb02c309b8254ffc685c5cc
Diffstat (limited to 'tools/simulator.py')
| -rwxr-xr-x | tools/simulator.py | 2 |
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() |