OLD | NEW |
1 #!/usr/bin/python | 1 #!/usr/bin/python |
2 | 2 |
3 import sys | 3 import sys |
4 import exceptions | 4 import exceptions |
5 import time | 5 import time |
6 | 6 |
7 from py4j.java_gateway import JavaGateway | 7 from py4j.java_gateway import JavaGateway |
8 | 8 |
9 gateway = JavaGateway() | 9 gateway = JavaGateway() |
10 app = gateway.entry_point | 10 app = gateway.entry_point |
11 mode = sys.argv[1] | 11 mode = sys.argv[1] |
12 sender_name = sys.argv[2] | 12 sender_name = sys.argv[2] |
13 node_a_name = sys.argv[3] | 13 node_a_name = sys.argv[3] |
14 node_a_ip = sys.argv[4] | 14 node_a_ip = sys.argv[4] |
15 node_b_name = sys.argv[5] | 15 node_b_name = sys.argv[5] |
16 node_b_ip = sys.argv[6] | 16 node_b_ip = sys.argv[6] |
17 val = int(sys.argv[7]) # latency or jitter | 17 val = int(sys.argv[7]) # latency or jitter |
18 | 18 |
19 | 19 print('[{7}: NOTIFIED Node: {0}][{1}={2}] Node A :{3}[{4}], Node B:{5}[{6}]'. |
20 print( | 20 format(sender_name, mode, val, node_a_name, node_a_ip, node_b_name, |
21 '[{7}: NOTIFIED Node: {0}][{1}={2}] Node A :{3}[{4}], Node B:{5}[{6}]'.forma
t( | 21 node_b_ip, int(time.time()))) |
22 sender_name, mode, val, node_a_name, node_a_ip, node_b_name, node_b_ip, | |
23 int(time.time()) | |
24 ) | |
25 ) | |
26 if mode == 'latency': | 22 if mode == 'latency': |
27 app.latencyChanged(node_a_name, node_a_ip, node_b_name, node_b_ip, val) | 23 app.latencyChanged(node_a_name, node_a_ip, node_b_name, node_b_ip, val) |
28 elif mode == 'jitter': | 24 elif mode == 'jitter': |
29 app.jitterChanged(node_a_name, node_a_ip, node_b_name, node_b_ip, val) | 25 app.jitterChanged(node_a_name, node_a_ip, node_b_name, node_b_ip, val) |
30 else: | 26 else: |
31 raise exceptions.Exception('Error: mode must be either latency or jitter') | 27 raise exceptions.Exception('Error: mode must be either latency or jitter') |
32 gateway.close() | 28 gateway.close() |
OLD | NEW |