/bootable/recovery/updater_sample/src/com/example/android/systemupdatersample/util/ |
FileDownloader.java | 60 URLConnection connection = url.openConnection(); local 61 connection.connect(); 64 try (InputStream input = connection.getInputStream()) {
|
/cts/apps/CtsVerifier/src/com/android/cts/verifier/telecom/ |
SelfManagedIncomingCallTestActivity.java | 23 import android.telecom.Connection; 52 void onShowIncomingCallUi(CtsConnection connection) { 59 void onAnswer(CtsConnection connection, int videoState) { 61 connection.onDisconnect(); 65 void onDisconnect(CtsConnection connection) { 66 super.onDisconnect(connection); 148 return new Throwable("Could not get connection service."); 151 CtsConnection connection = ctsConnectionService.waitForAndGetConnection(); 152 if (connection == null) { 154 return new Throwable("Could not get connection.") [all...] |
CtsConnection.java | 24 import android.telecom.Connection; 36 * An implementation of the {@link android.telecom.Connection} class used by the 39 public class CtsConnection extends Connection { 41 * Listener used to inform the CtsVerifier app of changes to a connection. 44 void onDestroyed(CtsConnection connection) { }; 45 void onDisconnect(CtsConnection connection) { }; 46 void onHold(CtsConnection connection) { }; 47 void onUnhold(CtsConnection connection) { }; 48 void onAnswer(CtsConnection connection, int videoState) { }; 49 void onReject(CtsConnection connection) { }; [all...] |
/external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
ResponseCacheTest.java | 199 HttpURLConnection connection = openConnection(url); local 200 assertEquals(responseCode, connection.getResponseCode()); 203 readAscii(connection); 270 // OpenJDK 6 fails on this line, complaining that the connection isn't open yet 302 HttpURLConnection connection = openConnection(server.getUrl("/")); local 303 assertEquals("ABC", readAscii(connection)); 305 connection = openConnection(server.getUrl("/")); // cached! 306 assertEquals("ABC", readAscii(connection)); 329 // an unrelated request should reuse the pooled connection 488 URLConnection connection = openConnection(server.getUrl("/")) local 513 URLConnection connection = openConnection(server.getUrl("\/")); local 539 URLConnection connection = openConnection(url); local 567 URLConnection connection = openConnection(server.getUrl("\/")); local 987 URLConnection connection = openConnection(server.getUrl("\/")); local 1002 URLConnection connection = openConnection(server.getUrl("\/")); local 1017 URLConnection connection = openConnection(server.getUrl("\/")); local 1053 URLConnection connection = openConnection(server.getUrl("\/")); local 1061 HttpURLConnection connection = openConnection(server.getUrl("\/")); local 1073 URLConnection connection = openConnection(server.getUrl("\/")); local 1085 HttpURLConnection connection = openConnection(server.getUrl("\/")); local 1095 HttpURLConnection connection = openConnection(server.getUrl("\/")); local 1110 URLConnection connection = openConnection(url); local 1125 URLConnection connection = openConnection(url); local 1161 HttpURLConnection connection = openConnection(url); local 1207 HttpURLConnection connection = openConnection(server.getUrl("\/")); local 1222 URLConnection connection = openConnection(url); local 1631 URLConnection connection = openConnection(server.getUrl("\/")); local 1647 HttpURLConnection connection = openConnection(server.getUrl("\/")); local 1660 HttpURLConnection connection = openConnection(server.getUrl("\/")); local 1668 URLConnection connection = openConnection(server.getUrl("\/")); local 1680 HttpURLConnection connection = openConnection(server.getUrl("\/")); local [all...] |
/device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Modules/_sqlite/ |
cursor.c | 81 pysqlite_Connection* connection;
local 83 if (!PyArg_ParseTuple(args, "O!", &pysqlite_ConnectionType, &connection))
88 Py_INCREF(connection);
89 self->connection = connection;
114 if (!pysqlite_check_thread(self->connection)) {
118 if (!pysqlite_connection_register_cursor(connection, (PyObject*)self)) {
137 Py_XDECREF(self->connection);
179 if (!self->connection->detect_types) {
189 if (self->connection->detect_types & PARSE_COLNAMES) { [all...] |
statement.h | 28 #include "connection.h"
46 int pysqlite_statement_create(pysqlite_Statement* self, pysqlite_Connection* connection, PyObject* sql);
|
/cts/tests/tests/telecom/src/android/telecom/cts/ |
MockConference.java | 21 import android.telecom.Connection; 46 // a is the primary connection, so inherit the properties from it. 55 for (Connection c : getConnections()) { 66 public void onSeparate(Connection connection) { 67 super.onSeparate(connection); 68 if (getConnections().contains(connection)) { 69 removeConnection(connection); 72 mRemoteConference.separate(((MockConnection)connection).getRemoteConnection()); 79 // Let's just change the connection display name for testing that onMerge was invoked [all...] |
/developers/build/prebuilts/gradle/NetworkConnect/Application/src/main/java/com/example/android/networkconnect/ |
NetworkFragment.java | 215 * Given a URL, sets up a connection and gets the HTTP response body from the server. 221 HttpsURLConnection connection = null; local 224 connection = (HttpsURLConnection) url.openConnection(); 226 connection.setReadTimeout(3000); 227 // Timeout for connection.connect() arbitrarily set to 3000ms. 228 connection.setConnectTimeout(3000); 230 connection.setRequestMethod("GET"); 233 connection.setDoInput(true); 235 connection.connect(); 237 int responseCode = connection.getResponseCode() [all...] |
/developers/samples/android/connectivity/network/NetworkConnect/Application/src/main/java/com/example/android/networkconnect/ |
NetworkFragment.java | 215 * Given a URL, sets up a connection and gets the HTTP response body from the server. 221 HttpsURLConnection connection = null; local 224 connection = (HttpsURLConnection) url.openConnection(); 226 connection.setReadTimeout(3000); 227 // Timeout for connection.connect() arbitrarily set to 3000ms. 228 connection.setConnectTimeout(3000); 230 connection.setRequestMethod("GET"); 233 connection.setDoInput(true); 235 connection.connect(); 237 int responseCode = connection.getResponseCode() [all...] |
/development/samples/browseable/NetworkConnect/src/com.example.android.networkconnect/ |
NetworkFragment.java | 215 * Given a URL, sets up a connection and gets the HTTP response body from the server. 221 HttpsURLConnection connection = null; local 224 connection = (HttpsURLConnection) url.openConnection(); 226 connection.setReadTimeout(3000); 227 // Timeout for connection.connect() arbitrarily set to 3000ms. 228 connection.setConnectTimeout(3000); 230 connection.setRequestMethod("GET"); 233 connection.setDoInput(true); 235 connection.connect(); 237 int responseCode = connection.getResponseCode() [all...] |
/external/libbrillo/brillo/http/ |
http_transport_curl.cc | 31 // This is a class that stores connection data on particular CURL socket 80 // The socket file descriptor for the connection. 89 // connection. 94 // We store a connection here to make sure the object is alive for 96 std::shared_ptr<Connection> connection; member in struct:brillo::http::curl::Transport::AsyncRequestData 117 std::shared_ptr<http::Connection> Transport::CreateConnection( 124 std::shared_ptr<http::Connection> connection; local 130 return connection; 434 Connection* connection = nullptr; local [all...] |
/external/mockwebserver/src/test/java/com/google/mockwebserver/ |
MockWebServerTest.java | 111 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local 112 connection.setRequestProperty("Accept-Language", "en-US"); 113 InputStream in = connection.getInputStream(); 115 assertEquals(HttpURLConnection.HTTP_OK, connection.getResponseCode()); 131 URLConnection connection = server.getUrl("/").openConnection(); local 132 InputStream in = connection.getInputStream(); 159 URLConnection connection = server.getUrl("/").openConnection(); local 160 InputStream in = connection.getInputStream(); 172 URLConnection connection = server.getUrl("/").openConnection(); local 173 InputStream in = connection.getInputStream() [all...] |
/external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
AbstractLauncher.java | 137 return manager.createVirtualMachine(helper.connection(), 154 private Connection connection = null; field in class:AbstractLauncher.Helper 185 while ((connection == null) && 211 Connection connection() { method in class:AbstractLauncher.Helper 212 return connection; 220 synchronized void notifyOfConnection(Connection connection) { 221 this.connection = connection [all...] |
/external/webrtc/webrtc/base/ |
httpserver.cc | 48 Connection* connection = new Connection(connection_id, this); local 49 connections_.insert(ConnectionMap::value_type(connection_id, connection)); 50 connection->BeginProcess(stream); 57 if (Connection* connection = Find(connection_id)) { 58 connection->Respond(transaction); 62 // connection still exists. 68 if (Connection* connection = Find(connection_id)) 106 Connection* connection = it->second; local [all...] |
/external/wayland/tests/ |
connection-test.c | 22 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE 49 struct wl_connection *connection; local 53 connection = wl_connection_create(s[0]); 54 assert(connection); 56 return connection; 61 struct wl_connection *connection; local 64 connection = setup(s); 65 wl_connection_destroy(connection); 72 struct wl_connection *connection; local 76 connection = setup(s) 90 struct wl_connection *connection; local 109 struct wl_connection *connection; local [all...] |
/external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
ConscryptSocketTest.java | 423 TestConnection connection = new TestConnection(new X509Certificate[] {cert, ca}, certKey); 424 connection.doHandshake(); 426 assertTrue(connection.clientHooks.isHandshakeCompleted); 427 assertTrue(connection.serverHooks.isHandshakeCompleted); 506 TestConnection connection = 509 connection.doHandshake(); 511 assertTrue(connection.clientHooks.isHandshakeCompleted); 512 assertTrue(connection.serverHooks.isHandshakeCompleted); 517 TestConnection connection = new TestConnection(new X509Certificate[] {cert, ca}, certKey); 519 connection.serverHooks.ocspResponse = readTestFile("ocsp-response.der") [all...] |
/external/conscrypt/repackaged/openjdk/src/test/java/com/android/org/conscrypt/ |
ConscryptSocketTest.java | 429 TestConnection connection = new TestConnection(new X509Certificate[] {cert, ca}, certKey); 430 connection.doHandshake(); 432 assertTrue(connection.clientHooks.isHandshakeCompleted); 433 assertTrue(connection.serverHooks.isHandshakeCompleted); 512 TestConnection connection = 515 connection.doHandshake(); 517 assertTrue(connection.clientHooks.isHandshakeCompleted); 518 assertTrue(connection.serverHooks.isHandshakeCompleted); 523 TestConnection connection = new TestConnection(new X509Certificate[] {cert, ca}, certKey); 525 connection.serverHooks.ocspResponse = readTestFile("ocsp-response.der") [all...] |
/external/python/cpython3/Modules/_sqlite/ |
cursor.c | 34 pysqlite_Connection* connection; local 36 if (!PyArg_ParseTuple(args, "O!", &pysqlite_ConnectionType, &connection)) 41 Py_INCREF(connection); 42 Py_XSETREF(self->connection, connection); 66 if (!pysqlite_check_thread(self->connection)) { 70 if (!pysqlite_connection_register_cursor(connection, (PyObject*)self)) { 87 Py_XDECREF(self->connection); 130 if (!self->connection->detect_types) { 139 if (self->connection->detect_types & PARSE_COLNAMES) [all...] |
/frameworks/av/media/codec2/hidl/1.0/utils/ |
InputSurface.cpp | 133 sp<InputSurfaceConnection> connection; local 140 connection = new InputSurfaceConnection(mSource, comp, mStore); 142 connection = new InputSurfaceConnection(mSource, sink, mStore); 144 if (!connection->init()) { 145 connection = nullptr; 150 _hidl_cb(status, connection);
|
/external/clang/test/Analysis/Inputs/ |
system-header-simulator.h | 77 void xpc_connection_set_context(xpc_connection_t connection, void *context); 78 void xpc_connection_set_finalizer_f(xpc_connection_t connection, xpc_finalizer_t finalizer); 79 void xpc_connection_resume(xpc_connection_t connection);
|
/external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
UrlConnectionCacheTest.java | 259 // OpenJDK 6 fails on this line, complaining that the connection isn't open yet 292 HttpURLConnection connection = client.open(server.getUrl("/")); local 293 assertEquals("ABC", readAscii(connection)); 295 connection = client.open(server.getUrl("/")); // cached! 296 assertEquals("ABC", readAscii(connection)); 319 // an unrelated request should reuse the pooled connection 421 URLConnection connection = client.open(server.getUrl("/")); local 422 assertEquals("Request #2", readAscii(connection)); 446 URLConnection connection = client.open(server.getUrl("/")); local 447 InputStream in = connection.getInputStream() 476 URLConnection connection = client.open(url); local 503 URLConnection connection = client.open(server.getUrl("\/")); local 876 URLConnection connection = client.open(server.getUrl("\/")); local 889 URLConnection connection = client.open(server.getUrl("\/")); local 902 URLConnection connection = client.open(server.getUrl("\/")); local 917 URLConnection connection = client.open(server.getUrl("\/")); local 925 HttpURLConnection connection = client.open(server.getUrl("\/")); local 939 URLConnection connection = client.open(server.getUrl("\/")); local 953 HttpURLConnection connection = client.open(server.getUrl("\/")); local 965 HttpURLConnection connection = client.open(server.getUrl("\/")); local 983 URLConnection connection = client.open(url); local 998 URLConnection connection = client.open(url); local 1031 HttpURLConnection connection = client.open(url); local 1050 URLConnection connection = client.open(url); local 1094 HttpURLConnection connection = client.open(server.getUrl("\/")); local 1106 URLConnection connection = client.open(url); local 1127 URLConnection connection = client.open(server.getUrl("\/")); local 1139 URLConnection connection = client.open(server.getUrl("\/")); local 1545 URLConnection connection = client.open(server.getUrl("\/")); local 1559 HttpURLConnection connection = client.open(server.getUrl("\/")); local 1570 HttpURLConnection connection = client.open(server.getUrl("\/")); local 1577 URLConnection connection = client.open(server.getUrl("\/")); local 1587 HttpURLConnection connection = client.open(server.getUrl("\/")); local 1646 HttpURLConnection connection = client.open(url); local [all...] |
/art/adbconnection/ |
adbconnection.h | 37 static constexpr char kAdbConnectionThreadName[] = "ADB-JDWP Connection Control Thread"; 45 explicit AdbConnectionDebuggerController(AdbConnectionState* connection) 46 : connection_(connection) {} 63 explicit AdbConnectionDdmCallback(AdbConnectionState* connection) : connection_(connection) {} 158 // the adb connection socket until connection goes away.
|
/device/google/cuttlefish_common/host/commands/ivserver/ |
qemu_client.h | 33 const cvd::SharedFD &connection);
|
/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/client/site_tests/platform_PrinterPpds/ |
fake_printer.py | 117 # Accepts incoming connection 120 (connection, client_address) = self._socket.accept() 132 data = connection.recv(_BUF_SIZE) 142 connection.close() 145 # Closes connection & returns document 146 connection.close()
|