| /external/libmicrohttpd/src/microhttpd/ |
| test_postprocessor_large.c | 62 struct MHD_Connection connection; local
75 memset (&connection, 0, sizeof (struct MHD_Connection));
77 connection.headers_received = &header;
81 pp = MHD_create_post_processor (&connection, 1024, &value_checker, &pos);
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Interceptor.java | 31 Connection connection(); method in interface:Interceptor.Chain
|
| /external/skia/tools/skiaserve/urlhandlers/ |
| CmdHandler.cpp | 21 int CmdHandler::handle(Request* request, MHD_Connection* connection,
41 return SendData(connection, data.get(), "application/json");
49 return SendOK(connection);
58 return SendOK(connection);
|
| QuitHandler.cpp | 22 int QuitHandler::handle(Request* request, MHD_Connection* connection,
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| URLConnectionTest.java | 339 HttpURLConnection connection = (HttpURLConnection) server.getUrl("/").openConnection(); local
340 assertNull(connection.getErrorStream());
346 HttpURLConnection connection = (HttpURLConnection) server.getUrl("/").openConnection(); local
347 assertEquals("A", readAscii(connection.getErrorStream(), Integer.MAX_VALUE));
351 // recycled connection doesn't get the unread tail of the first request's response.
430 .setBody("This connection won't pool properly")
432 server.enqueue(new MockResponse().setBody("This comes after a busted connection"));
435 assertContent("This connection won't pool properly", server.getUrl("/a").openConnection());
437 assertContent("This comes after a busted connection", server.getUrl("/b").openConnection());
438 // sequence number 0 means the HTTP socket connection was not reuse
551 HttpsURLConnection connection = (HttpsURLConnection) server.getUrl("\/foo").openConnection(); local
570 HttpsURLConnection connection = (HttpsURLConnection) server.getUrl("\/").openConnection(); local
592 HttpsURLConnection connection = (HttpsURLConnection) server.getUrl("\/").openConnection(); local
618 HttpsURLConnection connection = (HttpsURLConnection) server.getUrl("\/foo").openConnection(); local
667 HttpURLConnection connection = proxyConfig.connect(server, url); local
718 HttpsURLConnection connection = (HttpsURLConnection) proxyConfig.connect(server, url); local
760 HttpsURLConnection connection = (HttpsURLConnection) proxyConfig.connect(server, url); local
801 HttpsURLConnection connection = (HttpsURLConnection) proxyConfig.connect(server, url); local
883 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
932 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
971 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection( local
1022 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection( local
1054 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection( local
1069 HttpURLConnection connection = (HttpURLConnection) server.getUrl("\/").openConnection(); local
1129 HttpURLConnection connection = (HttpURLConnection) server.getUrl("\/").openConnection(); local
1148 HttpURLConnection connection = (HttpURLConnection) server.getUrl("\/").openConnection(); local
1161 HttpURLConnection connection = (HttpURLConnection) server.getUrl("\/").openConnection(); local
1255 URLConnection connection = server.getUrl("\/").openConnection(); local
1271 URLConnection connection = server.getUrl("\/").openConnection(); local
1290 URLConnection connection = server.getUrl("\/").openConnection(); local
1307 URLConnection connection = server.getUrl("\/").openConnection(); local
1332 URLConnection connection = server.getUrl("\/").openConnection(); local
1356 URLConnection connection = server.getUrl("\/").openConnection(); local
[all...] |
| /packages/services/Telecomm/src/com/android/server/telecom/ |
| CreateConnectionResponse.java | 25 * A callback for providing the result of creating a connection.
29 void handleCreateConnectionSuccess(CallIdMapper idMapper, ParcelableConnection connection);
|
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/telecom/ |
| CtsConnection.java | 24 import android.telecom.Connection;
34 * An implementation of the {@link android.telecom.Connection} class used by the
37 public class CtsConnection extends Connection {
39 * Listener used to inform the CtsVerifier app of changes to a connection.
42 void onDestroyed(CtsConnection connection) { };
43 void onDisconnect(CtsConnection connection) { };
44 void onHold(CtsConnection connection) { };
45 void onUnhold(CtsConnection connection) { };
46 void onAnswer(CtsConnection connection, int videoState) { };
47 void onReject(CtsConnection connection) { };
[all...] |
| /packages/services/Telephony/src/com/android/phone/ |
| CallGatewayManager.java | 26 import com.android.internal.telephony.Connection;
39 * proper number to dial. It also saves an association between the connection object and the gateway
70 private final ConcurrentHashMap<Connection, RawGatewayInfo> mMap =
71 new ConcurrentHashMap<Connection, RawGatewayInfo>(4, 0.9f, 1);
100 * This function sets the current mapping from connection to gatewayInfo.
101 * @param connection The connection object for the placed outgoing call.
104 public void setGatewayInfoForConnection(Connection connection, RawGatewayInfo gatewayInfo) {
106 mMap.put(connection, gatewayInfo)
[all...] |
| /frameworks/base/services/core/java/com/android/server/location/ |
| GpsXtraDownloader.java | 116 HttpURLConnection connection = null; local
118 connection = (HttpURLConnection) (new URL(url)).openConnection();
119 connection.setRequestProperty(
122 connection.setRequestProperty(
125 connection.setConnectTimeout(CONNECTION_TIMEOUT_MS);
127 connection.connect();
128 int statusCode = connection.getResponseCode();
134 try (InputStream in = connection.getInputStream()) {
150 if (connection != null) {
151 connection.disconnect()
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| ExternalHttp2Example.java | 38 HttpsURLConnection connection = (HttpsURLConnection) new OkUrlFactory(client) local
41 connection.setHostnameVerifier(new HostnameVerifier() {
48 int responseCode = connection.getResponseCode();
50 List<String> protocolValues = connection.getHeaderFields().get(SELECTED_PROTOCOL);
57 new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
|
| ExternalSpdyExample.java | 38 HttpsURLConnection connection = (HttpsURLConnection) new OkUrlFactory(client) local
41 connection.setHostnameVerifier(new HostnameVerifier() {
48 int responseCode = connection.getResponseCode();
50 List<String> protocolValues = connection.getHeaderFields().get(SELECTED_PROTOCOL);
57 new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
|
| /packages/apps/Dialer/java/com/android/dialer/simulator/impl/ |
| SimulatorConnectionService.java | 22 import android.telecom.Connection;
33 /** Simple connection provider to create an incoming call. This is useful for emulators. */
46 getConnectionServiceHandle(context), "Simulator connection service");
52 .setShortDescription("Simulator Connection Service")
68 public Connection onCreateOutgoingConnection(
77 public Connection onCreateIncomingConnection(
80 SimulatorConnection connection = new SimulatorConnection(); local
81 connection.setRinging();
82 connection.setAddress(getPhoneNumber(request), TelecomManager.PRESENTATION_ALLOWED);
83 connection.setConnectionCapabilities
[all...] |
| /packages/apps/KeyChain/support/src/com/android/keychain/tests/support/ |
| KeyChainServiceTestSupport.java | 72 KeyChain.KeyChainConnection connection = null;
74 connection = KeyChain.bind(KeyChainServiceTestSupport.this);
75 connection.getService().setGrant(senderUid, alias, value);
81 if (connection != null) {
82 connection.close();
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| MockWebServerTest.java | 86 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
87 connection.setRequestProperty("Accept-Language", "en-US");
88 InputStream in = connection.getInputStream();
90 assertEquals(HttpURLConnection.HTTP_OK, connection.getResponseCode());
105 URLConnection connection = server.getUrl("/").openConnection(); local
106 InputStream in = connection.getInputStream();
131 URLConnection connection = server.getUrl("/").openConnection(); local
132 InputStream in = connection.getInputStream();
143 URLConnection connection = server.getUrl("/").openConnection(); local
144 InputStream in = connection.getInputStream()
202 URLConnection connection = server.getUrl("\/").openConnection(); local
263 HttpURLConnection connection = (HttpURLConnection) server.getUrl("\/").openConnection(); local
288 URLConnection connection = server.getUrl("\/").openConnection(); local
[all...] |
| /packages/apps/Messaging/src/android/support/v7/mms/ |
| MmsHttpClient.java | 119 HttpURLConnection connection = null; local
126 // Now get the connection
127 connection = (HttpURLConnection) url.openConnection(proxy);
128 connection.setDoInput(true);
129 connection.setConnectTimeout(
134 connection.setRequestProperty(HEADER_ACCEPT, HEADER_VALUE_ACCEPT);
136 connection.setRequestProperty(
140 connection.setRequestProperty(HEADER_USER_AGENT, userAgent);
147 connection.setRequestProperty(uaProfUrlTagName, uaProfUrl);
150 addExtraHeaders(connection, mmsConfig)
[all...] |
| /external/dnsmasq/src/ |
| dbus.c | 261 DBusHandlerResult message_handler(DBusConnection *connection,
272 dbus_connection_send (connection, reply, NULL);
281 dbus_connection_send (connection, reply, NULL);
305 DBusConnection *connection = NULL; local
311 if (!(connection = dbus_bus_get (DBUS_BUS_SYSTEM, &dbus_error)))
314 dbus_connection_set_exit_on_disconnect(connection, FALSE);
315 dbus_connection_set_watch_functions(connection, add_watch, remove_watch,
318 dbus_bus_request_name (connection, DNSMASQ_SERVICE, 0, &dbus_error);
322 if (!dbus_connection_register_object_path(connection, DNSMASQ_PATH,
326 daemon->dbus = connection;
363 DBusConnection *connection = (DBusConnection *)daemon->dbus; local
395 DBusConnection *connection = (DBusConnection *)daemon->dbus; local
[all...] |
| /external/libbrillo/brillo/http/ |
| http_transport_curl_unittest.cc | 69 auto connection = transport_->CreateConnection("http://foo.bar/get", local
75 EXPECT_NE(nullptr, connection.get());
78 connection.reset();
87 auto connection = transport_->CreateConnection( local
89 EXPECT_NE(nullptr, connection.get());
92 connection.reset();
101 auto connection = transport_->CreateConnection( local
103 EXPECT_NE(nullptr, connection.get());
106 connection.reset();
117 auto connection = transport_->CreateConnection local
137 auto connection = transport_->CreateConnection( local
155 auto connection = transport_->CreateConnection( local
202 auto connection = transport_->CreateConnection( local
302 auto connection = transport_->CreateConnection( local
[all...] |
| /packages/services/Telecomm/tests/src/com/android/server/telecom/tests/ |
| CallExtrasTest.java | 22 import android.telecom.Connection;
32 * Tests the {@link Connection} and {@link Call} extras functionality.
45 * Tests setting extras on the connection side and ensuring they are propagated through to
61 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
62 connection.putExtras(extras);
71 * Tests setting extras on the connection side and ensuring they are propagated through to
82 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
83 connection.putExtra(EXTRA_KEY_BOOL, true)
103 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
124 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
147 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
176 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
212 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
257 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
278 Connection connection = mConnectionServiceFixtureA.mLatestConnection; local
[all...] |
| /external/libmicrohttpd/doc/examples/ |
| largepost.c | 57 send_page (struct MHD_Connection *connection, const char *page,
69 ret = MHD_queue_response (connection, status_code, response);
120 request_completed (void *cls, struct MHD_Connection *connection,
146 answer_to_connection (void *cls, struct MHD_Connection *connection,
156 return send_page (connection, busypage, MHD_HTTP_SERVICE_UNAVAILABLE);
167 MHD_create_post_processor (connection, POSTBUFFERSIZE,
195 return send_page (connection, buffer, MHD_HTTP_OK);
218 return send_page (connection, con_info->answerstring,
224 return send_page (connection, errorpage, MHD_HTTP_BAD_REQUEST);
|
| /frameworks/base/services/core/java/com/android/server/tv/ |
| TvRemoteProviderProxy.java | 37 * Maintains a connection to a tv remote provider service.
64 // Connection state
67 private Connection mActiveConnection;
186 Connection connection = new Connection(provider); local
187 if (connection.register()) {
189 mActiveConnection = connection;
212 private void onConnectionReady(Connection connection) {
576 Connection connection = mConnectionRef.get(); local
584 Connection connection = mConnectionRef.get(); local
592 Connection connection = mConnectionRef.get(); local
600 Connection connection = mConnectionRef.get(); local
608 Connection connection = mConnectionRef.get(); local
616 Connection connection = mConnectionRef.get(); local
625 Connection connection = mConnectionRef.get(); local
633 Connection connection = mConnectionRef.get(); local
641 Connection connection = mConnectionRef.get(); local
[all...] |
| /frameworks/native/services/sensorservice/ |
| SensorService.h | 73 void cleanupConnection(SensorEventConnection* connection);
76 status_t enable(const sp<SensorEventConnection>& connection, int handle,
80 status_t disable(const sp<SensorEventConnection>& connection, int handle);
82 status_t setEventRate(const sp<SensorEventConnection>& connection, int handle, nsecs_t ns,
85 status_t flushSensor(const sp<SensorEventConnection>& connection,
176 status_t cleanupWithoutDisable(const sp<SensorEventConnection>& connection, int handle);
177 status_t cleanupWithoutDisableLocked(const sp<SensorEventConnection>& connection, int handle);
178 void cleanupAutoDisabledSensorLocked(const sp<SensorEventConnection>& connection,
201 // Send events from the event cache for this particular connection.
202 void sendEventsFromCache(const sp<SensorEventConnection>& connection);
[all...] |
| SensorService.cpp | 343 sp<SensorDirectConnection> connection(i.promote());
344 if (connection != nullptr) {
345 connection->stopAll(true /* backupRecord */);
352 // flush complete event is returned, we need to remove the connection from this queue.
365 sp<SensorDirectConnection> connection(i.promote());
366 if (connection != nullptr) {
367 connection->recoverAll();
451 sp<SensorEventConnection> connection(mActiveConnections[i].promote());
452 if (connection != 0) {
453 result.appendFormat("Connection Number: %zu \n", i)
[all...] |
| /external/libbrillo/brillo/glib/ |
| dbus.cc | 69 return system_bus_connection; // returns NULL connection.
132 Proxy::Proxy(const BusConnection& connection,
138 connection, name, path, interface, connect_to_name_owner)) {
141 // Equivalent to Proxy(connection, name, path, interface, false).
142 Proxy::Proxy(const BusConnection& connection,
146 : object_(GetGProxy(connection, name, path, interface, false)) {
150 Proxy::Proxy(const BusConnection& connection,
153 : object_(GetGPeerProxy(connection, path, interface)) {
168 Proxy::value_type Proxy::GetGProxy(const BusConnection& connection,
176 result = ::dbus_g_proxy_new_for_name_owner(connection.object_
[all...] |
| /external/chromium-trace/catapult/telemetry/third_party/web-page-replay/ |
| httpclient_test.py | 126 """Test that a connection is made with request IP/port or proxy IP/port."""
148 """HTTP connection with no proxy connects to host IP."""
150 connection = self.fetch._get_connection('example.com', None, is_ssl=False)
151 self.assertEqual('127.127.127.127', connection.host)
152 self.assertEqual(80, connection.port) # default HTTP port
155 """HTTP connection with no proxy connects with request port."""
157 connection = self.fetch._get_connection('example.com', 8888, is_ssl=False)
158 self.assertEqual('127.127.127.127', connection.host)
159 self.assertEqual(8888, connection.port) # request HTTP port
162 """HTTP connection with proxy connects used proxy port.""
[all...] |
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| RemoteConnectionTest.java | 27 import android.telecom.Connection;
70 assertConnectionState(mConnection, Connection.STATE_ACTIVE);
71 assertRemoteConnectionState(mRemoteConnectionObject, Connection.STATE_ACTIVE);
72 assertConnectionState(mRemoteConnection, Connection.STATE_ACTIVE);
76 assertConnectionState(mConnection, Connection.STATE_HOLDING);
77 assertRemoteConnectionState(mRemoteConnectionObject, Connection.STATE_HOLDING);
78 assertConnectionState(mRemoteConnection, Connection.STATE_HOLDING);
82 assertConnectionState(mConnection, Connection.STATE_ACTIVE);
83 assertRemoteConnectionState(mRemoteConnectionObject, Connection.STATE_ACTIVE);
84 assertConnectionState(mRemoteConnection, Connection.STATE_ACTIVE)
[all...] |
