commit 09c0e43ea375b4810f37a0b0b7bbf670d0a2b3df
author Lorenzo Colitti <lorenzo@google.com> Thu Oct 01 17:36:37 2015 +0900
committer Lorenzo Colitti <lorenzo@google.com> Tue Oct 27 17:00:19 2015 +0900
tree 87d9883341d5b6380335885d36f99532d9e26c8a
parent f9f8746474fed71c22cd162de80d9d2e58ce6d8b

Test nuking IPv4 sockets as well as IPv6.

Also, for clarity, use cstruct.Struct to make the ifreq
structures instead of hand-packing them.

Change-Id: I917d6e38b3db067182ef1c971ff6c676fc2d7431

net/test/tcp_nuke_addr_test.py

diff --git a/net/test/tcp_nuke_addr_test.py b/net/test/tcp_nuke_addr_test.py
index a0f44d3..b4c1882 100755
--- a/net/test/tcp_nuke_addr_test.py
+++ b/net/test/tcp_nuke_addr_test.py
@@ -25,10 +25,14 @@
 import time
 import unittest
 
+import csocket
+import cstruct
 import net_test
 
-IPV4_LOOPBACK_ADDR = '127.0.0.1'
-IPV6_LOOPBACK_ADDR = '::1'
+IPV4_LOOPBACK_ADDR = "127.0.0.1"
+IPV6_LOOPBACK_ADDR = "::1"
+LOOPBACK_DEV = "lo"
+LOOPBACK_IFINDEX = 1
 
 SIOCKILLADDR = 0x8939
 
@@ -36,10 +40,13 @@
 DEFAULT_BUFFER_SIZE = 20
 DEFAULT_TEST_MESSAGE = "TCP NUKE ADDR TEST"
 DEFAULT_TEST_RUNS = 100
-HASH_TEST_RUNS = 8000
+HASH_TEST_RUNS = 4000
 HASH_TEST_NOFILE = 16384
 
 
+Ifreq = cstruct.Struct("Ifreq", "=16s16s", "name data")
+In6Ifreq = cstruct.Struct("In6Ifreq", "=16sIi", "addr prefixlen ifindex")
+
 @contextlib.contextmanager
 def RunInBackground(thread):
   """Starts a thread and waits until it joins.
@@ -99,11 +106,12 @@
     ValueError: If the address family is invalid for the ioctl.
   """
   if addr_family == AF_INET6:
-    ifreq = struct.pack('BBBBBBBBBBBBBBBBIi',
-                        0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1,
-                        128, 1)
+    addr = inet_pton(AF_INET6, IPV6_LOOPBACK_ADDR)
+    ifreq = In6Ifreq((addr, 128, LOOPBACK_IFINDEX)).Pack()
   elif addr_family == AF_INET:
-    raise NotImplementedError('Support for IPv4 not implemented yet.')
+    addr = inet_pton(AF_INET, IPV4_LOOPBACK_ADDR)
+    sockaddr = csocket.SockaddrIn((AF_INET, 0, addr)).Pack()
+    ifreq = Ifreq((LOOPBACK_DEV, sockaddr)).Pack()
   else:
     raise ValueError('Address family %r not supported.' % addr_family)
   datagram_socket = socket(addr_family, SOCK_DGRAM)
@@ -126,10 +134,10 @@
       self.exception = e
 
 
-def CreateSocketPair():
-  clientsock = socket(AF_INET6, SOCK_STREAM, 0)
-  listensock = socket(AF_INET6, SOCK_STREAM, 0)
-  listensock.bind((IPV6_LOOPBACK_ADDR, 0))
+def CreateSocketPair(family, addr):
+  clientsock = socket(family, SOCK_STREAM, 0)
+  listensock = socket(family, SOCK_STREAM, 0)
+  listensock.bind((addr, 0))
   addr = listensock.getsockname()
   listensock.listen(1)
   clientsock.connect(addr)
@@ -148,6 +156,8 @@
     for i in xrange(DEFAULT_TEST_RUNS):
       ExchangeMessage(AF_INET6, IPV6_LOOPBACK_ADDR)
       KillAddrIoctl(AF_INET6)
+      ExchangeMessage(AF_INET, IPV4_LOOPBACK_ADDR)
+      KillAddrIoctl(AF_INET)
       # Test passes if kernel does not crash.
 
   def testClosesSockets(self):
@@ -156,7 +166,7 @@
     threadpairs = []
 
     for i in xrange(DEFAULT_TEST_RUNS):
-      clientsock, acceptedsock = CreateSocketPair()
+      clientsock, acceptedsock = CreateSocketPair(AF_INET6, "::1")
       clientthread = ExceptionalReadThread(clientsock)
       clientthread.start()
       serverthread = ExceptionalReadThread(acceptedsock)
@@ -193,8 +203,10 @@
   def testClosesAllSockets(self):
     socketpairs = []
     for i in xrange(HASH_TEST_RUNS):
-      socketpairs.append(CreateSocketPair())
+      socketpairs.append(CreateSocketPair(AF_INET, IPV4_LOOPBACK_ADDR))
+      socketpairs.append(CreateSocketPair(AF_INET6, IPV6_LOOPBACK_ADDR))
 
+    KillAddrIoctl(AF_INET)
     KillAddrIoctl(AF_INET6)
 
     for socketpair in socketpairs: