| OLD | NEW |
| 1 import logging | 1 import logging |
| 2 from autotest_lib.client.common_lib import error | 2 from autotest_lib.client.common_lib import error |
| 3 import kvm_test_utils | 3 from autotest_lib.client.virt import virt_test_utils |
| 4 | 4 |
| 5 | 5 |
| 6 def run_ping(test, params, env): | 6 def run_ping(test, params, env): |
| 7 """ | 7 """ |
| 8 Ping the guest with different size of packets. | 8 Ping the guest with different size of packets. |
| 9 | 9 |
| 10 Packet Loss Test: | 10 Packet Loss Test: |
| 11 1) Ping the guest with different size/interval of packets. | 11 1) Ping the guest with different size/interval of packets. |
| 12 | 12 |
| 13 Stress Test: | 13 Stress Test: |
| (...skipping 19 matching lines...) Expand all Loading... |
| 33 try: | 33 try: |
| 34 for i, nic in enumerate(nics): | 34 for i, nic in enumerate(nics): |
| 35 ip = vm.get_address(i) | 35 ip = vm.get_address(i) |
| 36 if not ip: | 36 if not ip: |
| 37 logging.error("Could not get the ip of nic index %d: %s", | 37 logging.error("Could not get the ip of nic index %d: %s", |
| 38 i, nic) | 38 i, nic) |
| 39 continue | 39 continue |
| 40 | 40 |
| 41 for size in packet_size: | 41 for size in packet_size: |
| 42 logging.info("Ping with packet size %s", size) | 42 logging.info("Ping with packet size %s", size) |
| 43 status, output = kvm_test_utils.ping(ip, 10, | 43 status, output = virt_test_utils.ping(ip, 10, |
| 44 packetsize=size, | 44 packetsize=size, |
| 45 timeout=20) | 45 timeout=20) |
| 46 if strict_check: | 46 if strict_check: |
| 47 ratio = kvm_test_utils.get_loss_ratio(output) | 47 ratio = virt_test_utils.get_loss_ratio(output) |
| 48 if ratio != 0: | 48 if ratio != 0: |
| 49 raise error.TestFail("Loss ratio is %s for packet size" | 49 raise error.TestFail("Loss ratio is %s for packet size" |
| 50 " %s" % (ratio, size)) | 50 " %s" % (ratio, size)) |
| 51 else: | 51 else: |
| 52 if status != 0: | 52 if status != 0: |
| 53 raise error.TestFail("Ping failed, status: %s," | 53 raise error.TestFail("Ping failed, status: %s," |
| 54 " output: %s" % (status, output)) | 54 " output: %s" % (status, output)) |
| 55 | 55 |
| 56 logging.info("Flood ping test") | 56 logging.info("Flood ping test") |
| 57 kvm_test_utils.ping(ip, None, flood=True, output_func=None, | 57 virt_test_utils.ping(ip, None, flood=True, output_func=None, |
| 58 timeout=flood_minutes * 60) | 58 timeout=flood_minutes * 60) |
| 59 | 59 |
| 60 logging.info("Final ping test") | 60 logging.info("Final ping test") |
| 61 status, output = kvm_test_utils.ping(ip, counts, | 61 status, output = virt_test_utils.ping(ip, counts, |
| 62 timeout=float(counts) * 1.5) | 62 timeout=float(counts) * 1.5) |
| 63 if strict_check: | 63 if strict_check: |
| 64 ratio = kvm_test_utils.get_loss_ratio(output) | 64 ratio = virt_test_utils.get_loss_ratio(output) |
| 65 if ratio != 0: | 65 if ratio != 0: |
| 66 raise error.TestFail("Ping failed, status: %s," | 66 raise error.TestFail("Ping failed, status: %s," |
| 67 " output: %s" % (status, output)) | 67 " output: %s" % (status, output)) |
| 68 else: | 68 else: |
| 69 if status != 0: | 69 if status != 0: |
| 70 raise error.TestFail("Ping returns non-zero value %s" % | 70 raise error.TestFail("Ping returns non-zero value %s" % |
| 71 output) | 71 output) |
| 72 finally: | 72 finally: |
| 73 session.close() | 73 session.close() |
| OLD | NEW |