| /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...] |
| /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/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...] |
| /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/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...] |
| /packages/apps/Dialer/java/com/android/dialer/simulator/impl/ |
| SimulatorMissedCallCreator.java | 22 import android.telecom.Connection;
50 public void onNewOutgoingConnection(@NonNull SimulatorConnection connection) {}
53 public void onNewIncomingConnection(@NonNull SimulatorConnection connection) {
54 if (!isMissedCallConnection(connection)) {
59 connection.setDisconnected(new DisconnectCause(DisconnectCause.MISSED));
60 addNextIncomingCall(getCallCount(connection));
85 private static boolean isMissedCallConnection(@NonNull Connection connection) {
86 return connection.getExtras().getBoolean(EXTRA_IS_MISSED_CALL_CONNECTION);
89 private static int getCallCount(@NonNull Connection connection)
[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...] |
| /external/skia/tools/skiaserve/urlhandlers/ |
| 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/skqp/tools/skiaserve/urlhandlers/ |
| 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);
|
| /packages/apps/Dialer/java/com/android/dialer/simulator/ |
| SimulatorConnectionsBank.java | 21 import android.telecom.Connection;
31 /** Add a connection into bank. */
32 void add(Connection connection);
34 /** Remove a connection from bank. */
35 void remove(Connection connection);
45 * connection). Before calling this method, make sure all connections are returned by
50 /** Determine whether a connection is created by simulator. */
51 boolean isSimulatorConnection(@NonNull Connection connection)
[all...] |
| /packages/services/Telephony/src/com/android/services/telephony/ |
| 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...] |
| /external/cmockery/cmockery_0_1_2/src/example/ |
| customer_database_test.c | 24 DatabaseConnection * const connection, const char * const customer_name);
28 DatabaseConnection* const connection, const char * const query_string,
53 DatabaseConnection connection = { local
60 assert_int_equal(get_customer_id_by_name(&connection, "john doe"), 543);
|
| database.h | 24 DatabaseConnection* const connection, const char * const query_string,
27 // Connection to a database.
|
| /external/libmicrohttpd/src/examples/ |
| mhd2spdy_spdy.h | 38 struct SPDY_Connection *connection);
45 struct SPDY_Connection *connection);
49 spdy_exec_io(struct SPDY_Connection *connection);
69 spdy_free_connection(struct SPDY_Connection * connection);
|
| /external/libmicrohttpd/src/microhttpd/ |
| test_postprocessor_amp.c | 26 struct MHD_Connection connection; local
30 memset (&connection, 0, sizeof (struct MHD_Connection));
32 connection.headers_received = &header;
37 pp = MHD_create_post_processor (&connection,
|
| /external/pdfium/fxjs/xfa/ |
| cjx_binditems.h | 19 JS_PROP(connection);
|
| cjx_setproperty.h | 19 JS_PROP(connection);
|
| cjx_wsdlconnection.h | 17 explicit CJX_WsdlConnection(CXFA_WsdlConnection* connection);
|
| /external/python/cpython2/Modules/_sqlite/ |
| util.h | 29 #include "connection.h"
31 int pysqlite_step(sqlite3_stmt* statement, pysqlite_Connection* connection);
|
