| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| WiredHeadsetTest.java | 21 import android.telecom.Connection;
44 final MockConnection connection = verifyConnectionForIncomingCall(); local
48 assertConnectionState(connection, Connection.STATE_RINGING);
52 assertConnectionState(connection, Connection.STATE_ACTIVE);
61 final MockConnection connection = verifyConnectionForIncomingCall(); local
65 assertConnectionState(connection, Connection.STATE_RINGING);
69 assertConnectionState(connection, Connection.STATE_DISCONNECTED)
78 final MockConnection connection = verifyConnectionForOutgoingCall(); local
100 final MockConnection connection = verifyConnectionForOutgoingCall(); local
[all...] |
| SelfManagedConnectionServiceTest.java | 158 * but is also registered as a connection manager is not permitted.
160 * A self-managed {@link android.telecom.PhoneAccount} cannot also be a connection manager.
187 "connection managers, or SIM accounts.", se.getMessage());
194 * Tests ability to add a new self-managed incoming connection.
209 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
212 connection.getOnShowIncomingUiInvokeCounter().waitForCount(1);
213 setActiveAndVerify(connection);
218 setDisconnectedAndVerify(connection);
222 * Tests ability to add a new self-managed outgoing connection.
236 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1) local
259 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
296 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
322 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
351 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(address); local
[all...] |
| /external/chromium-trace/catapult/telemetry/third_party/web-page-replay/ |
| sslproxy.py | 25 """Sets up connection providing the certificate to the client.
35 def handle_servername(connection):
38 host = connection.get_servername()
46 connection.set_context(new_context)
54 handler.connection = certutils.get_ssl_connection(context, handler.connection)
55 handler.connection.set_accept_state()
57 handler.connection.do_handshake()
59 host = handler.connection.get_servername()
65 # Re-wrap the read/write streams with our new connection
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Modules/_sqlite/ |
| util.h | 29 #include "connection.h"
31 int pysqlite_step(sqlite3_stmt* statement, pysqlite_Connection* connection);
|
| /packages/services/Telephony/src/com/android/services/telephony/ |
| TelephonyConnectionServiceProxy.java | 20 import android.telecom.Connection;
30 Collection<Connection> getAllConnections();
33 void removeConnection(Connection connection);
35 Connection connection);
37 Connection connection, Conference conference);
38 void addConnectionToConferenceController(TelephonyConnection connection);
|
| /packages/apps/Messaging/src/com/android/messaging/datamodel/media/ |
| NetworkUriImageRequest.java | 49 // that connection open. There is no good way to perform this method.
57 HttpURLConnection connection = null; local
60 connection = (HttpURLConnection) url.openConnection();
61 connection.connect();
62 if (connection.getResponseCode() == HttpURLConnection.HTTP_OK) {
63 return ContentType.IMAGE_GIF.equalsIgnoreCase(connection.getContentType());
74 if (connection != null) {
75 connection.disconnect();
88 HttpURLConnection connection = null; local
91 connection = (HttpURLConnection) url.openConnection()
[all...] |
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
| CacheAdapterTest.java | 65 private HttpURLConnection connection; field in class:CacheAdapterTest
73 if (connection != null) {
74 connection.disconnect();
95 connection = new OkUrlFactory(client).open(serverUrl);
96 connection.setRequestProperty("key1", "value1");
98 executeGet(connection);
120 connection = new OkUrlFactory(client).open(serverUrl);
121 connection.setRequestProperty("key1", "value1");
123 executeGet(connection);
136 @Override public CacheRequest put(URI uri, URLConnection connection) throws IOException
[all...] |
| /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...] |
| mhd2spdy_http.h | 32 struct MHD_Connection *connection,
50 struct MHD_Connection *connection,
|
| /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/microhttpd/ |
| basicauth.c | 39 * @param connection The MHD connection structure
46 MHD_basic_auth_get_username_password (struct MHD_Connection *connection,
54 if ( (NULL == (header = MHD_lookup_connection_value (connection,
63 MHD_DLOG (connection->daemon,
72 MHD_DLOG(connection->daemon,
90 MHD_DLOG(connection->daemon,
109 * @param connection The MHD connection structure
116 MHD_queue_basic_auth_fail_response (struct MHD_Connection *connection,
[all...] |
| /external/skia/tools/skiaserve/ |
| Response.cpp | 44 int SendOK(MHD_Connection* connection) {
50 int ret = MHD_queue_response(connection, 200, response);
55 int SendError(MHD_Connection* connection, const char* msg) {
59 int ret = MHD_queue_response(connection, 500, response);
64 int SendData(MHD_Connection* connection, const SkData* data, const char* type,
75 int ret = MHD_queue_response(connection, MHD_HTTP_OK, response);
80 int SendTemplate(MHD_Connection* connection, bool redirect, const char* redirectUrl) {
96 int ret = MHD_queue_response(connection, status, response);
|
| /external/skia/tools/skiaserve/urlhandlers/ |
| RootHandler.cpp | 21 int RootHandler::handle(Request* request, MHD_Connection* connection,
24 return SendTemplate(connection);
|
| ColorModeHandler.cpp | 22 int ColorModeHandler::handle(Request* request, MHD_Connection* connection,
39 return SendError(connection, "Unable to create requested surface");
41 return SendOK(connection);
|
| EnableGPUHandler.cpp | 22 int EnableGPUHandler::handle(Request* request, MHD_Connection* connection,
37 return SendError(connection, "Unable to create GPU surface");
39 return SendOK(connection);
|
| OverdrawHandler.cpp | 22 int OverdrawHandler::handle(Request* request, MHD_Connection* connection,
37 return SendError(connection, "Unable to set overdraw");
39 return SendOK(connection);
|
| /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...] |
| /cts/apps/CtsVerifierUSBCompanion/src/com/android/cts/verifierusbcompanion/ |
| AccessoryTestCompanion.java | 120 UsbDeviceConnection connection = mUsbManager.openDevice(mDevice); local
125 testName = nextTest(connection, in, out, true);
133 int numTransferred = connection.bulkTransfer(in, buffer, 32, 0);
136 numTransferred = connection.bulkTransfer(out, buffer, 32, 0);
145 int numTransferred = connection.bulkTransfer(in, buffer, 32, 0);
147 numTransferred = connection.bulkTransfer(in, buffer, 16, 32, 0);
150 numTransferred = connection.bulkTransfer(out, buffer, 32, 0);
158 int numTransferred = connection.bulkTransfer(in, buffer, 32, 0);
161 numTransferred = connection.bulkTransfer(out, buffer, 16, 0);
163 numTransferred = connection.bulkTransfer(out, buffer, 16, 16, 0)
270 UsbDeviceConnection connection = mUsbManager.openDevice(device); local
[all...] |
| /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/network/ |
| HttpUrlConnectionBuilder.java | 203 final HttpURLConnection connection = (HttpURLConnection) mUrl.openConnection(); local
204 connection.setConnectTimeout(mConnectTimeoutMillis);
205 connection.setReadTimeout(mReadTimeoutMillis);
206 connection.setUseCaches(mUseCache);
209 connection.setDoInput(true);
210 connection.setDoOutput(false);
213 connection.setDoInput(false);
214 connection.setDoOutput(true);
217 connection.setDoInput(true);
218 connection.setDoOutput(true)
[all...] |
| /frameworks/base/core/java/android/database/sqlite/ |
| SQLiteConnectionPool.java | 39 * At any given time, a connection is either owned by the pool, or it has been
41 * finished with the connection it is using, it must return the connection
47 * that the connection pool can detect when connections have been improperly
50 * The connection pool is thread-safe (but the connections themselves are not).
76 // and logging a message about the connection pool being busy.
96 // Describes what should happen to an acquired connection when it is returned to the pool.
98 // The connection should be returned to the pool as usual.
101 // The connection must be reconfigured before being returned.
104 // The connection must be closed and discarded
519 SQLiteConnection connection = local
555 final SQLiteConnection connection = mAvailableNonPrimaryConnections.get(i); local
607 SQLiteConnection connection = null; local
679 final SQLiteConnection connection = waiter.mAssignedConnection; local
794 SQLiteConnection connection = null; local
844 SQLiteConnection connection = mAvailablePrimaryConnection; local
870 SQLiteConnection connection; local
1029 final SQLiteConnection connection = entry.getKey(); local
[all...] |
| /external/autotest/frontend/db/backends/afe/ |
| base.py | 19 self.connection = None
25 self.ops = DatabaseOperations(connection=kwargs.get('connection'))
29 if self.connection is not None:
30 if self.connection.open:
32 self.connection.ping()
35 self.connection.close()
36 self.connection = None
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| StreamAllocation.java | 43 * potentially slow to establish so it is necessary to be able to cancel a connection
46 * connections. Each connection has its own allocation limit, which defines how many
47 * concurrent streams that connection can carry. HTTP/1.x connections can carry 1 stream
51 * connection for better behavior and locality.
58 * <li>{@link #noNewStreams()} prevents the connection from being used for new streams in the
59 * future. Use this after a {@code Connection: close} header, or when the connection may be
65 * <li>{@link #release()} removes the call's hold on the connection. Note that this won't
66 * immediately free the connection if there is a stream still lingering. That happens when a
72 * stream but not the other streams sharing its connection. But if the TLS handshake is still i
81 private RealConnection connection; field in class:StreamAllocation
210 public synchronized RealConnection connection() { method in class:StreamAllocation
[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...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| DisconnectTest.java | 81 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); local
82 disconnectLater(connection, 500);
84 connection.setDoOutput(true);
85 connection.setFixedLengthStreamingMode(requestBodySize);
86 OutputStream requestBody = connection.getOutputStream();
93 fail("Expected connection to be closed");
97 connection.disconnect();
108 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); local
109 disconnectLater(connection, 500);
111 InputStream responseBody = connection.getInputStream()
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/hfpclient/connserv/ |
| HfpClientConference.java | 23 import android.telecom.Connection;
43 setConnectionCapabilities(Connection.CAPABILITY_SUPPORT_HOLD |
44 Connection.CAPABILITY_HOLD |
45 (manage ? Connection.CAPABILITY_MANAGE_CONFERENCE : 0));
56 public void onMerge(Connection connection) {
57 Log.d(TAG, "onMerge " + connection);
58 addConnection(connection);
62 public void onSeparate(Connection connection) {
[all...] |
