| /external/autotest/site_utils/lxc/container_pool/ |
| unittest_client.py | 8 from multiprocessing import connection
15 @param timeout: Connection timeout, in seconds. Default is 30.
17 @raises socket.timeout: If a connection is not made before the timeout
27 care of polling for a connection. If a connection is not established within
42 """Instantiates a connection.Client."""
43 self._client = connection.Client(self._address)
47 """Attempts to create a connection.Client with a timeout.
52 @param timeout: A connection timeout, in seconds.
54 @return: A connection.Client connected using the address that wa
[all...] |
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| RttOperationsTest.java | 21 import android.telecom.Connection;
63 final MockConnection connection = verifyConnectionForOutgoingCall(); local
67 verifyRttEnabled(call, connection);
77 final MockConnection connection = verifyConnectionForIncomingCall(); local
81 verifyRttEnabled(call, connection);
90 final MockConnection connection = verifyConnectionForOutgoingCall(); local
96 connection.getInvokeCounter(MockConnection.ON_START_RTT);
100 connection.setRttTextStream((Connection.RttTextStream) startRttCounter.getArgs(0)[0]);
101 connection.setConnectionProperties
114 final MockConnection connection = verifyConnectionForOutgoingCall(); local
138 final MockConnection connection = verifyConnectionForOutgoingCall(); local
161 final MockConnection connection = verifyConnectionForOutgoingCall(); local
185 final MockConnection connection = verifyConnectionForOutgoingCall(); local
206 final MockConnection connection = verifyConnectionForOutgoingCall(); local
[all...] |
| ExtendedInCallServiceTest.java | 29 import android.telecom.Connection;
72 final MockConnection connection = verifyConnectionForOutgoingCall(); local
80 assertMuteState(connection, false);
85 assertMuteState(connection, true);
89 assertMuteState(connection, false);
99 final MockConnection connection = verifyConnectionForOutgoingCall(); local
130 assertAudioRoute(connection, CallAudioState.ROUTE_SPEAKER);
136 assertAudioRoute(connection, secondRoute);
159 final MockConnection connection = verifyConnectionForOutgoingCall(); local
166 assertDtmfString(connection, "");
192 final MockConnection connection = verifyConnectionForOutgoingCall(); local
219 final MockConnection connection = verifyConnectionForIncomingCall(); local
240 MockConnection connection = verifyConnectionForIncomingCall(0); local
262 MockConnection connection = verifyConnectionForIncomingCall(0); local
284 MockConnection connection = verifyConnectionForIncomingCall(0); local
391 final MockConnection connection = verifyConnectionForIncomingCall(); local
415 final MockConnection connection = verifyConnectionForIncomingCall(); local
438 final MockConnection connection = verifyConnectionForIncomingCall(); local
460 final MockConnection connection = verifyConnectionForIncomingCall(); local
499 final MockConnection connection = verifyConnectionForOutgoingCall(); local
587 final MockConnection connection = verifyConnectionForIncomingCall(); local
602 final MockConnection connection = verifyConnectionForOutgoingCall(); local
[all...] |
| /frameworks/base/core/java/android/database/sqlite/ |
| SQLiteConnectionPool.java | 47 * At any given time, a connection is either owned by the pool, or it has been
49 * finished with the connection it is using, it must return the connection
55 * that the connection pool can detect when connections have been improperly
58 * The connection pool is thread-safe (but the connections themselves are not).
84 // and logging a message about the connection pool being busy.
109 // Describes what should happen to an acquired connection when it is returned to the pool.
111 // The connection should be returned to the pool as usual.
114 // The connection must be reconfigured before being returned.
117 // The connection must be closed and discarded
598 SQLiteConnection connection = local
639 final SQLiteConnection connection = mAvailableNonPrimaryConnections.get(i); local
691 SQLiteConnection connection = null; local
763 final SQLiteConnection connection = waiter.mAssignedConnection; local
880 SQLiteConnection connection = null; local
931 SQLiteConnection connection = mAvailablePrimaryConnection; local
958 SQLiteConnection connection; local
1155 final SQLiteConnection connection = entry.getKey(); local
[all...] |
| /frameworks/native/services/sensorservice/ |
| SensorRecord.cpp | 24 const sp<const SensorEventConnection>& connection)
26 mConnections.add(connection);
30 const sp<const SensorEventConnection>& connection)
32 if (mConnections.indexOf(connection) < 0) {
33 mConnections.add(connection);
40 const wp<const SensorEventConnection>& connection)
42 ssize_t index = mConnections.indexOf(connection);
49 if (*it == connection) {
59 const sp<const SensorEventConnection>& connection) {
60 mPendingFlushConnections.add(connection);
[all...] |
| /packages/services/Telecomm/testapps/src/com/android/server/telecom/testapps/ |
| SelfManagedCallListAdapter.java | 20 import android.telecom.Connection;
39 * Listener used to handle tap of the "disconnect" button for a connection.
45 SelfManagedConnection connection = (SelfManagedConnection) parent.getTag();
46 connection.setConnectionDisconnected(DisconnectCause.LOCAL);
47 SelfManagedCallList.getInstance().removeConnection(connection);
52 * Listener used to handle tap of the "active" button for a connection.
58 SelfManagedConnection connection = (SelfManagedConnection) parent.getTag();
59 connection.setConnectionActive();
65 * Listener used to handle tap of the "missed" button for a connection.
71 SelfManagedConnection connection = (SelfManagedConnection) parent.getTag()
154 SelfManagedConnection connection = mConnections.get(position); local
[all...] |
| TestConnectionService.java | 30 import android.telecom.Connection;
71 private final Connection.Listener mConnectionListener = new Connection.Listener() {
73 public void onDestroyed(Connection c) {
82 public TestConference(Connection a, Connection b) {
85 Connection.CAPABILITY_SUPPORT_HOLD |
86 Connection.CAPABILITY_HOLD |
87 Connection.CAPABILITY_MUTE |
88 Connection.CAPABILITY_MANAGE_CONFERENCE)
[all...] |
| /external/autotest/scheduler/ |
| scheduler_lib_unittest.py | 21 """Connection manager unittests."""
36 """Test connection and disconnecting from the database."""
37 # Test that the connection manager only opens a connection once.
40 connection = connection_manager.get_connection()
43 connection = connection_manager.get_connection()
48 # Test that del on the connection manager closes the connection
55 """Test that retries don't destroy the connection."""
60 connection = connection_manager.get_connection(
[all...] |
| /external/replicaisland/src/com/replica/replicaisland/ |
| EventReporter.java | 82 HttpURLConnection connection = null; local
95 connection = null;
97 //Set up the initial connection
98 connection = (HttpURLConnection)serverAddress.openConnection();
100 connection.setRequestMethod("GET");
101 connection.setDoOutput(true);
102 connection.setReadTimeout(0);
104 connection.connect();
105 final int response = connection.getResponseCode();
106 DebugLog.d("Report Event", event.eventType + " " + response + ":" + connection.getURL().toString())
[all...] |
| /packages/services/Telephony/src/com/android/services/telephony/ |
| CdmaConference.java | 22 import android.telecom.Connection;
44 mProperties = Connection.PROPERTY_GENERIC_CONFERENCE;
51 capabilities |= Connection.CAPABILITY_MUTE;
56 * Invoked when the Conference and all it's {@link Connection}s should be disconnected.
72 public void onSeparate(Connection connection) {
93 mCapabilities &= ~Connection.CAPABILITY_MERGE_CONFERENCE;
96 mCapabilities |= Connection.CAPABILITY_SWAP_CONFERENCE;
104 final CdmaConnection connection = getFirstConnection(); local
105 if (connection != null)
114 final CdmaConnection connection = getFirstConnection(); local
[all...] |
| PstnIncomingCallNotifier.java | 32 import com.android.internal.telephony.Connection;
51 /** New ringing connection event code. */
126 Connection connection = (Connection) asyncResult.result; local
127 if (connection != null) {
128 Call call = connection.getCall();
132 sendIncomingCallIntent(connection);
142 Connection connection = call.getLatestConnection() local
174 Connection connection = (Connection) asyncResult.result; local
[all...] |
| /frameworks/base/services/core/java/com/android/server/tv/ |
| TvRemoteProviderProxy.java | 37 * Maintains a connection to a tv remote provider service.
64 // Connection state
67 private Connection mActiveConnection;
186 Connection connection = new Connection(provider); local
187 if (connection.register()) {
189 mActiveConnection = connection;
212 private void onConnectionReady(Connection connection) {
576 Connection connection = mConnectionRef.get(); local
584 Connection connection = mConnectionRef.get(); local
592 Connection connection = mConnectionRef.get(); local
600 Connection connection = mConnectionRef.get(); local
608 Connection connection = mConnectionRef.get(); local
616 Connection connection = mConnectionRef.get(); local
625 Connection connection = mConnectionRef.get(); local
633 Connection connection = mConnectionRef.get(); local
641 Connection connection = mConnectionRef.get(); local
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| ConnectionPool.java | 38 * {@link Connection}. This class implements the policy of which connections to
49 * connection alive in the pool before closing it. Default is 5 minutes.
81 * thread running per connection pool. We use a thread pool executor because it can shrink to
134 for (RealConnection connection : connections) {
135 if (connection.allocations.isEmpty()) total++;
159 for (RealConnection connection : connections) {
160 if (connection.isMultiplexed()) total++;
170 /** Returns a recycled connection to {@code address}, or null if no such connection exists. */
173 for (RealConnection connection : connections)
214 RealConnection connection = i.next(); local
244 RealConnection connection = i.next(); local
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/hfpclient/connserv/ |
| HfpClientDeviceBlock.java | 24 import android.telecom.Connection;
90 synchronized Connection onCreateIncomingConnection(BluetoothHeadsetClientCall call) {
91 HfpClientConnection connection = mConnections.get(call.getUUID()); local
92 if (connection != null) {
93 connection.onAdded();
94 return connection;
96 Log.e(mTAG, "Call " + call + " ignored: connection does not exist");
101 Connection onCreateOutgoingConnection(Uri address) {
102 HfpClientConnection connection = buildConnection(null, address); local
103 if (connection != null)
111 HfpClientConnection connection = mConnections.get(call.getUUID()); local
151 HfpClientConnection connection = findConnectionKey(call); local
251 HfpClientConnection connection = null; local
259 mConnections.put(connection.getUUID(), connection); local
[all...] |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/telecom/ |
| CtsConnectionService.java | 21 import android.telecom.Connection;
41 void onDestroyed(CtsConnection connection) {
43 mConnections.remove(connection);
106 public Connection onCreateOutgoingConnection(PhoneAccountHandle connectionManagerAccount,
113 public Connection onCreateIncomingConnection(PhoneAccountHandle connectionManagerPhoneAccount,
129 private Connection createManagedConnection(ConnectionRequest request, boolean isIncoming) {
135 CtsConnection connection = new CtsConnection(getApplicationContext(), isIncoming, local
138 connection.setConnectionProperties(Connection.PROPERTY_SELF_MANAGED);
140 connection.setConnectionCapabilities(Connection.CAPABILITY_SUPPORT_HOLD
[all...] |
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
| HttpsURLConnectionTest.java | 50 HttpsURLConnection connection = local
53 assertSame(originalHostnameVerifier, connection.getHostnameVerifier());
55 connection.disconnect();
61 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection();
63 assertSame(anotherVerifier, connection.getHostnameVerifier());
65 connection.disconnect();
69 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection();
71 assertSame(originalHostnameVerifier, connection.getHostnameVerifier());
73 connection.disconnect();
88 HttpsURLConnection connection local
[all...] |
| /external/autotest/frontend/afe/ |
| readonly_connection.py | 19 If disabled, connection() will return the global connection instead of the
20 readonly connection.
27 def connection(): function
28 """Return a readonly database connection."""
35 """Return a cursor on the readonly database connection."""
36 return connection().cursor()
|
| /external/libmicrohttpd/src/examples/ |
| mhd2spdy_spdy.c | 21 * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
146 struct SPDY_Connection *connection; local
148 connection = (struct SPDY_Connection*)user_data;
149 connection->want_io = IO_NONE;
164 if(connection->is_tls)
167 rv = SSL_write(connection->ssl, data, length);
169 int err = SSL_get_error(connection->ssl, rv);
171 connection->want_io |= (err == SSL_ERROR_WANT_READ ?
181 rv = write(connection->fd,
193 connection->want_io |= WANT_WRITE
228 struct SPDY_Connection *connection; local
730 struct SPDY_Connection * connection = NULL; local
848 struct SPDY_Connection *connection; local
990 struct SPDY_Connection *connection; local
[all...] |
| /external/python/cpython3/Lib/multiprocessing/dummy/ |
| connection.py | 2 # Analogue of `multiprocessing.connection` which uses queues instead of sockets
4 # multiprocessing/dummy/connection.py
24 return Connection(*self._backlog_queue.get())
41 return Connection(_in, _out)
46 return Connection(a, b), Connection(b, a)
49 class Connection(object):
|
| /packages/apps/Dialer/java/com/android/dialer/simulator/impl/ |
| SimulatorConnectionService.java | 22 import android.telecom.Connection;
39 /** Simple connection provider to create phone calls. This is useful for emulators. */
73 public Connection onCreateOutgoingConnection(
86 SimulatorConnection connection = new SimulatorConnection(this, request); local
88 simulatorConnectionsBank.add(connection);
89 connection.setAddress(
94 connection.setDialing();
101 listener.onNewOutgoingConnection(connection);
104 connection.setAddress(request.getAddress(), 1);
105 Bundle extras = connection.getExtras()
129 SimulatorConnection connection = new SimulatorConnection(this, request); local
[all...] |
| /system/tpm/tpm_manager/server/ |
| tpm_initializer_impl.cc | 57 TpmConnection connection(GetDefaultOwnerPassword());
58 if (!InitializeEndorsementKey(&connection) || !TakeOwnership(&connection) ||
59 !InitializeSrk(&connection)) {
76 if (!ChangeOwnerPassword(&connection, owner_password)) {
91 bool TpmInitializerImpl::InitializeEndorsementKey(TpmConnection* connection) {
92 trousers::ScopedTssKey local_key_handle(connection->GetContext());
94 connection->GetTpm(), false, nullptr, local_key_handle.ptr());
103 connection->GetContext(), TSS_OBJECT_TYPE_RSAKEY,
109 connection->GetTpm(), local_key_handle, NULL)))
[all...] |
| /frameworks/base/telecomm/java/android/telecom/ |
| Conference.java | 24 import android.telecom.Connection.VideoProvider;
37 * Represents a conference call which can contain any number of {@link Connection} objects.
42 * Used to indicate that the conference connection time is not specified. If not specified,
51 public void onConnectionAdded(Conference conference, Connection connection) {}
52 public void onConnectionRemoved(Conference conference, Connection connection) {}
54 Conference conference, List<Connection> conferenceableConnections) {}
61 public void onVideoProviderChanged(Conference c, Connection.VideoProvider videoProvider) {}
68 private final List<Connection> mChildConnections = new CopyOnWriteArrayList<>()
[all...] |
| /libcore/ojluni/src/main/java/javax/sql/ |
| PooledConnection.java | 28 import java.sql.Connection;
32 * An object that provides hooks for connection pool management.
34 * represents a physical connection to a data source. The connection
44 * it gets back a <code>Connection</code> object. If connection pooling is
45 * being done, that <code>Connection</code> object is actually a handle to
46 * a <code>PooledConnection</code> object, which is a physical connection.
48 * The connection pool manager, typically the application server, maintains
51 * connection pool manager returns a <code>Connection</code> object tha
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/gatt/ |
| ContextMap.java | 45 * Connection class helps map connection IDs to device addresses.
47 class Connection {
53 Connection(int connId, String address, int appId) {
158 Set<Connection> mConnections = new HashSet<Connection>();
233 * Add a new connection for a given application ID.
239 mConnections.add(new Connection(connId, address, id));
245 * Remove a connection with the given ID.
249 Iterator<Connection> i = mConnections.iterator()
251 Connection connection = i.next(); local
266 Connection connection = i.next(); local
366 Connection connection = i.next(); local
378 Connection connection = ii.next(); local
397 Connection connection = i.next(); local
411 Connection connection = i.next(); local
423 Connection connection = i.next(); local
[all...] |
| /packages/apps/TV/src/com/android/tv/util/ |
| NetworkUtils.java | 32 /** Checks if the internet connection is available. */
41 HttpURLConnection connection = null; local
43 connection = (HttpURLConnection) new URL(GENERATE_204).openConnection();
44 connection.setInstanceFollowRedirects(false);
45 connection.setDefaultUseCaches(false);
46 connection.setUseCaches(false);
47 if (connection.getResponseCode() == HttpURLConnection.HTTP_NO_CONTENT) {
53 if (connection != null) {
54 connection.disconnect();
|
