wip

slapos/networkbench/ping.py

@@ -13,7 +13,7 @@ ping_re = re.compile(
 date_reg_exp = re.compile('\d{4}[-/]\d{2}[-/]\d{2}')
 
 
-def ping(host, timeout=10, protocol="4"):
+def ping(host, timeout=10, protocol="4", count=10):
   if protocol == '4':
     ping_bin = 'ping'
     test_title = 'PING'
@@ -21,7 +21,7 @@ def ping(host, timeout=10, protocol="4"):
     ping_bin = 'ping6'
     test_title = 'PING6'
 
-  proc = subprocess.Popen((ping_bin, '-c', '10', '-w', str(timeout), host), 
+  proc = subprocess.Popen((ping_bin, '-c', str(count), '-w', str(timeout), host),
                             stdout=subprocess.PIPE, stderr=subprocess.PIPE)
 
   out, err = proc.communicate()
@@ -46,6 +46,6 @@ def ping(host, timeout=10, protocol="4"):
 
   return info_list
 
-def ping6(host, timeout=10):
-  return ping(host, timeout=10, protocol='6')
+def ping6(host, timeout=10, count=10):
+  return ping(host, timeout=10, protocol='6', count=count)
 

slapos/promise/is_icmp_packet_lost/__init__.py

+import re
+import time
+import sys
+import gzip
+from slapos.networkcache.ping import ping, ping6
+
+def test(address, ipv4, count):
+
+  if ipv4:
+    return ping(address, count=count)
+
+  return ping6(address, count=count)
+
+def main():
+  parser = argparse.ArgumentParser()
+  # Address to ping to
+  parser.add_argument("-a", "--address", metavar="LOG_FILE")
+  # Force use ipv4 protocol
+  parser.add_argument("-4", "--ipv4", action="store_true" )
+  parser.add_argument("-c", "--count", metavar="COUNT", default=10 )
+  args = parser.parse_args()
+
+  result = test(args.address, args.ipv4, args.count)
+
+  print "%s host=%s code=%s, result=%s, packet_lost_ratio=%s msg=%s" % result
+  if result[4] != "0":
+    # Packet lost occurred
+    sys.exit(1)
+