| /packages/modules/Bluetooth/system/osi/src/ |
| D | socket.cc | 56 ret->fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in socket_new()
85 void socket_free(socket_t* socket) { in socket_free() argument
86 if (!socket) return; in socket_free()
88 socket_unregister(socket); in socket_free()
89 close(socket->fd); in socket_free()
90 osi_free(socket); in socket_free()
93 bool socket_listen(const socket_t* socket, port_t port) { in socket_listen() argument
94 CHECK(socket != NULL); in socket_listen()
100 if (bind(socket->fd, (struct sockaddr*)&addr, sizeof(addr)) == -1) { in socket_listen()
106 if (listen(socket->fd, 10) == -1) { in socket_listen()
[all …]
|
| /packages/modules/Bluetooth/system/test/mock/ |
| D | mock_osi_socket.h | 65 std::function<socket_t*(const socket_t* socket)> body{
66 [this](const socket_t* socket) { return return_value; }};
67 socket_t* operator()(const socket_t* socket) { return body(socket); }; in operator()
76 std::function<ssize_t(const socket_t* socket)> body{
77 [this](const socket_t* socket) { return return_value; }};
78 ssize_t operator()(const socket_t* socket) { return body(socket); }; in operator()
86 std::function<void(socket_t* socket)> body{[](socket_t* socket) {}};
87 void operator()(socket_t* socket) { body(socket); }; in operator()
96 std::function<bool(const socket_t* socket, port_t port)> body{
97 [this](const socket_t* socket, port_t port) { return return_value; }};
[all …]
|
| D | mock_osi_socket.cc | 58 socket_t* socket_accept(const socket_t* socket) { in socket_accept() argument
60 return test::mock::osi_socket::socket_accept(socket); in socket_accept()
62 ssize_t socket_bytes_available(const socket_t* socket) { in socket_bytes_available() argument
64 return test::mock::osi_socket::socket_bytes_available(socket); in socket_bytes_available()
66 void socket_free(socket_t* socket) { in socket_free() argument
68 test::mock::osi_socket::socket_free(socket); in socket_free()
70 bool socket_listen(const socket_t* socket, port_t port) { in socket_listen() argument
72 return test::mock::osi_socket::socket_listen(socket, port); in socket_listen()
82 ssize_t socket_read(const socket_t* socket, void* buf, size_t count) { in socket_read() argument
84 return test::mock::osi_socket::socket_read(socket, buf, count); in socket_read()
[all …]
|
| /packages/modules/Connectivity/tests/cts/net/src/android/net/cts/ |
| D | SSLCertificateSocketFactoryTest.java | 134 Socket socket = new Socket(); in createSocket_io_error_expected() local
135 mSocketFactory.createSocket(socket, "localhost", HTTPS_PORT, true); in createSocket_io_error_expected()
174 Socket socket = mSocketFactory.createSocket(TEST_HOST, HTTPS_PORT); in createSocket_simple_with_hostname_verification() local
175 assertConnectedSocket(socket); in createSocket_simple_with_hostname_verification()
176 socket.close(); in createSocket_simple_with_hostname_verification()
202 Socket socket = mSocketFactory.createSocket(underlying, TEST_HOST, HTTPS_PORT, true); in createSocket_wrapped_with_hostname_verification() local
203 assertConnectedSocket(socket); in createSocket_wrapped_with_hostname_verification()
204 socket.close(); in createSocket_wrapped_with_hostname_verification()
231 Socket socket = mSocketFactory.createSocket(TEST_HOST, HTTPS_PORT, mLocalAddress, 0); in createSocket_bound_with_hostname_verification() local
232 assertConnectedSocket(socket); in createSocket_bound_with_hostname_verification()
[all …]
|
| D | VpnServiceTest.java | 68 DatagramSocket socket = new DatagramSocket(); in testProtect_DatagramSocket() local
71 assertFalse(mVpnService.protect(socket)); in testProtect_DatagramSocket()
74 socket.close(); in testProtect_DatagramSocket()
83 Socket socket = new Socket(); in testProtect_Socket() local
86 assertFalse(mVpnService.protect(socket)); in testProtect_Socket()
89 socket.close(); in testProtect_Socket()
98 DatagramSocket socket = new DatagramSocket(); in testProtect_int() local
99 ParcelFileDescriptor descriptor = ParcelFileDescriptor.fromDatagramSocket(socket); in testProtect_int()
110 socket.close(); in testProtect_int()
|
| /packages/modules/Connectivity/framework/src/android/net/ |
| D | Network.java | 208 Socket socket = createSocket(); in connectToHost() local
211 if (localAddress != null) socket.bind(localAddress); in connectToHost()
212 socket.connect(new InetSocketAddress(hostAddresses[i], port)); in connectToHost()
214 return socket; in connectToHost()
216 if (failed) IoUtils.closeQuietly(socket); in connectToHost()
234 Socket socket = createSocket(); in createSocket() local
237 socket.bind(new InetSocketAddress(localAddress, localPort)); in createSocket()
238 socket.connect(new InetSocketAddress(address, port)); in createSocket()
241 if (failed) IoUtils.closeQuietly(socket); in createSocket()
243 return socket; in createSocket()
[all …]
|
| D | QosSocketInfo.java | 123 public QosSocketInfo(@NonNull final Network network, @NonNull final Socket socket) in QosSocketInfo() argument
125 Objects.requireNonNull(socket, "socket cannot be null"); in QosSocketInfo()
128 mParcelFileDescriptor = ParcelFileDescriptor.fromSocket(socket); in QosSocketInfo()
130 new InetSocketAddress(socket.getLocalAddress(), socket.getLocalPort()); in QosSocketInfo()
133 if (socket.isConnected()) { in QosSocketInfo()
134 mRemoteSocketAddress = (InetSocketAddress) socket.getRemoteSocketAddress(); in QosSocketInfo()
148 public QosSocketInfo(@NonNull final Network network, @NonNull final DatagramSocket socket) in QosSocketInfo() argument
150 Objects.requireNonNull(socket, "socket cannot be null"); in QosSocketInfo()
153 mParcelFileDescriptor = ParcelFileDescriptor.fromDatagramSocket(socket); in QosSocketInfo()
155 new InetSocketAddress(socket.getLocalAddress(), socket.getLocalPort()); in QosSocketInfo()
[all …]
|
| /packages/apps/Dialer/java/com/android/voicemail/impl/mail/ |
| D | MailTransport.java | 60 private Socket socket; field in MailTransport
130 socket = createSocket(); in open()
133 socket.connect(address, SOCKET_CONNECT_TIMEOUT); in open()
143 in = new BufferedInputStream(socket.getInputStream(), 1024); in open()
144 out = new BufferedOutputStream(socket.getOutputStream(), 512); in open()
145 socket.setSoTimeout(SOCKET_READ_TIMEOUT); in open()
159 socket.close(); in open()
160 socket = null; in open()
207 socket = in reopenTls()
209 .createSocket(socket, address.getHostName(), address.getPort(), true); in reopenTls()
[all …]
|
| /packages/modules/Bluetooth/android/pandora/mmi2grpc/mmi2grpc/ |
| D | _modem.py | 2 import socket
8 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
11 self.socket = s
15 …self.socket.sendall(b'REM0\r\nAT+REMOTECALL=6,0,0,"' + str(phone_number).encode("utf-8") + b'",0\r…
16 self.socket.close()
20 …self.socket.sendall(b'REM0\r\nAT+REMOTECALL=4,0,0,"' + str(phone_number).encode("utf-8") + b'",129…
24 …self.socket.sendall(b'REM0\r\nAT+REMOTECALL=0,0,0,"' + str(phone_number).encode("utf-8") + b'",129…
|
| /packages/modules/Bluetooth/system/osi/include/ |
| D | socket.h | 30 typedef void (*socket_cb)(socket_t* socket, void* context);
46 void socket_free(socket_t* socket);
51 bool socket_listen(const socket_t* socket, port_t port);
56 socket_t* socket_accept(const socket_t* socket);
68 ssize_t socket_read(const socket_t* socket, void* buf, size_t count);
80 ssize_t socket_write(const socket_t* socket, const void* buf, size_t count);
87 ssize_t socket_write_and_transfer_fd(const socket_t* socket, const void* buf,
97 ssize_t socket_bytes_available(const socket_t* socket);
104 void socket_register(socket_t* socket, reactor_t* reactor, void* context,
109 void socket_unregister(socket_t* socket);
|
| /packages/modules/adb/ |
| D | test_adb.py | 27 import socket
40 with socket.socket() as s:
45 def fake_adbd(protocol=socket.AF_INET, port=0):
48 serversock = socket.socket(protocol, socket.SOCK_STREAM)
49 serversock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
50 if protocol == socket.AF_INET:
57 readsock, writesock = socket.socketpair()
88 ready.shutdown(socket.SHUT_RDWR)
323 sock.setsockopt(socket.SOL_SOCKET, socket.SO_LINGER,
326 linger = sock.getsockopt(socket.SOL_SOCKET, socket.SO_LINGER, 16)
[all …]
|
| D | SOCKET-ACTIVATION.txt | 1 adb can be configured to work with systemd-style socket activation,
12 After=adb.socket
13 Requires=adb.socket
20 --- START adb.socket CUT HERE ---
29 --- END adb.socket CUT HERE ---
42 serve socket, not the accepted connection socket.
|
| /packages/modules/Bluetooth/tools/rootcanal/model/setup/ |
| D | test_channel_transport.cc | 46 void TestChannelTransport::OnCommandReady(AsyncDataChannel* socket, in OnCommandReady() argument
49 ssize_t bytes_read = socket->Recv(&command_name_size, 1); in OnCommandReady()
53 socket->Close(); in OnCommandReady()
57 bytes_read = socket->Recv(&command_name_raw[0], command_name_size); in OnCommandReady()
67 socket->Close(); in OnCommandReady()
72 bytes_read = socket->Recv(&num_args, 1); in OnCommandReady()
80 bytes_read = socket->Recv(&arg_size, 1); in OnCommandReady()
87 bytes_read = socket->Recv(&arg[0], arg_size); in OnCommandReady()
99 std::shared_ptr<AsyncDataChannel> socket, in SendResponse() argument
110 ssize_t written = socket->Send(size_buf, 4); in SendResponse()
[all …]
|
| /packages/modules/Bluetooth/system/btif/src/ |
| D | btif_sock_sco.cc | 57 socket_t* socket; member
65 static void sco_socket_free_locked(sco_socket_t* socket);
71 static void socket_read_ready_cb(socket_t* socket, void* context);
131 socket_t* socket = NULL; in sco_socket_establish_locked() local
155 socket = socket_new_from_fd(pair[1]); in sco_socket_establish_locked()
156 if (!socket) { in sco_socket_establish_locked()
163 sco_socket->socket = socket; // Hang on to the other end. in sco_socket_establish_locked()
166 socket_register(socket, thread_get_reactor(thread), sco_socket, in sco_socket_establish_locked()
192 socket_free(sco_socket->socket); in sco_socket_free_locked()
253 if (socket_write_and_transfer_fd(sco_socket->socket, &connect_signal, in connection_request_cb()
[all …]
|
| /packages/modules/Connectivity/nearby/tests/robotests/src/com/android/libraries/testing/deviceshadower/shadows/bluetooth/ |
| D | ShadowBluetoothServerSocket.java | 65 BluetoothSocket socket = Shadow.directlyOn(mRealServerSocket, BluetoothServerSocket.class, in accept() local
69 String remoteAddress = socket.getRemoteDevice().getAddress(); in accept()
70 ShadowLocalSocket shadowLocalSocket = getLocalSocketShadow(socket); in accept()
75 return socket; in accept()
86 BluetoothSocket socket = ReflectionHelpers.getField(mRealServerSocket, "mSocket"); in getServerSocketFileDescriptor() local
87 ParcelFileDescriptor pfd = ReflectionHelpers.getField(socket, "mPfd"); in getServerSocketFileDescriptor()
96 BluetoothSocket socket = ReflectionHelpers.getField(mRealServerSocket, "mSocket"); in getPort() local
97 return ReflectionHelpers.getField(socket, "mPort"); in getPort()
100 private ShadowLocalSocket getLocalSocketShadow(BluetoothSocket socket) { in getLocalSocketShadow() argument
101 LocalSocket localSocket = ReflectionHelpers.getField(socket, "mSocket"); in getLocalSocketShadow()
|
| /packages/modules/NetworkStack/tests/integration/src/android/net/util/ |
| D | NetworkStackUtilsIntegrationTest.kt | 106 val socket = Os.socket(AF_INET, SOCK_DGRAM or SOCK_NONBLOCK, IPPROTO_UDP) in testAddArpEntry() constant
107 SocketUtils.bindSocketToInterface(socket, iface.interfaceName) in testAddArpEntry()
110 socket) in testAddArpEntry()
128 Os.sendto(socket, originalPacket, 0 /* bytesOffset */, originalPacket.size /* bytesCount */, in testAddArpEntry()
148 val socket = Os.socket(AF_PACKET, SOCK_RAW, ETH_P_IPV6) in testAttachRaFilter() constant
152 Os.bind(socket, socketAddr) in testAttachRaFilter()
153 Os.setsockoptTimeval(socket, SOL_SOCKET, SO_RCVTIMEO, in testAttachRaFilter()
161 assertNextPacketEquals(socket, echo.readAsArray(), "ICMPv6 echo") in testAttachRaFilter()
163 NetworkStackUtils.attachRaFilter(socket, ARPHRD_ETHER) in testAttachRaFilter()
176 assertNextPacketEquals(socket, ra.readAsArray(), "ICMPv6 RA") in testAttachRaFilter()
[all …]
|
| /packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/keepalive/ |
| D | IkeNattKeepalive.java | 51 UdpEncapsulationSocket socket, in IkeNattKeepalive() argument
61 socket, in IkeNattKeepalive()
73 UdpEncapsulationSocket socket, in IkeNattKeepalive() argument
85 socket, in IkeNattKeepalive()
87 new HardwareKeepaliveCb(context, dest, socket, ikeAlarmConfig)); in IkeNattKeepalive()
124 UdpEncapsulationSocket socket, in createSoftwareKeepaliveImpl() argument
126 return new SoftwareKeepaliveImpl(context, dest, socket, alarmConfig); in createSoftwareKeepaliveImpl()
139 UdpEncapsulationSocket socket, in HardwareKeepaliveCb() argument
143 mSocket = socket; in HardwareKeepaliveCb()
|
| /packages/modules/Connectivity/framework/src/android/net/util/ |
| D | DnsUtils.java | 167 final FileDescriptor socket; in findSrcAddress() local
169 socket = Os.socket(domain, SOCK_DGRAM, IPPROTO_UDP); in findSrcAddress()
175 if (network != null) network.bindSocket(socket); in findSrcAddress()
176 Os.connect(socket, new InetSocketAddress(addr, 0)); in findSrcAddress()
177 return ((InetSocketAddress) Os.getsockname(socket)).getAddress(); in findSrcAddress()
181 IoUtils.closeQuietly(socket); in findSrcAddress()
361 final FileDescriptor socket; in checkConnectivity() local
363 socket = Os.socket(domain, SOCK_DGRAM, IPPROTO_UDP); in checkConnectivity()
368 if (network != null) network.bindSocket(socket); in checkConnectivity()
369 Os.connect(socket, addr); in checkConnectivity()
[all …]
|
| /packages/apps/Nfc/src/com/android/nfc/snep/ |
| D | SnepClient.java | 142 LlcpSocket socket = null; in connect() local
147 socket = NfcService.getInstance().createLlcpSocket(0, mMiu, mRwSize, 1024); in connect()
148 if (socket == null) { in connect()
153 socket.connectToService(mServiceName); in connect()
156 socket.connectToSap(mPort); in connect()
158 int miu = socket.getRemoteMiu(); in connect()
160 messenger = new SnepMessenger(true, socket, fragmentLength); in connect()
167 if (socket != null) { in connect()
169 socket.close(); in connect()
|
| /packages/modules/Bluetooth/tools/rootcanal/desktop/ |
| D | test_environment.cc | 64 SetUpHciServer([this](std::shared_ptr<AsyncDataChannel> socket, in initialize()
66 auto transport = HciSocketTransport::Create(socket); in initialize()
117 link_ble_socket_server_, [this](std::shared_ptr<AsyncDataChannel> socket, in SetUpLinkBleLayerServer()
121 LinkLayerSocketDevice::Create(socket, phy_type), phy_type); in SetUpLinkBleLayerServer()
132 link_socket_server_, [this](std::shared_ptr<AsyncDataChannel> socket, in SetUpLinkLayerServer() argument
136 LinkLayerSocketDevice::Create(socket, phy_type), phy_type); in SetUpLinkLayerServer()
147 auto socket = connector_->ConnectToRemoteServer(server, port); in ConnectToRemoteServer() local
148 if (!socket->Connected()) return nullptr; in ConnectToRemoteServer()
149 return LinkLayerSocketDevice::Create(socket, phy_type); in ConnectToRemoteServer()
|
| /packages/modules/DnsResolver/doh/connection/ |
| D | mod.rs | 58 fn mark_socket(socket: &std::net::UdpSocket, socket_mark: u32) -> io::Result<()> { in mark_socket()
60 let fd = socket.as_raw_fd(); in mark_socket()
91 let socket = UdpSocket::bind(bind_addr).await?; in build_socket() localVariable
92 let std_socket = socket.into_std()?; in build_socket()
96 let socket = UdpSocket::from_std(std_socket)?; in build_socket() localVariable
97 socket.connect(peer_addr).await?; in build_socket()
98 Ok(socket) in build_socket()
150 let socket = build_socket(to, socket_mark, tag_socket).await?; in new() localVariable
152 let result = drive(request_rx, status_tx, quiche_conn, socket, net_id).await; in new()
|
| /packages/modules/adb/daemon/ |
| D | jdwp_service.cpp | 144 static void jdwp_process_event(int socket, unsigned events, void* _proc);
152 JdwpProcess(unique_fd socket, ProcessInfo process) { in JdwpProcess()
155 this->socket = socket; in JdwpProcess()
157 this->fde = fdevent_create(socket.release(), jdwp_process_event, this); in JdwpProcess()
165 if (this->socket >= 0) { in ~JdwpProcess()
166 adb_shutdown(this->socket); in ~JdwpProcess()
167 this->socket = -1; in ~JdwpProcess()
183 borrowed_fd socket = -1; member
259 static void jdwp_process_event(int socket, unsigned events, void* _proc) { in jdwp_process_event() argument
261 CHECK_EQ(socket, proc->socket.get()); in jdwp_process_event()
[all …]
|
| /packages/modules/Connectivity/tests/cts/netpermission/updatestatspermission/src/android/net/cts/network/permission/ |
| D | UpdateStatsPermissionTest.java | 55 Socket socket = new Socket("example.com", 80); in testUpdateDeviceStatsPermission() local
56 TrafficStats.tagSocket(socket); in testUpdateDeviceStatsPermission()
62 socket.setTcpNoDelay(true); in testUpdateDeviceStatsPermission()
63 socket.setSoLinger(true, 0); in testUpdateDeviceStatsPermission()
64 OutputStream out = socket.getOutputStream(); in testUpdateDeviceStatsPermission()
69 socket.close(); in testUpdateDeviceStatsPermission()
|
| /packages/modules/Connectivity/framework-t/src/android/net/ |
| D | IpSecManager.java | 379 public void applyTransportModeTransform(@NonNull Socket socket, in applyTransportModeTransform() argument
382 socket.getSoLinger(); in applyTransportModeTransform()
384 applyTransportModeTransform(socket.getFileDescriptor$(), direction, transform); in applyTransportModeTransform()
416 public void applyTransportModeTransform(@NonNull DatagramSocket socket, in applyTransportModeTransform() argument
418 applyTransportModeTransform(socket.getFileDescriptor$(), direction, transform); in applyTransportModeTransform()
463 public void applyTransportModeTransform(@NonNull FileDescriptor socket, in applyTransportModeTransform() argument
467 try (ParcelFileDescriptor pfd = ParcelFileDescriptor.dup(socket)) { in applyTransportModeTransform()
489 public void removeTransportModeTransforms(@NonNull Socket socket) throws IOException { in removeTransportModeTransforms() argument
491 socket.getSoLinger(); in removeTransportModeTransforms()
493 removeTransportModeTransforms(socket.getFileDescriptor$()); in removeTransportModeTransforms()
[all …]
|
| /packages/apps/Nfc/src/com/android/nfc/echoserver/ |
| D | EchoServer.java | 180 private void handleClient(LlcpSocket socket) { in handleClient() argument
187 int size = socket.receive(dataUnit); in handleClient()
279 LlcpConnectionlessSocket socket; field in EchoServer.ConnectionlessServerThread
294 socket = mService.createLlcpConnectionLessSocket( in run()
296 if (socket == null) { in run()
303 packet = socket.receive(); in run()
329 if (socket != null) { in run()
331 socket.close(); in run()
346 socket.send(mRemoteSap, data); in write()
|