| /kernel/tests/net/test/ |
| D | tcp_repair_test.py | 65 def assertSocketNotConnected(self, sock): argument
66 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
68 def assertSocketConnected(self, sock): argument
69 sock.getpeername() # No errors? Socket is alive and connected.
99 def receiveFin(self, netid, version, sock): argument
100 self.assertSocketConnected(sock)
107 def sendData(self, netid, version, sock, payload): argument
108 sock.send(payload)
137 sock = self.createConnectedSocket(version, netid)
138 sock.setsockopt(SOL_TCP, TCP_REPAIR, TCP_REPAIR_ON)
[all …]
|
| D | nf_test.py | 49 sock = net_test.TCPSocket(net_test.GetAddressFamily(version))
51 self.SelectInterface(sock, netid, "mark")
55 sock.connect((addr, 53))
68 sock = net_test.UDPSocket(net_test.GetAddressFamily(version))
70 self.SelectInterface(sock, netid, "mark")
74 sock.sendto(net_test.UDP_PAYLOAD, (addr, 53))
|
| D | sock_diag_test.py | 119 def assertSocketClosed(self, sock): argument
120 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
122 def assertSocketConnected(self, sock): argument
123 sock.getpeername() # No errors? Socket is alive and connected.
126 for sock in socketpair:
127 self.assertSocketClosed(sock)
158 def _EventDuringBlockingCall(self, sock, call, expected_errno, event): argument
169 thread = SocketExceptionThread(sock, call)
172 event(sock)
182 self.assertSocketClosed(sock)
[all …]
|
| D | bpf_test.py | 62 sock = socket.socket(family, socket.SOCK_DGRAM, 0)
64 BpfProgAttachSocket(sock.fileno(), prog_fd)
65 net_test.SetNonBlocking(sock)
67 sock.bind((addr, 0))
68 addr = sock.getsockname()
71 sock.sendto("foo", addr)
72 data, retaddr = csocket.Recvfrom(sock, 4096, 0)
75 return sock
158 self.sock = None
165 if self.sock:
[all …]
|
| D | netlink.py | 150 sock = socket.socket(socket.AF_NETLINK, socket.SOCK_RAW, family)
152 sock.bind((0, groups))
153 sock.connect((0, 0)) # The kernel.
154 return sock
159 self.sock = self._OpenNetlinkSocket(family)
160 self.pid = self.sock.getsockname()[1]
169 self.sock.send(msg)
172 data = self.sock.recv(self.BUFSIZE)
|
| D | xfrm_algorithm_test.py | 235 def TcpServer(sock, client_port): argument
237 sock.listen(1)
239 accepted, peer = sock.accept()
248 sock.close()
250 def UdpServer(sock, client_port): argument
253 data, peer = sock.recvfrom(2048)
257 sock.sendto("hello response", peer)
261 sock.close()
|
| D | net_test.py | 170 def BindRandomPort(version, sock): argument
172 sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
173 sock.bind((addr, 0))
174 if sock.getsockopt(SOL_SOCKET, SO_PROTOCOL) == IPPROTO_TCP:
175 sock.listen(100)
176 port = sock.getsockname()[1]
180 def EnableFinWait(sock): argument
182 sock.setsockopt(SOL_SOCKET, SO_LINGER, struct.pack("ii", 0, 0))
185 def DisableFinWait(sock): argument
187 sock.setsockopt(SOL_SOCKET, SO_LINGER, struct.pack("ii", 1, 0))
|
| D | xfrm_base.py | 44 def SetPolicySockopt(sock, family, opt_data): argument
47 csocket.Setsockopt(sock, IPPROTO_IP, xfrm.IP_XFRM_POLICY, opt_data, optlen)
49 csocket.Setsockopt(sock, IPPROTO_IPV6, xfrm.IPV6_XFRM_POLICY, opt_data,
53 def ApplySocketPolicy(sock, family, direction, spi, reqid, tun_addrs): argument
80 sockfamily = sock.getsockopt(SOL_SOCKET, net_test.SO_DOMAIN)
81 SetPolicySockopt(sock, sockfamily, opt_data)
|
| D | tcp_fastopen_test.py | 47 def assertSocketNotConnected(self, sock): argument
48 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
50 def assertSocketConnected(self, sock): argument
51 sock.getpeername() # No errors? Socket is alive and connected.
|
| D | xfrm_test.py | 263 def _VerifyUdpEncapSocket(self, netid, remoteaddr, myaddr, encap_port, sock, argument
266 sock.sendto(net_test.UDP_PAYLOAD, (remoteaddr, 53))
267 srcport = sock.getsockname()[1]
493 sock = net_test.UDPSocket(family)
494 self.SelectInterface(sock, netid, "mark")
495 sock.bind((local_addr, 0))
496 local_port = sock.getsockname()[1]
500 sock, family, xfrm.XFRM_POLICY_OUT, 0xABCD, 123,
503 sock, family, xfrm.XFRM_POLICY_IN, 0x9876, 456,
516 msg, addr = sock.recvfrom(1024)
[all …]
|
| D | tcp_nuke_addr_test.py | 99 for sock in socketpair:
100 self.assertTrue(sock.getpeername())
|
| D | neighbour_test.py | 83 self.sock = socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE)
84 self.sock.bind((0, RTMGRP_NEIGH))
85 net_test.SetNonBlocking(self.sock)
100 self.assertRaisesErrno(errno.EAGAIN, self.sock.recvfrom, 4096, MSG_PEEK)
109 msg = self.sock.recv(4096)
|
| D | pf_key.py | 198 self.sock = socket(AF_KEY, SOCK_RAW, PF_KEY_V2)
199 net_test.SetNonBlocking(self.sock)
203 reply = self.sock.recv(4096)
215 self.sock.send(msg.Pack() + extensions)
|
| D | iproute.py | 493 def _WaitForAddress(self, sock, address, ifindex): argument
500 csocket.SetSocketTimeout(sock, 100)
503 data = sock.recv(4096)
538 sock = self._OpenNetlinkSocket(netlink.NETLINK_ROUTE,
545 self._WaitForAddress(sock, address, ifindex)
|
| D | csocket.py | 95 def SetSocketTimeout(sock, ms): argument
98 sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVTIMEO,
|
| D | xfrm_tunnel_test.py | 212 sock = write_sock if direction == xfrm.XFRM_POLICY_OUT else read_sock
214 remote_inner, local_outer, remote_outer, sock)
|