Lines Matching refs:diag_msg

133     diag_msg, attrs = info
135     self.assertEqual(diag_msg.family, family)
138     self.assertEqual(diag_msg.id.src, self.sock_diag.PaddedAddress(src))
139     self.assertEqual(diag_msg.id.sport, sport)
141     if self.sock_diag.GetDestinationAddress(diag_msg) not in ["0.0.0.0", "::"]:
143       self.assertEqual(diag_msg.id.dst, self.sock_diag.PaddedAddress(dst))
144       self.assertEqual(diag_msg.id.dport, dport)
208       diag_msg = self.sock_diag.FindSockDiagFromFd(sock)
209       diag_req = self.sock_diag.DiagReqFromDiagMsg(diag_msg, IPPROTO_TCP)
221     for diag_msg, unused_attrs in sockets:
222       addr = self.sock_diag.GetSourceAddress(diag_msg)
223       sport = diag_msg.id.sport
224       dport = diag_msg.id.dport
226         cookies[(addr, sport, dport)] = diag_msg.id.cookie
228         cookies[(addr, sport, dport)] = diag_msg.id.cookie
299         diag_msg = self.sock_diag.FindSockDiagFromFd(s)
301             (sock_diag.INET_DIAG_BC_S_GE, 1, 5, diag_msg.id.sport),
302             (sock_diag.INET_DIAG_BC_S_LE, 1, 4, diag_msg.id.sport),
303             (sock_diag.INET_DIAG_BC_D_GE, 1, 3, diag_msg.id.dport),
304             (sock_diag.INET_DIAG_BC_D_LE, 1, 2, diag_msg.id.dport),
312         self.assertEquals(diag_msg.Pack(), sockets[0][0].Pack())
389       diag_msg = self.sock_diag.FindSockDiagFromFd(sock)
391       self.assertEqual(diag_msg.id.cookie, cookie)
491         diag_msg = self.sock_diag.FindSockDiagFromFd(s)
495         real_cookie = diag_msg.id.cookie
496         diag_msg.id.cookie = os.urandom(len(real_cookie))
497         req = self.sock_diag.DiagReqFromDiagMsg(diag_msg, IPPROTO_TCP)
645       diag_msg = self.sock_diag.FindSockDiagFromFd(self.accepted)
646       diag_req = self.sock_diag.DiagReqFromDiagMsg(diag_msg, IPPROTO_TCP)
652       diag_msg, attrs = self.sock_diag.GetSockInfo(diag_req)
653       self.assertEquals(tcp_test.TCP_FIN_WAIT1, diag_msg.state)
659       diag_msg, attrs = self.sock_diag.GetSockInfo(diag_req)
663       self.assertEquals(tcp_test.TCP_FIN_WAIT1, diag_msg.state)
668       diag_msg, attrs = self.sock_diag.GetSockInfo(diag_req)
676         self.assertTrue(any(diag_msg.state == tcp_test.TCP_FIN_WAIT2
677                             for diag_msg, attrs in infos),
718         diag_msg, attrs = self.sock_diag.GetSockInfo(child)
719         self.assertEquals(diag_msg.state, expected_state)
1118     diag_msg, attrs = self.sock_diag.FindSockInfoFromFd(s)
1121       diag_msg, attrs = self.sock_diag.FindSockInfoFromFd(s)