| /external/apache-http/src/org/apache/http/impl/conn/ |
| IdleConnectionHandler.java | 44 * A helper class for connection managers to track idle connections.
71 * Registers the given connection with this handler. The connection will be held until
74 * @param connection the connection to add
78 public void add(HttpConnection connection, long validDuration, TimeUnit unit) {
83 log.debug("Adding connection at: " + timeAdded);
86 connectionToTimes.put(connection, new TimeValues(timeAdded, validDuration, unit));
90 * Removes the given connection from the list of connections to be closed when idle.
91 * This will return true if the connection is still valid, and fals
[all...] |
| /external/autotest/frontend/db/backends/afe_sqlite/ |
| base.py | 15 self.ops = DatabaseOperations(self.connection)
|
| /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/libchrome/dbus/ |
| exported_object.h | 138 DBusHandlerResult HandleMessage(DBusConnection* connection,
160 void OnUnregistered(DBusConnection* connection);
163 static DBusHandlerResult HandleMessageThunk(DBusConnection* connection,
168 static void OnUnregisteredThunk(DBusConnection* connection,
|
| /external/libmicrohttpd/src/examples/ |
| fileserver_example_dirs.c | 80 struct MHD_Connection *connection,
125 ret = MHD_queue_response (connection, MHD_HTTP_SERVICE_UNAVAILABLE, response);
140 ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
155 ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
|
| demo.c | 412 * Handle to connection that we're processing the upload for.
414 struct MHD_Connection *connection; member in struct:UploadContext
596 * @param connection connection handle
604 struct MHD_Connection *connection,
637 * @param connection connection to return the directory for
641 return_directory_response (struct MHD_Connection *connection)
647 ret = MHD_queue_response (connection,
651 ret = MHD_queue_response (connection,
[all...] |
| demo_https.c | 413 * Handle to connection that we're processing the upload for.
415 struct MHD_Connection *connection; member in struct:UploadContext
597 * @param connection connection handle
605 struct MHD_Connection *connection,
638 * @param connection connection to return the directory for
642 return_directory_response (struct MHD_Connection *connection)
648 ret = MHD_queue_response (connection,
652 ret = MHD_queue_response (connection,
[all...] |
| /external/skia/tools/skiaserve/ |
| skiaserve.cpp | 56 int invoke(Request* request, MHD_Connection* connection, const char* url, const char* method,
60 return fHandlers[i]->handle(request, connection, url, method, upload_data,
73 int answer_to_connection(void* cls, struct MHD_Connection* connection,
80 int result = kUrlManager.invoke(request, connection, url, method, upload_data,
|
| /frameworks/base/core/java/android/view/accessibility/ |
| IAccessibilityManager.aidl | 48 in IAccessibilityInteractionConnection connection, int userId);
53 in IAccessibilityInteractionConnection connection);
|
| /frameworks/base/packages/MtpDocumentsProvider/tests/src/com/android/mtp/ |
| TestUtil.java | 95 final UsbDeviceConnection connection = usbManager.openDevice(device); local
99 connection.claimInterface(device.getInterface(i), true);
100 connection.releaseInterface(device.getInterface(i));
102 connection.close();
|
| /frameworks/native/services/surfaceflinger/ |
| EventThread.h | 59 class Connection : public BnDisplayEventConnection {
61 explicit Connection(const sp<EventThread>& eventThread);
70 virtual ~Connection();
83 sp<Connection> createEventConnection() const;
84 status_t registerDisplayEventConnection(const sp<Connection>& connection);
86 void setVsyncRate(uint32_t count, const sp<Connection>& connection);
87 void requestNextVsync(const sp<Connection>& connection);
[all...] |
| /frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/imsphone/ |
| ImsExternalCallTrackerTest.java | 22 import com.android.internal.telephony.Connection;
86 ArgumentCaptor<Connection> connectionArgumentCaptor = ArgumentCaptor.forClass(
87 Connection.class);
91 Connection connection = connectionArgumentCaptor.getValue(); local
92 assert(connection instanceof ImsExternalConnection);
100 ImsExternalConnection connection = (ImsExternalConnection) local
106 assertEquals(connection.getState(), Call.State.DISCONNECTED);
|
| /hardware/intel/common/libmix/mix_audio/src/ |
| amhelper.c | 4 static DBusGConnection *connection; variable
30 connection = dbus_g_bus_get(DBUS_BUS_SESSION, &error);
32 if (connection == NULL) {
33 mix_log(MIX_AUDIO_COMP, MIX_LOG_LEVEL_WARNING, "Failed to open connection to bus: %s\n",
38 mix_log(MIX_AUDIO_COMP, MIX_LOG_LEVEL_VERBOSE, "Successfully get a dbus connection\n");
40 proxy_lpe = dbus_g_proxy_new_for_name(connection, name,
|
| /libcore/benchmarks/src/benchmarks/regression/ |
| HostnameVerifierBenchmark.java | 32 * This benchmark makes a real HTTP connection to a handful of hosts and
55 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
56 connection.setHostnameVerifier(new HostnameVerifier() {
67 connection.getInputStream();
68 connection.disconnect();
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| URLStreamHandlerFactoryTest.java | 60 URLConnection connection = url.openConnection(); local
61 assertTrue(connection instanceof Handler.HandlerURLConnection);
93 URLConnection connection = new URL("http://android.com/").openConnection(); local
94 assertTrue(connection instanceof Handler.HandlerURLConnection);
105 // creating a connection should use the platform's default stream handler
110 // set the property and get another connection. The property should not be honored
|
| /external/chromium-trace/catapult/telemetry/third_party/web-page-replay/ |
| sslproxy_test.py | 40 self.connection = None
49 self.connection = certutils.get_ssl_connection(context, s)
50 self.connection.connect((self.host, self.port))
51 self.connection.set_tlsext_host_name(self.host_name)
54 self.connection.send('\r\n\r\n')
56 self.connection.shutdown()
57 self.connection.close()
80 self.connection.shutdown()
81 self.connection.close()
158 conn: Connection objec
[all...] |
| /frameworks/base/services/core/java/com/android/server/tv/ |
| TvInputHardwareManager.java | 79 * This class does a basic connection management and forwarding calls to TvInputHal which eventually
90 private final SparseArray<Connection> mConnections = new SparseArray<>();
157 Connection connection = new Connection(info); local
158 connection.updateConfigsLocked(configs);
159 mConnections.put(info.getDeviceId(), connection); local
179 Connection connection = mConnections.get(deviceId); local
180 if (connection == null)
207 Connection connection = mConnections.get(deviceId); local
235 Connection connection = mConnections.get(deviceId); local
303 Connection connection = mConnections.get(deviceId); local
374 Connection connection = mConnections.get(deviceId); local
400 Connection connection = mConnections.get(deviceId); local
425 Connection connection = mConnections.get(i); local
445 Connection connection = mConnections.get(deviceId); local
466 Connection connection = mConnections.get(deviceId); local
[all...] |
| /external/libmicrohttpd/src/testspdy/ |
| test_new_connection.c | 21 * @brief tests new connection callback. spdycli.c
107 struct Connection {
110 /* WANT_READ if SSL connection needs more input; or WANT_WRITE if it
115 SSL connection. */
228 struct Connection *connection; local
230 connection = (struct Connection*)user_data;
231 connection->want_io = IO_NONE;
233 rv = SSL_write(connection->ssl, data, length)
260 struct Connection *connection; local
660 struct Connection connection; local
[all...] |
| test_request_response.c | 89 struct Connection {
92 /* WANT_READ if SSL connection needs more input; or WANT_WRITE if it
97 SSL connection. */
210 struct Connection *connection; local
212 connection = (struct Connection*)user_data;
213 connection->want_io = IO_NONE;
215 rv = SSL_write(connection->ssl, data, length);
217 int err = SSL_get_error(connection->ssl, rv)
242 struct Connection *connection; local
648 struct Connection connection; local
[all...] |
| /external/autotest/client/common_lib/ |
| barrier.py | 114 and the master a client. The connection process and usage is still the
116 connection initiation. This is called rendezvous_servers.
198 def _master_welcome(self, connection):
199 client, addr = connection
254 self._waiting[name] = connection
258 def _slave_hello(self, connection):
259 (client, addr) = connection
270 # Confirm the master accepted the connection.
272 logging.warning("Bad connection request to master")
289 self._waiting[self._hostid] = connection
[all...] |
| /external/compiler-rt/lib/tsan/rtl/ |
| tsan_interceptors_mac.cc | 240 xpc_connection_t connection, xpc_handler_t handler) {
241 SCOPED_TSAN_INTERCEPTOR(xpc_connection_set_event_handler, connection,
243 Release(thr, pc, (uptr)connection);
247 Acquire(thr, pc, (uptr)connection);
251 REAL(xpc_connection_set_event_handler)(connection, new_handler);
254 TSAN_INTERCEPTOR(void, xpc_connection_send_barrier, xpc_connection_t connection,
256 SCOPED_TSAN_INTERCEPTOR(xpc_connection_send_barrier, connection, barrier);
257 Release(thr, pc, (uptr)connection);
261 Acquire(thr, pc, (uptr)connection);
265 REAL(xpc_connection_send_barrier)(connection, new_barrier)
[all...] |
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
| ShadowSQLiteDatabase.java | 14 import java.sql.Connection;
32 * Implemented as a wrapper around an embedded SQL database, accessed via JDBC. The JDBC connection is
38 private static Connection connection; field in class:ShadowSQLiteDatabase
67 connection = DatabaseConfig.getMemoryConnection();
94 PreparedStatement insert = connection.prepareStatement(sqlInsertString.sql, Statement.RETURN_GENERATED_KEYS);
128 Statement statement = connection.createStatement(DatabaseConfig.getResultSetType(), ResultSet.CONCUR_READ_ONLY);
158 PreparedStatement statement = connection.prepareStatement(sqlUpdateString.sql);
176 return connection.prepareStatement(sql).executeUpdate();
190 connection.createStatement().execute(scrubbedSql)
[all...] |
| /frameworks/base/core/java/android/app/ |
| UiAutomation.java | 178 * operations on the provided connection.
181 * @param connection The connection for performing privileged operations.
185 public UiAutomation(Looper looper, IUiAutomationConnection connection) {
189 if (connection == null) {
190 throw new IllegalArgumentException("Connection cannot be null!");
192 mUiAutomationConnection = connection;
348 final IAccessibilityServiceConnection connection; local
351 connection = AccessibilityInteractionClient.getInstance()
355 if (connection != null)
397 final IAccessibilityServiceConnection connection; local
423 final IAccessibilityServiceConnection connection; local
[all...] |
| /packages/services/Telephony/src/com/android/services/telephony/ |
| ImsConference.java | 26 import android.telecom.Connection.VideoProvider;
27 import android.telecom.Connection;
56 * An IMS conference call consists of a conference host connection and potentially a list of
57 * conference participants. The conference host connection represents the radio connection to the
58 * IMS conference server. Since it is not a connection to any one individual, it is not represented
60 * connection via a conference event package. Conference participant connections do not represent
65 * connection and is responsible for managing the conference participant connections which represent
74 private final Connection.Listener mParticipantListener = new Connection.Listener()
663 ConferenceParticipantConnection connection = local
675 ConferenceParticipantConnection connection = local
725 ConferenceParticipantConnection connection = new ConferenceParticipantConnection( local
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/ |
| JDWPDebuggeeWrapper.java | 37 * It encapsulates JDWP connection and communicates with debuggee using
80 * Returns opened JDWP connection or null.
82 * @return JDWP connection or null
89 * Sets opened JDWP connection.
91 * @param connection to set
93 public void setConnection(TransportWrapper connection) {
94 vmMirror.setConnection(connection);
|
