/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
H A D | quic_connection_peer.cc | 22 QuicConnection* connection, SendAlgorithmInterface* send_algorithm) { in SetSendAlgorithm() argument 23 GetSentPacketManager(connection)->SetSendAlgorithm(send_algorithm); in SetSendAlgorithm() 28 QuicConnection* connection, LossDetectionInterface* loss_algorithm) { in SetLossAlgorithm() argument 29 GetSentPacketManager(connection)->loss_algorithm_ = loss_algorithm; in SetLossAlgorithm() 34 QuicConnection* connection) { in GetPacketCreator() argument 35 return &connection->packet_creator_; in GetPacketCreator() 40 QuicConnection* connection) { in GetSentPacketManager() argument 41 return &connection->sent_packet_manager_; in GetSentPacketManager() 46 QuicConnection* connection) { in GetNetworkTimeout() argument 47 return connection->idle_network_detector_.idle_network_timeout_; in GetNetworkTimeout() [all …]
|
H A D | quic_connection_peer.h | 39 static void SetSendAlgorithm(QuicConnection* connection, 42 static void SetLossAlgorithm(QuicConnection* connection, 45 static QuicPacketCreator* GetPacketCreator(QuicConnection* connection); 48 QuicConnection* connection); 50 static QuicTime::Delta GetNetworkTimeout(QuicConnection* connection); 52 static QuicTime::Delta GetHandshakeTimeout(QuicConnection* connection); 54 static void SetPerspective(QuicConnection* connection, 57 static void SetSelfAddress(QuicConnection* connection, 60 static void SetPeerAddress(QuicConnection* connection, 64 QuicConnection* connection, const QuicSocketAddress& direct_peer_address); [all …]
|
/aosp_15_r20/cts/tests/tests/telecom/src/android/telecom/cts/ |
H A D | ConnectionTest.java | 26 import android.telecom.Connection; 45 Connection connection = createConnection(lock); in testStateCallbacks() local 48 assertEquals(Connection.STATE_NEW, connection.getState()); in testStateCallbacks() 50 connection.setInitializing(); in testStateCallbacks() 52 assertEquals(Connection.STATE_INITIALIZING, connection.getState()); in testStateCallbacks() 54 connection.setInitialized(); in testStateCallbacks() 56 assertEquals(Connection.STATE_NEW, connection.getState()); in testStateCallbacks() 58 connection.setRinging(); in testStateCallbacks() 60 assertEquals(Connection.STATE_RINGING, connection.getState()); in testStateCallbacks() 62 connection.setDialing(); in testStateCallbacks() [all …]
|
/aosp_15_r20/external/google-cloud-java/java-bigqueryconnection/proto-google-cloud-bigqueryconnection-v1/src/main/java/com/google/cloud/bigquery/connection/v1/ |
H A D | Connection.java | 17 // source: google/cloud/bigquery/connection/v1/connection.proto 19 package com.google.cloud.bigquery.connection.v1; 25 * Configuration parameters to establish connection with an external data 29 * Protobuf type {@code google.cloud.bigquery.connection.v1.Connection} 31 public final class Connection extends com.google.protobuf.GeneratedMessageV3 class 33 // @@protoc_insertion_point(message_implements:google.cloud.bigquery.connection.v1.Connection) 36 // Use Connection.newBuilder() to construct. 37 private Connection(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Connection() method in Connection 41 private Connection() { in Connection() method in Connection 50 return new Connection(); in newInstance() [all …]
|
H A D | ListConnectionsResponse.java | 17 // source: google/cloud/bigquery/connection/v1/connection.proto 19 package com.google.cloud.bigquery.connection.v1; 26 …* [ConnectionService.ListConnections][google.cloud.bigquery.connection.v1.ConnectionService.ListCo… 29 * Protobuf type {@code google.cloud.bigquery.connection.v1.ListConnectionsResponse} 33 …// @@protoc_insertion_point(message_implements:google.cloud.bigquery.connection.v1.ListConnections… 58 return com.google.cloud.bigquery.connection.v1.ConnectionOuterClass in getDescriptor() 65 return com.google.cloud.bigquery.connection.v1.ConnectionOuterClass in internalGetFieldAccessorTable() 68 com.google.cloud.bigquery.connection.v1.ListConnectionsResponse.class, in internalGetFieldAccessorTable() 69 com.google.cloud.bigquery.connection.v1.ListConnectionsResponse.Builder.class); in internalGetFieldAccessorTable() 126 private java.util.List<com.google.cloud.bigquery.connection.v1.Connection> connections_; [all …]
|
H A D | CreateConnectionRequest.java | 17 // source: google/cloud/bigquery/connection/v1/connection.proto 19 package com.google.cloud.bigquery.connection.v1; 26 …* [ConnectionService.CreateConnection][google.cloud.bigquery.connection.v1.ConnectionService.Creat… 29 * Protobuf type {@code google.cloud.bigquery.connection.v1.CreateConnectionRequest} 33 …// @@protoc_insertion_point(message_implements:google.cloud.bigquery.connection.v1.CreateConnectio… 58 return com.google.cloud.bigquery.connection.v1.ConnectionOuterClass in getDescriptor() 65 return com.google.cloud.bigquery.connection.v1.ConnectionOuterClass in internalGetFieldAccessorTable() 68 com.google.cloud.bigquery.connection.v1.CreateConnectionRequest.class, in internalGetFieldAccessorTable() 69 com.google.cloud.bigquery.connection.v1.CreateConnectionRequest.Builder.class); in internalGetFieldAccessorTable() 137 * Optional. Connection id that should be assigned to the created connection. [all …]
|
H A D | UpdateConnectionRequest.java | 17 // source: google/cloud/bigquery/connection/v1/connection.proto 19 package com.google.cloud.bigquery.connection.v1; 26 …* [ConnectionService.UpdateConnection][google.cloud.bigquery.connection.v1.ConnectionService.Updat… 29 * Protobuf type {@code google.cloud.bigquery.connection.v1.UpdateConnectionRequest} 33 …// @@protoc_insertion_point(message_implements:google.cloud.bigquery.connection.v1.UpdateConnectio… 57 return com.google.cloud.bigquery.connection.v1.ConnectionOuterClass in getDescriptor() 64 return com.google.cloud.bigquery.connection.v1.ConnectionOuterClass in internalGetFieldAccessorTable() 67 com.google.cloud.bigquery.connection.v1.UpdateConnectionRequest.class, in internalGetFieldAccessorTable() 68 com.google.cloud.bigquery.connection.v1.UpdateConnectionRequest.Builder.class); in internalGetFieldAccessorTable() 79 * Required. Name of the connection to update, for example: [all …]
|
/aosp_15_r20/cts/apps/CtsVerifier/src/com/android/cts/verifier/usb/device/ |
H A D | UsbDeviceTestActivity.java | 167 UsbDeviceConnection connection = mUsbManager.openDevice(device); in onCreate() 169 makeThisDeviceAnAccessory(connection); in onCreate() 171 connection.close(); in onCreate() 215 * @param connection The connection to the USB device 217 private void makeThisDeviceAnAccessory(@NonNull UsbDeviceConnection connection) { in makeThisDeviceAnAccessory() argument 218 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_MANUFACTURER, in makeThisDeviceAnAccessory() 220 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_MODEL, in makeThisDeviceAnAccessory() 222 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_DESCRIPTION, in makeThisDeviceAnAccessory() 224 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_VERSION, "2"); in makeThisDeviceAnAccessory() 225 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_URI, in makeThisDeviceAnAccessory() [all …]
|
/aosp_15_r20/tools/test/connectivity/acts_tests/tests/google/bt/ |
D | RfcommTest.py | 79 """Test Bluetooth RFCOMM connection 81 Test RFCOMM though establishing a basic connection. 85 2. Establish an RFCOMM connection from the client to the server AD. 86 3. Verify that the RFCOMM connection is active from both the client and 90 RFCOMM connection is established then disconnected succcessfully. 106 Test RFCOMM though establishing a connection. 110 2. Establish an RFCOMM connection from the client to the server AD. 111 3. Verify that the RFCOMM connection is active from both the client and 115 6. Disconnect the RFCOMM connection. 118 RFCOMM connection is established then disconnected succcessfully. [all …]
|
/aosp_15_r20/packages/services/Telephony/src/com/android/services/telephony/ |
D | ImsConferenceController.java | 24 import android.telecom.Connection; 92 public void onConferenceSupportedChanged(Connection c, boolean isConferenceSupported) { 98 public void onStateChanged(Connection c, int state) { 104 public void onDisconnected(Connection c, DisconnectCause disconnectCause) { 110 public void onDestroyed(Connection connection) { 111 remove(connection); 139 * @param connectionService The current connection service. 162 * Adds a new connection to the IMS conference controller. 164 * @param connection 166 void add(TelephonyConnection connection) { in add() argument [all …]
|
D | TelephonyConferenceController.java | 20 import android.telecom.Connection; 49 public void onStateChanged(Connection c, int state) { 50 Log.v(this, "onStateChange triggered in Conf Controller : connection = " + c 56 public void onDisconnected(Connection c, DisconnectCause disconnectCause) { 61 public void onDestroyed(Connection connection) { 63 remove((TelephonyConnection) connection); 76 /** The TelephonyConference connection object. */ 84 void add(TelephonyConnection connection) { in add() argument 85 if (mTelephonyConnections.contains(connection)) { in add() 87 Log.w(this, "add - connection already tracked; connection=%s", connection); in add() [all …]
|
/aosp_15_r20/external/google-cloud-java/java-bigqueryconnection/proto-google-cloud-bigqueryconnection-v1beta1/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ |
H A D | ConnectionProto.java | 17 // source: google/cloud/bigquery/connection/v1beta1/connection.proto 19 package com.google.cloud.bigquery.connection.v1beta1; 32 …// @@protoc_insertion_point(interface_extends:google.cloud.bigquery.connection.v1beta1.CreateConne… 70 * Optional. Connection id that should be assigned to the created connection. 82 * Optional. Connection id that should be assigned to the created connection. 95 * Required. Connection to create. 99 …* .google.cloud.bigquery.connection.v1beta1.Connection connection = 3 [(.google.api.field_behavior… 102 * @return Whether the connection field is set. 109 * Required. Connection to create. 113 …* .google.cloud.bigquery.connection.v1beta1.Connection connection = 3 [(.google.api.field_behavior… [all …]
|
/aosp_15_r20/external/openthread/tests/unit/ |
H A D | test_dso.cpp | 111 class Connection : public Dso::Connection class 116 explicit Connection(Instance &aInstance, in Connection() function in ot::Dns::Connection 120 : Dso::Connection(aInstance, aPeerSockAddr, sCallbacks) in Connection() 270 static void HandleConnected(Dso::Connection &aConnection) in HandleConnected() 272 static_cast<Connection &>(aConnection).HandleConnected(); in HandleConnected() 275 static void HandleSessionEstablished(Dso::Connection &aConnection) in HandleSessionEstablished() 277 static_cast<Connection &>(aConnection).HandleSessionEstablished(); in HandleSessionEstablished() 280 static void HandleDisconnected(Dso::Connection &aConnection) in HandleDisconnected() 282 static_cast<Connection &>(aConnection).HandleDisconnected(); in HandleDisconnected() 285 static Error ProcessRequestMessage(Dso::Connection &aConnection, in ProcessRequestMessage() [all …]
|
/aosp_15_r20/frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/ |
D | GsmCdmaConnectionTest.java | 49 private GsmCdmaConnection connection; field in GsmCdmaConnectionTest 67 if (connection != null) { in tearDown() 68 connection.dispose(); in tearDown() 69 connection = null; in tearDown() 76 connection = new GsmCdmaConnection(mPhone, String.format( in testFormatDialString() 80 String formattedDialStr = connection.formatDialString( in testFormatDialString() 86 formattedDialStr = connection.formatDialString("+1 (700).555-41NN,;1234"); in testFormatDialString() 93 connection = new GsmCdmaConnection(mPhone, "+8610000", mCT, null, in testOriginalDialString() 95 assertEquals("+8610000", connection.getOrigDialString()); in testOriginalDialString() 98 connection = new GsmCdmaConnection(mPhone, "+8610000", mCT, null, in testOriginalDialString() [all …]
|
/aosp_15_r20/external/webrtc/p2p/base/ |
H A D | basic_ice_controller.cc | 18 bool IsRelayRelay(const cricket::Connection* conn) { in IsRelayRelay() 23 bool IsUdp(const cricket::Connection* conn) { in IsUdp() 34 const cricket::Connection* conn, in LocalCandidateUsesPreferredNetwork() 41 const cricket::Connection* a, in CompareCandidatePairsByNetworkPreference() 42 const cricket::Connection* b, in CompareCandidatePairsByNetworkPreference() 73 const Connection* selected_connection) { in SetSelectedConnection() 77 void BasicIceController::AddConnection(const Connection* connection) { in AddConnection() argument 78 connections_.push_back(connection); in AddConnection() 79 unpinged_connections_.insert(connection); in AddConnection() 82 void BasicIceController::OnConnectionDestroyed(const Connection* connection) { in OnConnectionDestroyed() argument [all …]
|
H A D | p2p_transport_channel.cc | 33 #include "p2p/base/connection.h" 219 [this](const Connection* connection) { in P2PTransportChannel() 220 return IsPortPruned(connection->port()) || in P2PTransportChannel() 221 IsRemoteCandidatePruned(connection->remote_candidate()); in P2PTransportChannel() 234 std::vector<Connection*> copy(connections().begin(), connections().end()); in ~P2PTransportChannel() 235 for (Connection* connection : copy) { in ~P2PTransportChannel() 236 connection->SignalDestroyed.disconnect(this); in ~P2PTransportChannel() 237 RemoveConnection(connection); in ~P2PTransportChannel() 238 connection->Destroy(); in ~P2PTransportChannel() 272 void P2PTransportChannel::AddConnection(Connection* connection) { in AddConnection() argument [all …]
|
/aosp_15_r20/hardware/google/gfxstream/guest/magma/magma_enc/ |
D | magma_entry.cpp | 13 void magma_connection_release(magma_connection_t connection); 14 magma_status_t magma_connection_get_error(magma_connection_t connection); 15 …magma_status_t magma_connection_create_context(magma_connection_t connection, uint32_t* context_id… 16 void magma_connection_release_context(magma_connection_t connection, uint32_t context_id); 17 …magma_status_t magma_connection_create_buffer(magma_connection_t connection, uint64_t size, uint64… 18 void magma_connection_release_buffer(magma_connection_t connection, magma_buffer_t buffer); 19 …magma_status_t magma_connection_import_buffer(magma_connection_t connection, magma_handle_t buffer… 20 …magma_status_t magma_connection_create_semaphore(magma_connection_t connection, magma_semaphore_t*… 21 …void magma_connection_release_semaphore(magma_connection_t connection, magma_semaphore_t semaphore… 22 …magma_status_t magma_connection_import_semaphore(magma_connection_t connection, magma_handle_t sem… [all …]
|
/aosp_15_r20/external/aws-crt-java/src/native/ |
H A D | mqtt_connection.c | 13 #include <aws/http/connection.h> 40 struct mqtt_jni_connection *connection; member 66 struct mqtt_jni_connection *connection; member 72 static void s_mqtt_connection_destroy(JNIEnv *env, struct mqtt_jni_connection *connection); 74 static void s_mqtt_jni_connection_acquire(struct mqtt_jni_connection *connection) { in s_mqtt_jni_connection_acquire() argument 75 size_t old_value = aws_atomic_fetch_add(&connection->ref_count, 1); in s_mqtt_jni_connection_acquire() 80 static void s_on_shutdown_disconnect_complete(struct aws_mqtt_client_connection *connection, void *… 82 static void s_mqtt_jni_connection_release(struct mqtt_jni_connection *connection) { in s_mqtt_jni_connection_release() argument 83 size_t old_value = aws_atomic_fetch_sub(&connection->ref_count, 1); in s_mqtt_jni_connection_release() 89 static void s_mqtt_jni_connection_destroy(struct mqtt_jni_connection *connection) { in s_mqtt_jni_connection_destroy() argument [all …]
|
/aosp_15_r20/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
H A D | URLConnectionTest.java | 125 private HttpURLConnection connection; field in URLConnectionTest 150 connection = client.open(server.getUrl("/")); in requestHeaders() 151 connection.addRequestProperty("D", "e"); in requestHeaders() 152 connection.addRequestProperty("D", "f"); in requestHeaders() 153 assertEquals("f", connection.getRequestProperty("D")); in requestHeaders() 154 assertEquals("f", connection.getRequestProperty("d")); in requestHeaders() 155 Map<String, List<String>> requestHeaders = connection.getRequestProperties(); in requestHeaders() 169 connection.setRequestProperty(null, "j"); in requestHeaders() 174 connection.addRequestProperty(null, "k"); in requestHeaders() 178 connection.setRequestProperty("NullValue", null); in requestHeaders() [all …]
|
/aosp_15_r20/external/python/bumble/bumble/ |
D | device.py | 990 async def transfer(self, connection: Connection, service_data: int = 0) -> None: argument 992 await connection.transfer_periodic_sync(self.sync_handle, service_data) 1102 def __init__(self, connection: Connection) -> None: argument 1103 self.connection = connection 1105 # Create a GATT client for the connection 1106 self.gatt_client = gatt_client.Client(connection) 1107 connection.gatt_client = self.gatt_client 1115 self.connection.emit('connection_att_mtu_update') 1239 await self.connection.sustain(timeout) 1243 return await self.connection.request_remote_name() [all …]
|
/aosp_15_r20/external/google-cloud-java/java-bigqueryconnection/grpc-google-cloud-bigqueryconnection-v1beta1/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ |
H A D | ConnectionServiceGrpc.java | 16 package com.google.cloud.bigquery.connection.v1beta1; 29 comments = "Source: google/cloud/bigquery/connection/v1beta1/connection.proto") 36 "google.cloud.bigquery.connection.v1beta1.ConnectionService"; 40 com.google.cloud.bigquery.connection.v1beta1.ConnectionProto.CreateConnectionRequest, 41 com.google.cloud.bigquery.connection.v1beta1.ConnectionProto.Connection> 47 com.google.cloud.bigquery.connection.v1beta1.ConnectionProto.CreateConnectionRequest 49 responseType = com.google.cloud.bigquery.connection.v1beta1.ConnectionProto.Connection.class, 52 com.google.cloud.bigquery.connection.v1beta1.ConnectionProto.CreateConnectionRequest, 53 com.google.cloud.bigquery.connection.v1beta1.ConnectionProto.Connection> 56 com.google.cloud.bigquery.connection.v1beta1.ConnectionProto.CreateConnectionRequest, in getCreateConnectionMethod() [all …]
|
/aosp_15_r20/frameworks/base/telecomm/java/android/telecom/ |
H A D | ConnectionService.java | 97 * wherein it should provide a new instance of a {@link Connection} object. It is through this 98 * {@link Connection} object that telecom receives state updates and the {@link ConnectionService} 103 * <h1>Self-Managed Connection Services</h1> 111 * (e.g. {@link android.telecom.Connection#onAvailableCallEndpointsChanged(List)}) and a 113 * (e.g. {@link android.telecom.Connection#requestCallEndpointChange(CallEndpoint, Executor, 153 * create a new instance of {@link Connection} to represent a call in your app. 158 * ConnectionRequest)} - called by Telecom to ask your app to make a new {@link Connection} 166 * ConnectionRequest)} - called by Telecom to ask your app to make a new {@link Connection} 176 * <h2>Implementing a Connection</h2> 177 * Your app should extend the {@link Connection} class to represent calls in your app. When you [all …]
|
/aosp_15_r20/external/google-cloud-java/java-bigqueryconnection/grpc-google-cloud-bigqueryconnection-v1/src/main/java/com/google/cloud/bigquery/connection/v1/ |
H A D | ConnectionServiceGrpc.java | 16 package com.google.cloud.bigquery.connection.v1; 29 comments = "Source: google/cloud/bigquery/connection/v1/connection.proto") 35 public static final String SERVICE_NAME = "google.cloud.bigquery.connection.v1.ConnectionService"; 39 com.google.cloud.bigquery.connection.v1.CreateConnectionRequest, 40 com.google.cloud.bigquery.connection.v1.Connection> 45 requestType = com.google.cloud.bigquery.connection.v1.CreateConnectionRequest.class, 46 responseType = com.google.cloud.bigquery.connection.v1.Connection.class, 49 com.google.cloud.bigquery.connection.v1.CreateConnectionRequest, 50 com.google.cloud.bigquery.connection.v1.Connection> 53 com.google.cloud.bigquery.connection.v1.CreateConnectionRequest, in getCreateConnectionMethod() [all …]
|
/aosp_15_r20/external/python/bumble/bumble/pandora/ |
D | security.py | 30 from bumble.device import Connection as BumbleConnection, Device 37 from pandora.host_pb2 import Connection 66 connection: BumbleConnection, 74 {'service_name': 'Security', 'device': connection.device}, 76 self.connection = connection 88 if not self.connection.is_incomplete: 89 assert ev.connection 90 ev.connection.CopyFrom( 91 Connection( 92 cookie=any_pb2.Any(value=self.connection.handle.to_bytes(4, 'big')) [all …]
|
/aosp_15_r20/frameworks/base/core/java/android/database/sqlite/ |
H A D | SQLiteConnectionPool.java | 50 * At any given time, a connection is either owned by the pool, or it has been 52 * finished with the connection it is using, it must return the connection 58 * that the connection pool can detect when connections have been improperly 61 * The connection pool is thread-safe (but the connections themselves are not). 87 // and logging a message about the connection pool being busy. 125 // whole execution time for this connection in milliseconds. 128 // total statements executed by this connection 131 // Describes what should happen to an acquired connection when it is returned to the pool. 133 // The connection should be returned to the pool as usual. 136 // The connection must be reconfigured before being returned. [all …]
|