| /external/apache-harmony/sql/src/test/java/org/apache/harmony/sql/tests/java/sql/ |
| TestHelper_Driver1.java | 20 import java.sql.Connection;
76 public Connection connect(String url, Properties info) throws SQLException {
88 // It all checks out - so return a connection
89 Connection connection = new TestHelper_Connection1(); local
90 return connection;
|
| /external/apache-http/src/org/apache/http/impl/conn/ |
| SingleClientConnManager.java | 52 * A connection "manager" for a single connection.
54 * Allocation <i>always</i> returns the connection immediately,
57 * and the previously issued connection is revoked.
83 "Invalid use of SingleClientConnManager: connection still allocated.\n" +
84 "Make sure to release the connection before allocating another one.";
87 /** The schemes supported by this connection manager. */
96 /** The currently issued managed connection, if any. */
99 /** The time of the last connection release, or -1. */
102 /** The time the last released connection expires and shouldn't be reused. *
[all...] |
| /external/jacoco/org.jacoco.examples/src/org/jacoco/examples/ |
| MBeanClient.java | 41 // Open connection to the coverage agent:
44 MBeanServerConnection connection = jmxc.getMBeanServerConnection(); local
47 connection, new ObjectName("org.jacoco:type=Runtime"),
60 // Close connection:
|
| /external/libmicrohttpd/src/testcurl/ |
| test_termination.c | 53 struct MHD_Connection *connection,
77 int ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| ConnectionPoolTest.java | 148 // Add a third connection
151 // The third connection bounces the first.
174 private void allocateAndLeakAllocation(ConnectionPool pool, RealConnection connection) {
175 StreamAllocation leak = new StreamAllocation(pool, connection.getRoute().getAddress());
176 leak.acquire(connection);
191 RealConnection connection = new RealConnection(route); local
192 connection.idleAtNanos = idleAtNanos;
193 connection.socket = new Socket();
195 pool.put(connection);
197 return connection;
[all...] |
| /external/vulkan-validation-layers/include/vulkan/ |
| vk_icd.h | 59 * contains the platform-specific connection and surface information.
77 MirConnection *connection; member in struct:__anon36634
101 xcb_connection_t *connection; member in struct:__anon36637
|
| /frameworks/base/core/java/android/accessibilityservice/ |
| IAccessibilityServiceClient.aidl | 32 void init(in IAccessibilityServiceConnection connection, int connectionId, IBinder windowToken);
|
| /frameworks/base/tests/AccessoryDisplay/sink/src/com/android/accessorydisplay/sink/ |
| UsbAccessoryBulkTransport.java | 39 public UsbAccessoryBulkTransport(Logger logger, UsbDeviceConnection connection,
42 mConnection = connection;
57 throw new IOException("Connection was closed.");
65 throw new IOException("Connection was closed.");
|
| /frameworks/base/wifi/java/android/net/wifi/ |
| WifiNetworkConnectionStatistics.java | 25 * Connection Statistics For a WiFi Network.
35 public WifiNetworkConnectionStatistics(int connection, int usage) {
36 numConnection = connection;
|
| /frameworks/multidex/instrumentation/ |
| build.gradle | 67 connection "scm:git:https://android.googlesource.com/platform/frameworks/multidex"
|
| /frameworks/multidex/library/ |
| build.gradle | 66 connection "scm:git:https://android.googlesource.com/platform/frameworks/multidex"
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldCookieHandlerTest.java | 69 URLConnection connection = server.getUrl("/path/foo").openConnection(); local
70 connection.getContent();
|
| FtpURLConnectionTest.java | 93 URLConnection connection = fileUrl.openConnection(); local
94 assertContents(fileContents, connection.getInputStream());
103 URLConnection connection = fileUrl.openConnection(); local
104 connection.setDoInput(false);
105 connection.setDoOutput(true);
106 OutputStream os = connection.getOutputStream();
116 URLConnection connection = fileUrl.openConnection(proxy); local
117 assertContents(fileContents, connection.getInputStream());
124 * counts connection attempts to the address represented by {@code asProxy()}.
134 socket.connect(address, /* timeout (msec) */ 200); // attempt one connection
155 URLConnection connection = fileUrl.openConnection(proxy); local
179 URLConnection connection = fileUrl.openConnection(); local
200 URLConnection connection = url.openConnection(); local
[all...] |
| /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/network/ |
| BlockingHttpClient.java | 54 public BlockingHttpClient(HttpURLConnection connection) {
55 mConnection = connection;
|
| /prebuilts/go/darwin-x86/src/net/http/httptrace/ |
| trace.go | 80 // GetConn is called before a connection is created or
83 // if there's already an idle cached connection available.
86 // GotConn is called after a successful connection is
88 // connection; instead, use the error from
92 // PutIdleConn is called when the connection is returned to
93 // the idle pool. If err is nil, the connection was
96 // connection reuse is disabled via Transport.DisableKeepAlives.
116 // ConnectStart is called when a new connection's Dial begins.
121 // ConnectDone is called when a new connection's Dial
123 // connection completedly successfully
[all...] |
| /prebuilts/go/linux-x86/src/net/http/httptrace/ |
| trace.go | 80 // GetConn is called before a connection is created or
83 // if there's already an idle cached connection available.
86 // GotConn is called after a successful connection is
88 // connection; instead, use the error from
92 // PutIdleConn is called when the connection is returned to
93 // the idle pool. If err is nil, the connection was
96 // connection reuse is disabled via Transport.DisableKeepAlives.
116 // ConnectStart is called when a new connection's Dial begins.
121 // ConnectDone is called when a new connection's Dial
123 // connection completedly successfully
[all...] |
| /prebuilts/ndk/r13/sources/third_party/vulkan/src/include/vulkan/ |
| vk_icd.h | 59 * contains the platform-specific connection and surface information.
77 MirConnection *connection; member in struct:__anon104996
101 xcb_connection_t *connection; member in struct:__anon104999
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| CookiesTest.java | 279 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); local
281 connection.getRequestProperties());
283 connection.setRequestProperty("Foo", "foo");
284 connection.setDoOutput(true);
285 connection.getOutputStream().write(5);
286 connection.getOutputStream().close();
287 connection.getInputStream().close();
293 "Content-type", "User-Agent", "Connection", "Host");
302 assertContainsAll(connection.getRequestProperties().keySet(), "Foo");
303 assertContainsAll(connection.getRequestProperties().keySet()
354 URLConnection connection = new OkUrlFactory(client).open(server.getUrl(path)); local
[all...] |
| /external/libmicrohttpd/src/examples/ |
| mhd2spdy.c | 79 struct SPDY_Connection *connection; local
202 connection = glob_opt.spdy_connections_head;
203 while(NULL != connection)
205 connection_for_delete = connection;
206 connection = connection_for_delete->next;
244 " connection to the requested server. If the\n"
|
| /external/syslinux/com32/gpllib/dmi/ |
| dmi_memory.c | 209 void dmi_memory_module_connections(uint8_t code, char *connection, int sizeof_connection)
212 sprintf(connection, "%s", "None");
215 sprintf(connection, "%u ", code >> 4);
217 snprintf(connection, sizeof_connection, "%s%u", connection, code & 0x0F);
247 snprintf(size, sizeof_size, "%s %s", size, "(Double-bank Connection)");
249 snprintf(size, sizeof_size, "%s %s", size, "(Single-bank Connection)");
|
| /packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/setting/usb/ |
| UsbDeviceStateController.java | 179 UsbDeviceConnection connection = openConnection(device); local
181 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_MANUFACTURER,
183 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_MODEL,
185 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_DESCRIPTION,
187 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_VERSION,
189 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_URI, request.uri);
190 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_SERIAL,
192 AoapInterface.sendAoapStart(connection);
199 connection.close();
208 connection.close()
[all...] |
| /external/dhcpcd-6.8.2/dbus/ |
| rpc-dbus.c | 53 static DBusConnection *connection; variable
359 success = dbus_connection_send(connection, msg, NULL);
435 success = dbus_connection_send(connection, msg, NULL);
558 if (connection != NULL) {
559 dbus_connection_ref(connection);
560 while (dbus_connection_dispatch(connection) ==
563 dbus_connection_unref(connection);
658 connection = dbus_bus_get(DBUS_BUS_SYSTEM, &err);
659 if (connection == NULL) {
663 syslog(LOG_ERR, "failed to get a dbus connection");
[all...] |
| /external/chromium-trace/catapult/telemetry/third_party/web-page-replay/ |
| certutils.py | 83 def get_ssl_connection(context, connection):
84 return WrappedConnection(SSL.Connection(context, connection))
160 connection = SSL.Connection(context, s)
162 connection.connect((host, port))
163 connection.send('')
169 connection.shutdown()
170 connection.close()
|
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
| RoomParametersFetcher.java | 75 Log.e(TAG, "Room connection error: " + errorMessage);
175 HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection(); local
176 connection.setConnectTimeout(TURN_HTTP_TIMEOUT_MS);
177 connection.setReadTimeout(TURN_HTTP_TIMEOUT_MS);
178 int responseCode = connection.getResponseCode();
181 + url + " : " + connection.getHeaderField(null));
183 InputStream responseStream = connection.getInputStream();
185 connection.disconnect();
|
| /frameworks/base/services/core/jni/ |
| com_android_server_tv_TvInputHal.cpp | 268 // Connection between a surface and a stream.
269 class Connection {
271 Connection() {}
307 KeyedVector<int, KeyedVector<int, Connection> > mConnections;
341 KeyedVector<int, Connection>& connections = mConnections.editValueFor(deviceId);
343 connections.add(streamId, Connection());
345 Connection& connection = connections.editValueFor(streamId); local
346 if (connection.mSurface == surface) {
350 // Clear the surface in the connection
415 Connection& connection = connections.editValueFor(streamId); local
536 Connection& connection = connections.editValueFor(streamId); local
[all...] |
