/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/pbapclient/obex/ |
D | PbapClientSocket.java | 49 private final BluetoothSocket mSocket; field in PbapClientSocket 87 mSocket = socket; in PbapClientSocket() 97 mSocket = null; in PbapClientSocket() 110 if (mSocket != null) { in connect() 111 mSocket.connect(); in connect() 117 if (mSocket != null) { in getRemoteDevice() 118 return mSocket.getRemoteDevice(); in getRemoteDevice() 125 if (mSocket != null) { in getConnectionType() 126 return mSocket.getConnectionType(); in getConnectionType() 136 if (mSocket != null) { in getMaxTransmitPacketSize() [all …]
|
D | PbapClientObexTransport.java | 34 private final PbapClientSocket mSocket; field in PbapClientObexTransport 40 mSocket = requireNonNull(socket); in PbapClientObexTransport() 45 mSocket.close(); in close() 60 return mSocket.getInputStream(); in openInputStream() 65 return mSocket.getOutputStream(); in openOutputStream() 87 if (mSocket.getConnectionType() != BluetoothSocket.TYPE_L2CAP) { in getMaxTransmitPacketSize() 90 return mSocket.getMaxTransmitPacketSize(); in getMaxTransmitPacketSize() 95 if (mSocket.getConnectionType() != BluetoothSocket.TYPE_L2CAP) { in getMaxReceivePacketSize() 98 return mSocket.getMaxReceivePacketSize(); in getMaxReceivePacketSize() 103 String identityAddress = Utils.getBrEdrAddress(mSocket.getRemoteDevice()); in getRemoteAddress() [all …]
|
D | PbapClientConnectionHandler.java | 88 private BluetoothSocket mSocket; field in PbapClientConnectionHandler 245 return mSocket; in getSocket() 258 mSocket = in connectSocket() 262 mSocket = mDevice.createL2capSocket(mPseRec.getL2capPsm()); in connectSocket() 265 mSocket = mDevice.createRfcommSocket(mPseRec.getRfcommChannelNumber()); in connectSocket() 271 if (mSocket != null) { in connectSocket() 272 mSocket.connect(); in connectSocket() 291 BluetoothObexTransport transport = new BluetoothObexTransport(mSocket); in connectObexSession() 335 if (mSocket != null) { in closeSocket() 336 Log.d(TAG, "Closing socket" + mSocket); in closeSocket() [all …]
|
D | PbapClientObexClient.java | 99 private PbapClientSocket mSocket; // Wraps a BluetoothSocket, for testability field in PbapClientObexClient 358 closeSocket(mSocket); in close() 411 mSocket = connectSocket(transport, psmOrChannel); in handleMessage() 412 if (mSocket == null) { in handleMessage() 419 mObexSession = connectObex(mSocket, mLocalSupportedFeatures); in handleMessage() 421 closeSocket(mSocket); in handleMessage() 422 mSocket = null; in handleMessage() 451 closeSocket(mSocket); in handleMessage() 452 mSocket = null; in handleMessage()
|
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/ |
D | BluetoothObexTransport.java | 31 private BluetoothSocket mSocket = null; field in BluetoothObexTransport 42 this.mSocket = socket; in BluetoothObexTransport() 46 this.mSocket = socket; in BluetoothObexTransport() 53 mSocket.close(); in close() 68 return mSocket.getInputStream(); in openInputStream() 73 return mSocket.getOutputStream(); in openOutputStream() 94 if (mSocket.getConnectionType() != BluetoothSocket.TYPE_L2CAP in getMaxTransmitPacketSize() 98 return mSocket.getMaxTransmitPacketSize(); in getMaxTransmitPacketSize() 103 if (mSocket.getConnectionType() != BluetoothSocket.TYPE_L2CAP) { in getMaxReceivePacketSize() 106 return mSocket.getMaxReceivePacketSize(); in getMaxReceivePacketSize() [all …]
|
/packages/modules/Connectivity/tests/unit/java/com/android/server/connectivity/mdns/ |
D | MdnsMultinetworkSocketClientTest.java | 74 @Mock private MdnsInterfaceSocket mSocket; field in MdnsMultinetworkSocketClientTest 147 for (MdnsInterfaceSocket socket : List.of(mSocket, tetherIfaceSock1, tetherIfaceSock2)) { in testSendPacket() 156 callback.onSocketCreated(mSocketKey, mSocket, List.of()); in testSendPacket() 167 verify(mSocket).send(ipv4Packet); in testSendPacket() 175 verify(mSocket, times(2)).send(ipv4Packet); in testSendPacket() 183 verify(mSocket, never()).send(ipv6Packet); in testSendPacket() 193 verify(mSocket, never()).send(ipv6Packet); in testSendPacket() 214 doReturn(createEmptyNetworkInterface()).when(mSocket).getInterface(); in testReceivePacket() 216 callback.onSocketCreated(mSocketKey, mSocket, List.of()); in testReceivePacket() 221 verify(mSocket).addPacketHandler(handlerCaptor.capture()); in testReceivePacket() [all …]
|
/packages/modules/Bluetooth/framework/java/android/bluetooth/ |
D | BluetoothServerSocket.java | 80 /*package*/ final BluetoothSocket mSocket; field in BluetoothServerSocket 104 mSocket = new BluetoothSocket(type, auth, encrypt, port, null); in BluetoothServerSocket() 106 mSocket.setExcludeSdp(true); in BluetoothServerSocket() 128 mSocket = new BluetoothSocket(type, auth, encrypt, port, null, pitm, min16DigitPin); in BluetoothServerSocket() 130 mSocket.setExcludeSdp(true); in BluetoothServerSocket() 148 mSocket = new BluetoothSocket(type, auth, encrypt, -1, uuid); in BluetoothServerSocket() 150 mChannel = mSocket.getPort(); in BluetoothServerSocket() 188 mSocket = in BluetoothServerSocket() 203 mSocket.setExcludeSdp(true); in BluetoothServerSocket() 240 acceptedSocket = mSocket.accept(timeout); in accept() [all …]
|
D | BluetoothInputStream.java | 33 private final BluetoothSocket mSocket; field in BluetoothInputStream 36 mSocket = s; in BluetoothInputStream() 41 return mSocket.available(); in available() 45 mSocket.close(); in close() 59 int ret = mSocket.read(b, 0, 1); in read() 88 return mSocket.read(b, offset, length); in read()
|
D | BluetoothOutputStream.java | 33 private final BluetoothSocket mSocket; field in BluetoothOutputStream 36 mSocket = s; in BluetoothOutputStream() 41 mSocket.close(); in close() 55 mSocket.write(b, 0, 1); in write() 77 mSocket.write(b, offset, count); in write()
|
D | BluetoothSocket.java | 189 @UnsupportedAppUsage private LocalSocket mSocket; field in BluetoothSocket 481 bluetoothSocket.mSocket = new LocalSocket(pfd.getFileDescriptor()); in createSocketFromOpenFd() 482 bluetoothSocket.mSocketIS = bluetoothSocket.mSocket.getInputStream(); in createSocketFromOpenFd() 483 bluetoothSocket.mSocketOS = bluetoothSocket.mSocket.getOutputStream(); in createSocketFromOpenFd() 519 FileDescriptor[] fds = mSocket.getAncillaryFileDescriptors(); in acceptSocket() 528 as.mSocket = new LocalSocket(fds[0]); in acceptSocket() 529 as.mSocketIS = as.mSocket.getInputStream(); in acceptSocket() 530 as.mSocketOS = as.mSocket.getOutputStream(); in acceptSocket() 701 mSocket = new LocalSocket(fd); in connect() 702 mSocketIS = mSocket.getInputStream(); in connect() [all …]
|
/packages/modules/ImsMedia/tests/native/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/utils/ |
D | ImsMediaSocketTest.cpp | 24 ISocket* mSocket = nullptr; member in ImsMediaSocketTest 35 mSocket = ISocket::GetInstance(localPort, peerIpAddress, peerPort); in SetUp() 39 mSocket->SetLocalEndpoint(localIpAddress, localPort); in SetUp() 40 mSocket->SetPeerEndpoint(peerIpAddress, peerPort); in SetUp() 41 EXPECT_EQ(mSocket->Open(mSocketRtpFd), true); in SetUp() 50 ISocket::ReleaseInstance(mSocket); in TearDown() 56 EXPECT_EQ(mSocket->SetSocketOpt(kSocketOptionIpTos, -72), true); in TEST_F() 57 EXPECT_EQ(mSocket->SetSocketOpt(kSocketOptionIpTos, 0), true); in TEST_F() 58 EXPECT_EQ(mSocket->SetSocketOpt(kSocketOptionIpTos, 4), true); in TEST_F() 59 EXPECT_EQ(mSocket->SetSocketOpt(kSocketOptionIpTos, 46), true); in TEST_F() [all …]
|
/packages/apps/TV/tuner/src/com/android/tv/tuner/hdhomerun/ |
D | HdHomeRunControlSocket.java | 44 private Socket mSocket; field in HdHomeRunControlSocket 106 if (mSocket != null) { in connectAndUpdateDeviceInfo() 133 mSocket = new Socket(); in connectAndUpdateDeviceInfo() 135 mSocket.connect( in connectAndUpdateDeviceInfo() 141 if (DEBUG) Log.d(TAG, "Cannot connect to socket: " + mSocket); in connectAndUpdateDeviceInfo() 142 mSocket = null; in connectAndUpdateDeviceInfo() 147 Log.i(TAG, "Connected to socket: " + mSocket); in connectAndUpdateDeviceInfo() 154 if (mSocket == null && !connectAndUpdateDeviceInfo()) { in sendAndReceive() 176 OutputStream out = mSocket.getOutputStream(); in send() 177 mSocket.setSoTimeout(HdHomeRunUtils.HDHOMERUN_CONTROL_SEND_TIMEOUT_MS); in send() [all …]
|
/packages/modules/ImsMedia/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/nodes/ |
D | SocketWriterNode.cpp | 24 mSocket = nullptr; in SocketWriterNode() 31 if (mSocket != nullptr) in ~SocketWriterNode() 45 mSocket = ISocket::GetInstance(mLocalAddress.port, mPeerAddress.ipAddress, mPeerAddress.port); in Start() 47 if (mSocket == nullptr) in Start() 54 mSocket->SetLocalEndpoint(mLocalAddress.ipAddress, mLocalAddress.port); in Start() 55 mSocket->SetPeerEndpoint(mPeerAddress.ipAddress, mPeerAddress.port); in Start() 57 if (!mSocket->Open(mLocalFd)) in Start() 64 mSocket->SetSocketOpt(kSocketOptionIpTos, mDscp); in Start() 74 if (mSocket != nullptr) in Stop() 78 mSocket->Close(); in Stop() [all …]
|
D | SocketReaderNode.cpp | 28 mSocket = nullptr; in SocketReaderNode() 180 if (mSocketOpened && mSocket != nullptr) in OnReadDataFromSocket() 182 int len = mSocket->ReceiveFrom(mBuffer, DEFAULT_MTU); in OnReadDataFromSocket() 216 mSocket = ISocket::GetInstance(mLocalAddress.port, mPeerAddress.ipAddress, mPeerAddress.port); in OpenSocket() 218 if (mSocket == nullptr) in OpenSocket() 225 mSocket->SetLocalEndpoint(mLocalAddress.ipAddress, mLocalAddress.port); in OpenSocket() 226 mSocket->SetPeerEndpoint(mPeerAddress.ipAddress, mPeerAddress.port); in OpenSocket() 228 if (!mSocketOpened && !mSocket->Open(mLocalFd)) in OpenSocket() 237 if (mSocket->SetSocketOpt(kSocketOptionIpTtl, 1)) in OpenSocket() 242 mSocket->Listen(this); in OpenSocket() [all …]
|
/packages/services/Car/libs/obd2-lib/src/com/android/car/obd2/connections/ |
D | BluetoothConnection.java | 41 private BluetoothSocket mSocket = null; field in BluetoothConnection 71 mSocket = mDevice.createRfcommSocketToServiceRecord(SERIAL_PORT_PROFILE); in connect() 72 mSocket.connect(); in connect() 75 mSocket = null; in connect() 78 return mSocket.isConnected(); in connect() 83 return mSocket != null && mSocket.isConnected(); in isConnected() 89 mSocket.close(); in close() 94 mSocket = null; in close() 109 return mSocket.getInputStream(); in getInputStream() 121 return mSocket.getOutputStream(); in getOutputStream()
|
/packages/modules/Connectivity/tests/cts/net/src/android/net/cts/ |
D | IpSecBaseTest.java | 323 public final DatagramSocket mSocket; field in IpSecBaseTest.JavaUdpSocket 327 mSocket = new DatagramSocket(port, localAddr); in JavaUdpSocket() 328 mSocket.setSoTimeout(SOCK_TIMEOUT); in JavaUdpSocket() 338 mSocket = new DatagramSocket(0, localAddr); in JavaUdpSocket() 339 mSocket.setSoTimeout(SOCK_TIMEOUT); in JavaUdpSocket() 349 mSocket.send(new DatagramPacket(data, data.length)); in send() 354 mSocket.send(new DatagramPacket(data, data.length, dstAddr, port)); in sendTo() 359 return mSocket.getLocalPort(); in getPort() 364 mSocket.close(); in close() 370 mSocket.receive(data); in receive() [all …]
|
D | RateLimitTest.java | 110 private DatagramSocket mSocket; field in RateLimitTest 181 mSocket = new DatagramSocket(TEST_UDP_PORT); in setUp() 182 mSocket.setSoTimeout(1_000); in setUp() 183 mNetwork.bindSocket(mSocket); in setUp() 192 if (mSocket != null) mSocket.close(); in tearDown() 228 private DatagramSocket mSocket; field in RateLimitTest.RateMeasurementSocketReader 234 mSocket = socket; in RateMeasurementSocketReader() 257 mSocket.receive(receivedPacket); in run() 279 final RateMeasurementSocketReader reader = new RateMeasurementSocketReader(mSocket); in runIngressDataRateMeasurement()
|
/packages/modules/Uwb/ranging/test_app/app/src/main/java/com/android/ranging/rangingtestapp/ |
D | OobBleClient.java | 44 private BluetoothSocket mSocket; field in OobBleClient 63 mSocket.getOutputStream().write(data); in sendData() 97 OobBleClient.this.mSocket = in run() 100 OobBleClient.this.mSocket.connect(); in run() 102 printLog("Connected on L2cap socket " + mSocket.getRemoteDevice().getAddress()); in run() 109 int dataSize = OobBleClient.this.mSocket.getInputStream().read(data); in run() 122 OobBleClient.this.mSocket.close(); in run()
|
D | OobBleServer.java | 45 private BluetoothSocket mSocket; field in OobBleServer 64 mSocket.getOutputStream().write(data); in sendData() 126 OobBleServer.this.mSocket = socket; in OobBleServerConnectionThread() 135 int dataSize = OobBleServer.this.mSocket.getInputStream().read(data); in run() 148 OobBleServer.this.mSocket.close(); in run()
|
/packages/modules/Connectivity/service-t/src/com/android/server/connectivity/mdns/ |
D | MdnsSocketProvider.java | 325 final MdnsInterfaceSocket mSocket; field in MdnsSocketProvider.SocketInfo 332 mSocket = socket; in SocketInfo() 455 socketInfo.mSocket.joinGroup(addresses); in updateSocketInfoAddress() 594 socketInfo.mSocket.destroy(); in removeNetworkSocket() 596 mSocketRequestMonitor.onSocketDestroyed(network, socketInfo.mSocket); in removeNetworkSocket() 603 socketInfo.mSocket.destroy(); in removeTetherInterfaceSocket() 605 mSocketRequestMonitor.onSocketDestroyed(null /* network */, socketInfo.mSocket); in removeTetherInterfaceSocket() 614 socketInfo.mSocket, socketInfo.mAddresses); in notifySocketCreated() 615 mSocketRequestMonitor.onSocketRequestFulfilled(network, socketInfo.mSocket, in notifySocketCreated() 626 .onInterfaceDestroyed(socketInfo.mSocketKey, socketInfo.mSocket); in notifyInterfaceDestroyed() [all …]
|
/packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/ |
D | IkeUdpSocket.java | 43 protected final FileDescriptor mSocket; field in IkeUdpSocket 47 mSocket = socket; in IkeUdpSocket() 53 return mSocket; in getFd() 106 Os.sendto(mSocket, buffer, 0, serverAddress, getIkeServerPort()); in sendIkePacket() 121 IoUtils.close(mSocket); in close()
|
/packages/modules/DnsResolver/ |
D | DnsTlsTransport.cpp | 161 if (!mSocket) { in query() 178 const bool sent = mSocket->query(q.newId, netdutils::drop(netdutils::makeSlice(q.query), 2)); in sendQuery() 187 mSocket = mFactory->createDnsTlsSocket(mServer, mMark, this, &mCache); in doConnect() 190 if (mSocket.get() == nullptr || !mSocket->startHandshake()) { in doConnect() 205 mSocket.reset(); in doConnect() 247 mSocket.reset(); in doReconnect() 269 mSocket.reset(); in ~DnsTlsTransport()
|
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/mapclient/ |
D | MasClient.java | 83 private BluetoothSocket mSocket; field in MasClient 116 mSocket = mRemoteDevice.createL2capSocket(l2capSocket); in connect() 122 mSocket = mRemoteDevice.createRfcommSocket(mSdpMasRecord.getRfcommCannelNumber()); in connect() 124 Log.d(TAG, mRemoteDevice.toString() + "Socket: " + mSocket.toString()); in connect() 125 mSocket.connect(); in connect() 126 mTransport = new BluetoothObexTransport(mSocket); in connect()
|
/packages/modules/Connectivity/Tethering/src/android/net/ip/ |
D | RouterAdvertisementDaemon.java | 124 private volatile FileDescriptor mSocket; field in RouterAdvertisementDaemon 507 mSocket = Os.socket(AF_INET6, SOCK_RAW, IPPROTO_ICMPV6); in createSocket() 510 mSocket, SOL_SOCKET, SO_SNDTIMEO, StructTimeval.fromMillis(send_timout_ms)); in createSocket() 511 SocketUtils.bindSocketToInterface(mSocket, mInterface.name); in createSocket() 512 TetheringUtils.setupRaSocket(mSocket, mInterface.index); in createSocket() 524 if (mSocket != null) { in closeSocket() 526 SocketUtils.closeSocket(mSocket); in closeSocket() 529 mSocket = null; in closeSocket() 533 final FileDescriptor s = mSocket; in isSocketValid() 559 Os.sendto(mSocket, mRA, 0, mRaLength, 0, dest); in maybeSendRA() [all …]
|
/packages/services/BuiltInPrintService/src/com/android/bips/ipp/ |
D | GetCapabilitiesTask.java | 46 private volatile Socket mSocket; field in GetCapabilitiesTask 57 mSocket = socket; in isDeviceOnline() 64 mSocket = null; in isDeviceOnline() 71 Socket socket = mSocket; in forceCancel()
|