55   def assertSocketClosed(self, sock):  argument
56     self.assertRaisesErrno(ENOTCONN, sock.getpeername)
58   def assertSocketConnected(self, sock):  argument
59     sock.getpeername()  # No errors? Socket is alive and connected.
62     for sock in socketpair:
63       self.assertSocketClosed(sock)
103     for sock in socketpair:
104       diag_msg = self.sock_diag.FindSockDiagFromFd(sock)
139       for sock in socketpair:
142             sock,
143             self.sock_diag.FindSockDiagFromFd(sock))
144         cookie = self.sock_diag.FindSockDiagFromFd(sock).id.cookie
147         req = self.sock_diag.DiagReqFromSocket(sock)
151         self.assertSockDiagMatchesSocket(sock, diag_msg)
338   def __init__(self, sock, operation):  argument
342     self.sock = sock
347       self.operation(self.sock)
384   def CheckRstOnClose(self, sock, req, expect_reset, msg, do_close=True):  argument
386     if sock is not None:
388       self.sock_diag.CloseSocketFromFd(sock)
389       self.assertRaisesErrno(EINVAL, sock.accept)
391       self.assertIsNone(sock, "Must specify sock or req, not both")
402     if sock is not None and do_close:
403       sock.close()
496   def CloseDuringBlockingCall(self, sock, call, expected_errno):  argument
497     thread = SocketExceptionThread(sock, call)
500     self.sock_diag.CloseSocketFromFd(sock)
507     self.assertSocketClosed(sock)
513       self.CloseDuringBlockingCall(self.s, lambda sock: sock.accept(), EINVAL)
521       self.CloseDuringBlockingCall(self.accepted, lambda sock: sock.recv(4096),
539           s, lambda sock: sock.connect((remoteaddr, 53)), ECONNABORTED)