Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 46) sorted by relevance

12

/openthread-latest/tests/scripts/thread-cert/
Dmcast6.py31 import socket
86 addrinfo = socket.getaddrinfo(group, None)[0]
88 s = socket.socket(addrinfo[0], socket.SOCK_DGRAM)
89 s.setsockopt(socket.SOL_SOCKET, socket.SO_BINDTODEVICE, (ifname + '\0').encode('ascii'))
93 assert addrinfo[0] == socket.AF_INET6
94 s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_HOPS, ttl_bin)
104 addrinfo = socket.getaddrinfo(group, None)[0]
105 assert addrinfo[0] == socket.AF_INET6
108 s = socket.socket(addrinfo[0], socket.SOCK_DGRAM)
109 s.setsockopt(socket.SOL_SOCKET, socket.SO_BINDTODEVICE, (ifname + '\0').encode('ascii'))
[all …]
Dsniffer_transport.py32 import socket
124 self._socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
129 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
130 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
131 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 2 * 1024 * 1024)
132 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, 2 * 1024 * 1024)
133 self._socket.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP,
134 socket.inet_aton(self.RADIO_GROUP) + socket.inet_aton('127.0.0.1'))
Dudp_send_host.py29 import socket
44 sock = socket.socket(
45 socket.AF_INET6, # Internet
46 socket.SOCK_DGRAM) # UDP
50 sock.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_HOPS, hop_limit)
52 sock.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_UNICAST_HOPS, hop_limit)
Dsimulator.py33 import socket
153 self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
154 self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 2 * 1024 * 1024)
155 self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, 2 * 1024 * 1024)
267 except socket.error:
285 except socket.error:
433 except socket.error:
/openthread-latest/tests/scripts/misc/
Dtest_multicast_join.py30 import socket
49 with socket.socket(socket.AF_INET6, socket.SOCK_DGRAM) as s:
50 s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_IF, if_index)
51 s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP,
52 struct.pack('16si', socket.inet_pton(socket.AF_INET6, group), if_index))
59 s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_LEAVE_GROUP,
60 struct.pack('16si', socket.inet_pton(socket.AF_INET6, group), if_index))
/openthread-latest/tools/harness-simulation/posix/sniffer_sim/
Dsniffer_transport.py31 import socket
117 self._socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
122 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
123 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
124 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 2 * 1024 * 1024)
125 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, 2 * 1024 * 1024)
126 self._socket.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP,
127 socket.inet_aton(self.RADIO_GROUP) + socket.inet_aton('127.0.0.1'))
Dsniffer.py38 import socket
131 except socket.timeout:
/openthread-latest/tools/tcat_ble_client/ble/
Dudp_stream.py30 import socket
43 self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
44 self.socket.setblocking(False)
49 return self.socket.sendto(data, self.address)
52 ready = select.select([self.socket], [], [], self.MAX_SERVER_TIMEOUT_SEC)
54 data = self.socket.recv(bufsize)
/openthread-latest/tools/harness-automation/autothreadharness/
Dpdu_controller.py221 def _outlet_oid_get(self, param, socket): argument
240 return parameters[param.lower()] + str(socket)
289 def _outlet_value_set(self, cmd, socket, value=1): argument
298 oid = self._outlet_oid_get(cmd, socket)
306 def _outlet_value_get(self, cmd, socket): argument
317 oid = self._outlet_oid_get(cmd, socket)
321 def validate_state(self, socket, state): argument
322 return (self._outlet_value_get('get_state', socket) == state)
333 for socket in sockets:
334 self._outlet_value_set('set_off', socket)
[all …]
Dopen_thread_controller.py32 import socket
100 self.handle = socket.create_connection(address)
105 self.handle = socket.create_connection((host, port))
165 except socket.error:
182 except socket.error:
/openthread-latest/tools/harness-simulation/posix/
Dlaunch_testbed.py38 import socket
66 def init_socket(ifname: str, group: str, port: int) -> socket.socket:
68 addrinfo = socket.getaddrinfo(group, None)[0]
69 assert addrinfo[0] == socket.AF_INET6
72 s = socket.socket(addrinfo[0], socket.SOCK_DGRAM)
73 s.setsockopt(socket.SOL_SOCKET, socket.SO_BINDTODEVICE, (ifname + '\0').encode('ascii'))
78 group_bin = socket.inet_pton(addrinfo[0], addrinfo[4][0])
82 s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP, mreq)
87 def _advertise(s: socket.socket, dst, info): argument
92 def advertise_devices(s: socket.socket, dst, ven: str, add: str, nodeids: Iterable[int], tag: str): argument
[all …]
/openthread-latest/third_party/mbedtls/repo/tests/src/test_helpers/
Dssl_helpers.c313 void mbedtls_test_mock_socket_init(mbedtls_test_mock_socket *socket) in mbedtls_test_mock_socket_init() argument
315 memset(socket, 0, sizeof(*socket)); in mbedtls_test_mock_socket_init()
318 void mbedtls_test_mock_socket_close(mbedtls_test_mock_socket *socket) in mbedtls_test_mock_socket_close() argument
320 if (socket == NULL) { in mbedtls_test_mock_socket_close()
324 if (socket->input != NULL) { in mbedtls_test_mock_socket_close()
325 mbedtls_test_ssl_buffer_free(socket->input); in mbedtls_test_mock_socket_close()
326 mbedtls_free(socket->input); in mbedtls_test_mock_socket_close()
329 if (socket->output != NULL) { in mbedtls_test_mock_socket_close()
330 mbedtls_test_ssl_buffer_free(socket->output); in mbedtls_test_mock_socket_close()
331 mbedtls_free(socket->output); in mbedtls_test_mock_socket_close()
[all …]
/openthread-latest/tests/scripts/thread-cert/border_router/nat64/
Dtest_single_border_router.py38 import socket
92 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
108 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
/openthread-latest/src/posix/platform/
Dudp.cpp548 … for (otUdpSocket *socket = otUdpGetSockets(gInstance); socket != nullptr; socket = socket->mNext) in Update() local
552 if (socket->mHandle == nullptr) in Update()
557 fd = FdFromHandle(socket->mHandle); in Update()
609 … for (otUdpSocket *socket = otUdpGetSockets(gInstance); socket != nullptr; socket = socket->mNext) in Process() local
611 int fd = FdFromHandle(socket->mHandle); in Process()
621 messageInfo.mSockPort = socket->mSockName.mPort; in Process()
641 socket->mHandler(socket->mContext, message, &messageInfo); in Process()
Dmisc.cpp105 VerifyOrExit((fd = socket(aDomain, aType, aProtocol)) != -1, perror("socket(SOCK_CLOEXEC)")); in SocketWithCloseExec()
112 VerifyOrExit((fd = socket(aDomain, aType, aProtocol)) != -1, perror("socket(SOCK_CLOEXEC)")); in SocketWithCloseExec()
/openthread-latest/third_party/mbedtls/repo/tests/scripts/
Dtcp_client.pl25 my $socket = IO::Socket::INET->new(PeerAddr => $host,
29 die "Cannot connect to $host:$port: $!" unless $socket;
30 return $socket;
/openthread-latest/src/cli/
DREADME_UDP.md13 On node 1, open and bind the example UDP socket.
24 On node 2, open the example UDP socket and send a simple message.
68 Assigns a name (i.e. IPv6 address and port) to the example socket.
90 Closes the example socket.
99 Specifies the peer with which the socket is to be associated.
149 Opens the example socket.
204 Send a UDP message on a connected socket.
/openthread-latest/tools/harness-simulation/harness/Thread_Harness/Sniffer/
DSimSniffer.py36 import socket
224 sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM)
232 sock.setsockopt(IPPROTO_IPV6, socket.IPV6_MULTICAST_IF, ifn)
/openthread-latest/third_party/mbedtls/repo/tests/include/test/
Dssl_helpers.h179 mbedtls_test_mock_socket *socket; member
200 mbedtls_test_mock_socket socket; member
321 void mbedtls_test_mock_socket_init(mbedtls_test_mock_socket *socket);
336 void mbedtls_test_mock_socket_close(mbedtls_test_mock_socket *socket);
385 mbedtls_test_mock_socket *socket,
/openthread-latest/tests/toranj/ncp/
Dwpan.py37 import socket
774 return socket.getaddrinfo(ip_address, port)[0][4]
793 sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM)
794 sock.setsockopt(socket.SOL_SOCKET, _SO_BINDTODEVICE, node.interface_name + '\0')
795 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
799 sock.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_HOPS, mcast_hops)
916 sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM)
917 sock.setsockopt(socket.SOL_SOCKET, _SO_BINDTODEVICE, node.interface_name + '\0')
918 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
/openthread-latest/src/core/net/
Dudp6.cpp503 SocketHandle *socket; in HandlePayload() local
521 socket = mSockets.FindMatching(socketsBegin, socketsEnd, aMessageInfo, prev); in HandlePayload()
524 socket = mSockets.FindMatching(aMessageInfo, prev); in HandlePayload()
527 VerifyOrExit(socket != nullptr); in HandlePayload()
531 socket->HandleUdpReceive(aMessage, aMessageInfo); in HandlePayload()
541 for (const SocketHandle &socket : mSockets) in IsPortInUse() local
543 if (socket.GetSockName().GetPort() == aPort) in IsPortInUse()
/openthread-latest/third_party/mbedtls/repo/tests/suites/
Dtest_suite_ssl.function262 mbedtls_test_mock_socket socket;
264 mbedtls_test_mock_socket_init(&socket);
266 TEST_ASSERT(mbedtls_test_mock_tcp_send_b(&socket, message, MSGLEN) < 0);
267 mbedtls_test_mock_socket_close(&socket);
268 mbedtls_test_mock_socket_init(&socket);
269 TEST_ASSERT(mbedtls_test_mock_tcp_recv_b(&socket, received, MSGLEN) < 0);
270 mbedtls_test_mock_socket_close(&socket);
272 mbedtls_test_mock_socket_init(&socket);
273 TEST_ASSERT(mbedtls_test_mock_tcp_send_nb(&socket, message, MSGLEN) < 0);
274 mbedtls_test_mock_socket_close(&socket);
[all …]
/openthread-latest/tools/harness-simulation/harness/Thread_Harness/THCI/
DOpenThread_Sim.py37 import socket
119 except socket.timeout:
/openthread-latest/examples/platforms/simulation/
Dsimul_utils.c73 fd = socket(aIp4Address ? AF_INET : AF_INET6, SOCK_DGRAM, IPPROTO_UDP); in InitRxSocket()
147 fd = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP); in InitTxSocketIp6()
187 fd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); in InitTxSocketIp4()
/openthread-latest/third_party/mbedtls/repo/library/
Dnet_sockets.c181 ctx->fd = (int) socket(cur->ai_family, cur->ai_socktype, in mbedtls_net_connect()
230 ctx->fd = (int) socket(cur->ai_family, cur->ai_socktype, in mbedtls_net_bind()
387 (bind_ctx->fd = (int) socket(local_addr.ss_family, in mbedtls_net_accept()

12