/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_tests/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 94 socket.inet_pton(socket.AF_INET6, ip_address) 96 except socket.error: 266 socket = sutils.open_datagram_socket(ad, local_ip, port) 268 ad, ad, socket, socket, remote_ip, port) 269 sutils.close_datagram_socket(ad, socket)
|
D | WifiSoftApTest.py | 155 socket = sutils.open_datagram_socket(ad, local_ip, port) 157 ad, ad, socket, socket, remote_ip, port) 158 sutils.close_datagram_socket(ad, socket)
|
/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
D | sl4a_session.py | 16 import socket 189 client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 191 client_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 194 client_socket.bind((socket.gethostname(), ports.client_port)) 209 except socket.timeout: 213 except socket.error as e:
|
/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)
|
D | net_test_utils.py | 303 socket.inet_pton(socket.AF_INET6, ip_address) 305 except socket.error:
|
/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/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/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 | android_device.py | 22 import socket 1300 socket.inet_aton(ip_address) 1302 except socket.error: 1323 socket.inet_aton(ipv4_gateway) 1325 except socket.error:
|
/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/acloud/internal/lib/ |
D | utils.py | 31 import socket 767 tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 783 tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 786 except socket.error:
|
/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:
|
D | md8475a.py | 22 import socket 471 self._sock = socket.create_connection((self._ipaddr, port_number), 479 except socket.timeout: 482 except socket.error: 595 except socket.timeout: 597 except socket.error: 620 except socket.timeout: 622 except socket.error: 630 except socket.error:
|
/tools/test/connectivity/acts/framework/acts/ |
D | utils.py | 31 import socket 1343 socket.inet_pton(socket.AF_INET, address) 1346 socket.inet_aton(address) 1347 except socket.error: 1350 except socket.error: # not a valid address 1360 socket.inet_pton(socket.AF_INET6, address) 1361 except socket.error: # not a valid address
|
/tools/tradefederation/core/test_framework/com/android/tradefed/testtype/ |
D | IsolatedHostTest.java | 165 Socket socket = mServer.accept(); in run() local 166 socket.setSoTimeout(mSocketTimeout); in run() 189 this.executeTests(socket, listener, paramsBuilder.build()); in run() 194 .writeDelimitedTo(socket.getOutputStream()); in run() 259 Socket socket, ITestInvocationListener listener, TestParameters params) in executeTests() argument 265 .writeDelimitedTo(socket.getOutputStream()); in executeTests() 270 RunnerReply reply = RunnerReply.parseDelimitedFrom(socket.getInputStream()); in executeTests()
|
/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 307 server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 308 server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
|
/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/tradefederation/core/tests/src/com/android/tradefed/util/ |
D | SubprocessTestResultsParserTest.java | 304 Socket socket = null; in testParser_receiveFromSocket() local 308 socket = new Socket("localhost", resultParser.getSocketServerPort()); in testParser_receiveFromSocket() 309 if (!socket.isConnected()) { in testParser_receiveFromSocket() 312 PrintWriter out = new PrintWriter(socket.getOutputStream(), true); in testParser_receiveFromSocket() 324 StreamUtil.close(socket); in testParser_receiveFromSocket() 329 StreamUtil.close(socket); in testParser_receiveFromSocket()
|
/tools/test/connectivity/acts/framework/acts/controllers/fuchsia_lib/ |
D | utils_lib.py | 21 import socket 67 paramiko.ssh_exception.AuthenticationException, socket.timeout, 68 socket.error, ConnectionRefusedError, ConnectionResetError),
|