Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 1 | #! /usr/bin/env python |
| 2 | import sys |
| 3 | import time |
| 4 | import os |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 5 | import re |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 6 | |
| 7 | hosts=['onosdevz1', 'onosdevz2', 'onosdevz3', 'onosdevz4', 'onosdevz5', 'onosdevz6', 'onosdevz7', 'onosdevz8'] |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 8 | ping_cnt=3 |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 9 | wait1=ping_cnt |
| 10 | wait2=10 |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 11 | |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 12 | |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 13 | def do_pingall(): |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 14 | |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 15 | pid=os.getpid() |
| 16 | os.popen("rm -f /tmp/ping.*") |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 17 | |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 18 | filename = sys.argv[1] |
| 19 | f = open(filename, 'r') |
| 20 | nr_ping = 0 |
| 21 | for line in f: |
| 22 | if line[0] != "#": |
| 23 | # logfile="/tmp/ping.pid%d.%d" % (pid, fid) |
| 24 | fid=int(line.strip().split()[0]) |
| 25 | logfile="/tmp/ping.%d" % (fid) |
| 26 | src_dpid=line.strip().split()[2] |
| 27 | dst_dpid=line.strip().split()[4] |
| 28 | src_nwid=int(src_dpid.split(':')[-2], 16) |
| 29 | dst_nwid=int(dst_dpid.split(':')[-2], 16) |
| 30 | src_hostid=int(src_dpid.split(':')[-1], 16) |
| 31 | dst_hostid=int(dst_dpid.split(':')[-1], 16) |
| 32 | cmd="echo \"Pingall flow %d : 192.168.%d.%d -> 192.168.%d.%d\" > %s" % (fid, src_nwid, src_hostid, dst_nwid, dst_hostid,logfile) |
| 33 | os.popen(cmd) |
| 34 | cmd="ssh %s \'${HOME}/ONOS/test-network/mininet/mrun host%d \'ping -c %d -W 1 192.168.%d.%d\'\' >> %s 2>&1 &" % (hosts[src_nwid-1], src_hostid, ping_cnt, dst_nwid, dst_hostid,logfile) |
| 35 | # print cmd |
| 36 | result = os.popen(cmd).read() |
| 37 | time.sleep(0.2) |
| 38 | nr_ping = nr_ping + 1 |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 39 | |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 40 | f.close() |
| 41 | return nr_ping |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 42 | |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 43 | def wait_ping_finish(nr_ping): |
| 44 | print "all pings started.. waiting for completion (%d sec)" % (wait1) |
| 45 | time.sleep(wait1) |
| 46 | cmd="cat /tmp/ping.* | grep \"packet loss\" |wc -l" |
| 47 | for i in range(wait2): |
| 48 | nr_done = int(os.popen(cmd).read()) |
| 49 | if nr_done == nr_ping: |
| 50 | break |
| 51 | print "%d ping finished" % nr_done |
| 52 | time.sleep(1) |
| 53 | |
| 54 | return nr_done |
Masayoshi Kobayashi | f04afb3 | 2013-04-06 06:49:03 +0000 | [diff] [blame] | 55 | |
Masayoshi Kobayashi | f9ccc38 | 2013-04-07 04:06:41 +0000 | [diff] [blame] | 56 | def report(nr_ping, nr_done): |
| 57 | cmd='cat /tmp/ping.* | grep " 0% packet loss" |wc -l' |
| 58 | nr_success = int(os.popen('cat /tmp/ping.* | grep " 0% packet loss" |wc -l').read()) |
| 59 | nr_incomplete = nr_ping - nr_done |
| 60 | nr_fail = nr_done - nr_success |
| 61 | |
| 62 | print "Pingall Result: success %d fail %d incomplete %d" % (nr_success, nr_fail, nr_incomplete) |
| 63 | if nr_fail > 0 or nr_incomplete > 0: |
| 64 | for i in range(nr_ping): |
| 65 | cmd="cat /tmp/ping.%d | head -n 1" % (i+1) |
| 66 | flow_desc = os.popen(cmd).read().strip() |
| 67 | |
| 68 | cmd="cat /tmp/ping.%d | grep \"packet loss\"" % (i+1) |
| 69 | result = os.popen(cmd).read().strip() |
| 70 | |
| 71 | if not re.search(" 0% packet loss", result): |
| 72 | print "flow # %d %s : %s" % (i+1, flow_desc, result) |
| 73 | |
| 74 | if __name__ == "__main__": |
| 75 | nr_ping=do_pingall() |
| 76 | nr_done=wait_ping_finish(nr_ping) |
| 77 | report(nr_ping, nr_done) |