| /tools/test/connectivity/acts/framework/acts/controllers/utils_lib/ |
| D | host_utils.py | 15 import socket
31 port = _try_bind(0, socket.SOCK_STREAM, socket.IPPROTO_TCP)
33 if port and _try_bind(port, socket.SOCK_DGRAM, socket.IPPROTO_UDP):
46 return (_try_bind(port, socket.SOCK_STREAM, socket.IPPROTO_TCP) and
47 _try_bind(port, socket.SOCK_DGRAM, socket.IPPROTO_UDP))
51 s = socket.socket(socket.AF_INET, socket_type, socket_proto)
58 except socket.error:
|
| /tools/test/connectivity/acts/framework/tests/ |
| D | acts_host_utils_test.py | 17 import socket
29 test_s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
38 test_s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
| /tools/test/connectivity/acts/tests/google/bt/power/ |
| D | SetupBTPairingTest.py | 25 import socket
49 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
50 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
60 except socket.timeout:
62 except socket.error:
68 sock.shutdown(socket.SHUT_RDWR)
|
| /tools/test/connectivity/acts/tests/google/wifi/ |
| D | SetupWifiNetworkTest.py | 18 import socket
34 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
35 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
45 except socket.timeout:
47 except socket.error:
51 sock.shutdown(socket.SHUT_RDWR)
|
| D | WifiTetheringTest.py | 18 import socket
96 socket.inet_pton(socket.AF_INET6, ip_address)
98 except socket.error:
268 socket = sutils.open_datagram_socket(ad, local_ip, port)
270 ad, ad, socket, socket, remote_ip, port)
271 sutils.close_datagram_socket(ad, socket)
|
| /tools/test/connectivity/acts/framework/tests/controllers/ |
| D | abstract_inst_test.py | 18 import socket
41 mock_connect.side_effect = socket.timeout
51 mock_connect.side_effect = socket.error
73 test_inst._socket.sendall.side_effect = socket.timeout
83 test_inst._socket.sendall.side_effect = socket.error
104 test_inst._socket.recv.side_effect = socket.timeout
114 test_inst._socket.recv.side_effect = socket.error
128 mock_connect.return_value.shutdown.assert_called_with(socket.SHUT_RDWR)
|
| /tools/test/connectivity/acts/framework/acts/controllers/ |
| D | abstract_inst.py | 18 import socket
74 self._socket = socket.create_connection(
81 except socket.timeout:
86 except socket.error:
109 except socket.timeout:
115 except socket.error:
148 except socket.timeout:
153 except socket.error:
177 self._socket.shutdown(socket.SHUT_RDWR)
|
| D | packet_sender.py | 21 import socket
182 except socket.error as excpt:
204 except socket.error as excpt:
455 ndst_ip = socket.inet_pton(socket.AF_INET6, target_ip6)
457 node_mcast = socket.inet_ntop(socket.AF_INET6, nnode_mcast)
|
| D | native.py | 20 import socket
|
| /tools/test/connectivity/acts/framework/acts/test_utils/net/ |
| D | ipsec_test_utils.py | 148 def apply_transport_mode_transforms_datagram_socket(ad, socket, transforms): argument
157 socket, cconst.DIRECTION_IN, transforms[0])
159 socket, cconst.DIRECTION_OUT, transforms[1])
166 def remove_transport_mode_transforms_datagram_socket(ad, socket): argument
173 status = ad.droid.ipSecRemoveTransportModeTransformsDatagramSocket(socket)
176 def apply_transport_mode_transforms_socket(ad, socket, transforms): argument
185 socket, cconst.DIRECTION_IN, transforms[0])
187 socket, cconst.DIRECTION_OUT, transforms[1])
194 def remove_transport_mode_transforms_socket(ad, socket): argument
201 status = ad.droid.ipSecRemoveTransportModeTransformsSocket(socket)
|
| D | socket_test_utils.py | 241 def close_socket(ad, socket): argument
248 status = ad.droid.closeTcpSocket(socket)
251 def close_server_socket(ad, socket): argument
258 status = ad.droid.closeTcpServerSocket(socket)
261 def shutdown_socket(ad, socket): argument
268 fd = ad.droid.getFileDescriptorOfSocket(socket)
|
| D | connectivity_test_utils.py | 59 def start_tcp_socket_keepalive(ad, socket, time_interval = 10): argument
68 key = ad.droid.startTcpSocketKeepalive(socket, time_interval)
|
| /tools/test/connectivity/acts/framework/tests/controllers/sl4a_lib/ |
| D | sl4a_session_test.py | 18 from socket import timeout
19 from socket import error as socket_error
83 with mock.patch('socket.socket') as socket:
90 socket.return_value = socket_instance
109 with mock.patch('socket.socket') as socket:
114 socket.return_value = socket_instance
130 with mock.patch('socket.socket') as socket:
135 socket.return_value = socket_instance
157 with mock.patch('socket.socket') as socket:
162 socket.return_value = socket_instance
|
| /tools/test/connectivity/acts/framework/acts/controllers/anritsu_lib/ |
| D | mg3710a.py | 22 import socket
59 self._sock = socket.create_connection(
65 except socket.timeout:
68 except socket.error:
101 except socket.timeout:
103 except socket.error:
125 except socket.timeout:
127 except socket.error:
|
| /tools/test/connectivity/acts/framework/tests/controllers/rohdeschwarz_lib/ |
| D | contest_test.py | 20 import socket
65 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
|
| /tools/test/connectivity/acts/framework/acts/controllers/fuchsia_lib/ |
| D | utils_lib.py | 21 import socket
59 paramiko.ssh_exception.AuthenticationException, socket.timeout,
60 socket.error, ConnectionRefusedError, ConnectionResetError),
|
| D | base_lib.py | 25 import socket
|
| /tools/tradefederation/core/test_framework/com/android/tradefed/testtype/ |
| D | IsolatedHostTest.java | 164 Socket socket = mServer.accept(); in run() local
165 socket.setSoTimeout(mSocketTimeout); in run()
188 this.executeTests(socket, listener, paramsBuilder.build()); in run()
193 .writeDelimitedTo(socket.getOutputStream()); in run()
255 Socket socket, ITestInvocationListener listener, TestParameters params) in executeTests() argument
261 .writeDelimitedTo(socket.getOutputStream()); in executeTests()
266 RunnerReply reply = RunnerReply.parseDelimitedFrom(socket.getInputStream()); in executeTests()
|
| /tools/acloud/internal/lib/ |
| D | utils.py | 32 import socket
761 tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
777 tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
780 except socket.error:
|
| D | base_cloud_client.py | 22 import socket
62 socket.error, ssl.SSLError)
|
| /tools/asuite/atest/metrics/ |
| D | metrics_base.py | 23 import socket
76 hostname = socket.getfqdn()
|
| /tools/tradefederation/core/atest/metrics/ |
| D | metrics_base.py | 23 import socket
76 hostname = socket.getfqdn()
|
| /tools/tradefederation/core/atest/test_runners/ |
| D | atest_tf_test_runner.py | 25 import socket
273 server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
274 server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
|
| /tools/asuite/atest/test_runners/ |
| D | atest_tf_test_runner.py | 27 import socket
282 server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
283 server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
|
| /tools/test/connectivity/acts/framework/acts/ |
| D | utils.py | 30 import socket
1336 socket.inet_pton(socket.AF_INET, address)
1339 socket.inet_aton(address)
1340 except socket.error:
1343 except socket.error: # not a valid address
1353 socket.inet_pton(socket.AF_INET6, address)
1354 except socket.error: # not a valid address
|