Home
last modified time | relevance | path

Searched refs:self (Results 1 – 25 of 41) sorted by relevance

12

/kernel/tests/net/test/
Dsrcaddr_selection_test.py59 def SetIPv6Sysctl(self, ifname, sysctl, value): argument
60 self.SetSysctl("/proc/sys/net/ipv6/conf/%s/%s" % (ifname, sysctl), value)
62 def SetDAD(self, ifname, value): argument
63 self.SetSysctl("/proc/sys/net/ipv6/conf/%s/accept_dad" % ifname, value)
64 self.SetSysctl("/proc/sys/net/ipv6/conf/%s/dad_transmits" % ifname, value)
66 def SetOptimisticDAD(self, ifname, value): argument
67 self.SetSysctl("/proc/sys/net/ipv6/conf/%s/optimistic_dad" % ifname, value)
69 def SetUseTempaddrs(self, ifname, value): argument
70 self.SetSysctl("/proc/sys/net/ipv6/conf/%s/use_tempaddr" % ifname, value)
72 def SetUseOptimistic(self, ifname, value): argument
[all …]
Dneighbour_test.py68 def setUp(self): argument
69 super(NeighbourTest, self).setUp()
71 for netid in self.tuns:
74 addr = self._RouterAddress(netid, 6)
75 ifindex = self.ifindices[netid]
76 self.iproute.UpdateNeighbour(6, addr, None, ifindex, NUD_FAILED)
79 self.SendRA(netid,
80 retranstimer=self.RETRANS_TIME_MS,
81 reachabletime=self.BASE_REACHABLE_TIME_MS)
83 self.sock = socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE)
[all …]
Dsock_diag_test.py119 def assertSocketClosed(self, sock): argument
120 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
122 def assertSocketConnected(self, sock): argument
125 def assertSocketsClosed(self, socketpair): argument
127 self.assertSocketClosed(sock)
129 def assertMarkIs(self, mark, attrs): argument
130 self.assertEqual(mark, attrs.get("INET_DIAG_MARK", None))
132 def assertSockInfoMatchesSocket(self, s, info): argument
135 self.assertEqual(diag_msg.family, family)
138 self.assertEqual(diag_msg.id.src, self.sock_diag.PaddedAddress(src))
[all …]
Dmultinetwork_test.py57 def CheckPingPacket(self, version, netid, routing_mode, packet): argument
58 s = self.BuildSocket(version, net_test.PingSocket, netid, routing_mode)
60 myaddr = self.MyAddress(version, netid)
61 mysockaddr = self.MySocketAddress(version, netid)
66 dstaddr = self.GetRemoteAddress(version)
67 dstsockaddr = self.GetRemoteSocketAddress(version)
70 version, desc, self.GetInterfaceName(netid))
74 self.ExpectPacketOn(netid, msg, expected)
76 def CheckTCPSYNPacket(self, version, netid, routing_mode): argument
77 s = self.BuildSocket(version, net_test.TCPSocket, netid, routing_mode)
[all …]
Dqtaguid_test.py36 def RunIptablesCommand(self, args): argument
37 self.assertFalse(net_test.RunIptablesCommand(4, args))
38 self.assertFalse(net_test.RunIptablesCommand(6, args))
40 def setUp(self): argument
41 self.RunIptablesCommand("-N qtaguid_test_OUTPUT")
42 self.RunIptablesCommand("-A OUTPUT -j qtaguid_test_OUTPUT")
44 def tearDown(self): argument
45 self.RunIptablesCommand("-D OUTPUT -j qtaguid_test_OUTPUT")
46 self.RunIptablesCommand("-F qtaguid_test_OUTPUT")
47 self.RunIptablesCommand("-X qtaguid_test_OUTPUT")
[all …]
Dbpf_test.py155 def setUp(self): argument
156 self.map_fd = -1
157 self.prog_fd = -1
158 self.sock = None
160 def tearDown(self): argument
161 if self.prog_fd >= 0:
162 os.close(self.prog_fd)
163 if self.map_fd >= 0:
164 os.close(self.map_fd)
165 if self.sock:
[all …]
Dxfrm_tunnel_test.py149 def _CheckTunnelOutput(self, inner_version, outer_version, underlying_netid, argument
154 self._ExpectEspPacketOn(underlying_netid, _TEST_OUT_SPI, 1, None,
157 def _CheckTunnelInput(self, inner_version, outer_version, underlying_netid, argument
168 self.ReceivePacketOn(underlying_netid, input_pkt)
172 self.assertEquals(net_test.UDP_PAYLOAD, data)
173 self.assertEquals((remote_inner, _TEST_REMOTE_PORT), src[:2])
175 def _TestTunnel(self, inner_version, outer_version, func, direction, argument
180 u_netid = self.RandomNetid()
183 netid = self.RandomNetid(exclude=u_netid)
185 local_inner = self.MyAddress(inner_version, netid)
[all …]
Dtcp_test.py43 def tearDown(self): argument
44 if hasattr(self, "s"):
45 self.s.close()
46 super(TcpBaseTest, self).tearDown()
48 def OpenListenSocket(self, version, netid): argument
53 self.SelectInterface(s, netid, "mark")
54 self.port = net_test.BindRandomPort(version, s)
57 def _ReceiveAndExpectResponse(self, netid, packet, reply, msg): argument
58 pkt = super(TcpBaseTest, self)._ReceiveAndExpectResponse(netid, packet,
60 self.last_packet = pkt
[all …]
Dtcp_repair_test.py65 def assertSocketNotConnected(self, sock): argument
66 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
68 def assertSocketConnected(self, sock): argument
71 def createConnectedSocket(self, version, netid): argument
74 self.SelectInterface(s, netid, "mark")
76 remotesockaddr = self.GetRemoteSocketAddress(version)
77 remoteaddr = self.GetRemoteAddress(version)
78 self.assertRaisesErrno(EINPROGRESS, s.connect, (remotesockaddr, TEST_PORT))
79 self.assertSocketNotConnected(s)
81 myaddr = self.MyAddress(version, netid)
[all …]
Dxfrm_test.py55 def assertIsUdpEncapEsp(self, packet, spi, seq, length): argument
56 self.assertEquals(IPPROTO_UDP, packet.proto)
58 self.assertEquals(4500, udp_hdr.dport)
59 self.assertEquals(length, len(udp_hdr))
63 self.assertEquals(xfrm.EspHdr((spi, seq)), esp_hdr)
65 def CreateNewSa(self, localAddr, remoteAddr, spi, reqId, encap_tmpl, argument
69 self.xfrm.AddSaInfo(localAddr, remoteAddr, spi, xfrm.XFRM_MODE_TRANSPORT,
73 def testAddSa(self): argument
74 self.CreateNewSa("::", TEST_ADDR1, TEST_SPI, 3320, None)
91 self.assertMultiLineEqual(expected, actual)
[all …]
Dtun_twister.py73 def __init__(self, fd=None, validator=None): argument
85 self._fd = fd
87 self._signal_read, self._signal_write = os.pipe()
88 self._thread = threading.Thread(target=self._RunLoop, name="TunTwister")
89 self._validator = validator
90 self._error = None
92 def __enter__(self): argument
93 self._thread.start()
95 def __exit__(self, *args): argument
97 os.write(self._signal_write, "bye")
[all …]
Dping6_test.py56 def __init__(self, tun, mymac, routermac, routeraddr): argument
57 super(PingReplyThread, self).__init__()
58 self._tun = tun
59 self._started = False
60 self._stopped = False
61 self._mymac = mymac
62 self._routermac = routermac
63 self._routeraddr = routeraddr
65 def IsStarted(self): argument
66 return self._started
[all …]
Dforwarding_test.py30 def ForwardBetweenInterfaces(self, enabled, iface1, iface2): argument
32 self.iproute.IifRule(6, enabled, self.GetInterfaceName(iif),
33 self._TableForNetid(oif), self.PRIORITY_IIF)
35 def setUp(self): argument
36 self.SetSysctl("/proc/sys/net/ipv6/conf/all/forwarding", 1)
38 def tearDown(self): argument
39 self.SetSysctl("/proc/sys/net/ipv6/conf/all/forwarding", 0)
49 def CheckForwardingUdp(self, netid, iface1, iface2): argument
61 self.SetSocketMark(s, netid)
65 remoteaddr = self.GetRemoteAddress(version)
[all …]
Dcstruct.py156 def _SetValues(self, values): argument
159 super(CStruct, self).__setattr__("_values", list(values))
161 def _Parse(self, data): argument
162 data = data[:self._length]
163 values = list(struct.unpack(self._format, data))
165 if isinstance(value, str) and index in self._nested:
166 values[index] = self._nested[index](value)
167 self._SetValues(values)
169 def __init__(self, tuple_or_bytes=None, **kwargs): argument
179 "%s: cannot specify both a tuple and keyword args" % self._name)
[all …]
Diproute.py249 def _NlAttrInterfaceName(self, nla_type, interface): argument
250 return self._NlAttr(nla_type, interface + "\x00")
252 def _GetConstantName(self, value, prefix): argument
253 return super(IPRoute, self)._GetConstantName(__name__, value, prefix)
255 def _Decode(self, command, msg, nla_type, nla_data, nested=0): argument
287 name = self._GetConstantName(nla_type, "RTAX_")
289 name = self._GetConstantName(nla_type, "IFLA_INFO_")
291 name = self._GetConstantName(nla_type, "IFLA_VTI_")
293 name = self._GetConstantName(nla_type, "IFA_")
295 name = self._GetConstantName(nla_type, "IFLA_")
[all …]
Dpf_key_test.py32 def setUp(self): argument
33 self.pf_key = pf_key.PfKey()
34 self.xfrm = xfrm.Xfrm()
36 def testAddDelSa(self): argument
39 self.pf_key.AddSa(src4, dst4, 0xdeadbeef, pf_key.SADB_TYPE_ESP,
46 self.pf_key.AddSa(src6, dst6, 0xbeefdead, pf_key.SADB_TYPE_ESP,
51 sainfos = self.xfrm.DumpSaInfo()
52 self.assertEquals(2, len(sainfos))
56 pfkey_sainfos = self.pf_key.DumpSaInfo()
57 self.assertEquals(2, len(pfkey_sainfos))
[all …]
Danycast_test.py43 def __init__(self, fd): argument
44 super(CloseFileDescriptorThread, self).__init__()
45 self.daemon = True
46 self._fd = fd
47 self.finished = False
49 def run(self): argument
52 self._fd.close()
54 self.finished = True
69 def AnycastSetsockopt(self, s, is_add, netid, addr): argument
70 ifindex = self.ifindices[netid]
[all …]
Dnetlink.py68 def _Debug(self, s): argument
69 if self.DEBUG:
72 def _NlAttr(self, nla_type, data): argument
79 def _NlAttrIPAddress(self, nla_type, family, address): argument
80 return self._NlAttr(nla_type, socket.inet_pton(family, address))
82 def _NlAttrStr(self, nla_type, value): argument
84 return self._NlAttr(nla_type, value.encode("UTF-8"))
86 def _NlAttrU32(self, nla_type, value): argument
87 return self._NlAttr(nla_type, struct.pack("=I", value))
89 def _GetConstantName(self, module, value, prefix): argument
[all …]
Dcstruct_test.py29 def CheckEquals(self, a, b): argument
30 self.assertEquals(a, b)
31 self.assertEquals(b, a)
37 def CheckNotEquals(self, a, b): argument
38 self.assertNotEquals(a, b)
39 self.assertNotEquals(b, a)
45 def testEqAndNe(self): argument
50 self.CheckNotEquals(a1, b)
51 self.CheckNotEquals(a2, b)
52 self.CheckNotEquals(a1, a2)
[all …]
Dtcp_fastopen_test.py40 def TFOClientSocket(self, version, netid): argument
43 self.SelectInterface(s, netid, "mark")
47 def assertSocketNotConnected(self, sock): argument
48 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
50 def assertSocketConnected(self, sock): argument
53 def clearTcpMetrics(self, version, netid): argument
54 saddr = self.MyAddress(version, netid)
55 daddr = self.GetRemoteAddress(version)
56 self.tcp_metrics.DelMetrics(saddr, daddr)
57 with self.assertRaisesErrno(ESRCH):
[all …]
Dtcp_metrics.py58 def __init__(self): argument
59 super(TcpMetrics, self).__init__()
62 self.family = ctrl.GetFamily(TCP_METRICS_GENL_NAME)
64 def _Decode(self, command, msg, nla_type, nla_data): argument
67 name = self._GetConstantName(__name__, nla_type, "TCP_METRICS_ATTR_")
86 def MaybeDebugCommand(self, command, unused_flags, data): argument
87 if "ALL" not in self.NL_DEBUG and command not in self.NL_DEBUG:
89 parsed = self._ParseNLMsg(data, genetlink.Genlmsghdr)
91 def _NlAttrSaddr(self, address): argument
98 return self._NlAttrIPAddress(nla_type, family, address)
[all …]
Dnf_test.py36 def setUp(self): argument
37 multinetwork_base.MultiNetworkBaseTest.setUp(self)
41 def tearDown(self): argument
44 multinetwork_base.MultiNetworkBaseTest.tearDown(self)
48 def CheckRejectedTcp(self, version, addr): argument
50 netid = self.RandomNetid()
51 self.SelectInterface(sock, netid, "mark")
59 def testRejectTcp4(self): argument
60 self.CheckRejectedTcp(4, _TEST_IP4_ADDR)
62 def testRejectTcp6(self): argument
[all …]
Dremoved_feature_test.py42 def assertFeatureEnabled(self, featureName): argument
43 return self.assertEqual("y", self.KCONFIG[featureName])
45 def assertFeatureAbsent(self, featureName): argument
46 return self.assertTrue(featureName not in self.KCONFIG)
48 def testNetfilterRejectWithSocketError(self): argument
61 self.assertFeatureEnabled("CONFIG_IP_NF_FILTER")
62 self.assertFeatureEnabled("CONFIG_IP_NF_TARGET_REJECT")
63 self.assertFeatureAbsent("CONFIG_IP_NF_TARGET_REJECT_SKERR")
65 self.assertFeatureEnabled("CONFIG_IP6_NF_FILTER")
66 self.assertFeatureEnabled("CONFIG_IP6_NF_TARGET_REJECT")
[all …]
Dleak_test.py29 def testRecvfromLeak(self): argument
37 self.assertRaisesErrno(ENOTCONN, s.shutdown, SHUT_RDWR)
46 self.assertEqual("", data)
47 self.assertEqual(None, addr)
55 def CheckForceSocketBufferOption(self, option, force_option): argument
64 self.assertGreater(2 * val, minbuf)
66 self.assertEquals(2 * val, s.getsockopt(SOL_SOCKET, option))
74 self.assertEquals(minbuf, s.getsockopt(SOL_SOCKET, option))
76 def testRcvBufForce(self): argument
77 self.CheckForceSocketBufferOption(SO_RCVBUF, self.SO_RCVBUFFORCE)
[all …]
/kernel/tests/devicetree/early_mount/
Ddt_early_mount_test.py55 def setUp(self): argument
56 self._android_dt_dir = GetAndroidDtDir()
57 self._fstab_dt_dir = os.path.join(self._android_dt_dir, 'fstab')
59 def GetEarlyMountedPartitions(self): argument
62 return [x for x in os.listdir(self._fstab_dt_dir) if os.path.isdir(x)]
64 def VerifyFstabEntry(self, partition): argument
65 partition_dt_dir = os.path.join(self._fstab_dt_dir, partition)
68 self.assertTrue(
72 def testFstabCompatible(self): argument
74 compatible = ReadFile(os.path.join(self._fstab_dt_dir, 'compatible'))
[all …]

12