kelvin-onlab | d9e23de | 2015-08-06 10:34:44 -0700 | [diff] [blame] | 1 | """ |
| 2 | These functions can be used for topology comparisons |
| 3 | """ |
| 4 | |
| 5 | import time |
| 6 | import os |
| 7 | import json |
| 8 | |
YPZhang | 81a7d4e | 2016-04-18 13:10:17 -0700 | [diff] [blame] | 9 | def sendArpPackage( main, hostList ): |
| 10 | import json |
YPZhang | 26a139e | 2016-04-25 14:01:55 -0700 | [diff] [blame] | 11 | import time |
YPZhang | 81a7d4e | 2016-04-18 13:10:17 -0700 | [diff] [blame] | 12 | """ |
| 13 | send arping package from host |
| 14 | return the total hosts number from Onos |
| 15 | """ |
YPZhang | acaaf42 | 2016-07-26 09:34:03 -0700 | [diff] [blame] | 16 | main.log.info( "Sending Arping package..." ) |
YPZhang | 81a7d4e | 2016-04-18 13:10:17 -0700 | [diff] [blame] | 17 | if isinstance(hostList, list): |
YPZhang | 81a7d4e | 2016-04-18 13:10:17 -0700 | [diff] [blame] | 18 | for h in hostList: |
YPZhang | 26a139e | 2016-04-25 14:01:55 -0700 | [diff] [blame] | 19 | main.Mininet1.arping( srcHost=h, dstHost="10.0.0.1", output=main.FALSE, noResult=True ) |
YPZhang | 0f87486 | 2016-04-27 11:14:10 -0700 | [diff] [blame] | 20 | time.sleep(0.5) |
YPZhang | 81a7d4e | 2016-04-18 13:10:17 -0700 | [diff] [blame] | 21 | else: |
YPZhang | acaaf42 | 2016-07-26 09:34:03 -0700 | [diff] [blame] | 22 | main.Mininet1.arping( srcHost=hostList, dstHost="10.0.0.1", output=main.FALSE, noResult=True ) |
| 23 | try: |
| 24 | summaryStr = "" |
| 25 | summaryStr = json.loads( main.CLIs[0].summary().encode() ) |
| 26 | hostNum = summaryStr.get( 'hosts' ) |
| 27 | |
| 28 | except (TypeError, ValueError): |
| 29 | main.log.exception( " Object not as expected: {!r}".format( summaryStr) ) |
| 30 | return -1 |
| 31 | except Exception: |
| 32 | main.log.exception( self.name + ": Uncaught exception!" ) |
| 33 | return -1 |
| 34 | |
YPZhang | 81a7d4e | 2016-04-18 13:10:17 -0700 | [diff] [blame] | 35 | return hostNum |