/external/libmicrohttpd/src/microhttpd/ |
D | connection.c | 128 MHD_get_connection_values (struct MHD_Connection *connection, in MHD_get_connection_values() argument 135 if (NULL == connection) in MHD_get_connection_values() 138 for (pos = connection->headers_received; NULL != pos; pos = pos->next) in MHD_get_connection_values() 177 MHD_set_connection_value (struct MHD_Connection *connection, in MHD_set_connection_value() argument 183 pos = MHD_pool_allocate (connection->pool, in MHD_set_connection_value() 192 if (NULL == connection->headers_received_tail) in MHD_set_connection_value() 194 connection->headers_received = pos; in MHD_set_connection_value() 195 connection->headers_received_tail = pos; in MHD_set_connection_value() 199 connection->headers_received_tail->next = pos; in MHD_set_connection_value() 200 connection->headers_received_tail = pos; in MHD_set_connection_value() [all …]
|
D | connection_https.c | 46 run_tls_handshake (struct MHD_Connection *connection) in run_tls_handshake() argument 49 connection->last_activity = MHD_monotonic_time(); in run_tls_handshake() 50 if (connection->state == MHD_TLS_CONNECTION_INIT) in run_tls_handshake() 52 ret = SSL_accept (connection->tls_session); in run_tls_handshake() 56 connection->state = MHD_CONNECTION_INIT; in run_tls_handshake() 59 int error = SSL_get_error (connection->tls_session, ret); in run_tls_handshake() 68 MHD_DLOG (connection->daemon, in run_tls_handshake() 71 MHD_connection_close (connection, in run_tls_handshake() 96 MHD_tls_connection_handle_read (struct MHD_Connection *connection) in MHD_tls_connection_handle_read() argument 98 if (MHD_YES == run_tls_handshake (connection)) in MHD_tls_connection_handle_read() [all …]
|
D | digestauth.c | 301 check_nonce_nc (struct MHD_Connection *connection, in check_nonce_nc() argument 309 mod = connection->daemon->nonce_nc_size; in check_nonce_nc() 327 (void) MHD_mutex_lock_ (&connection->daemon->nnc_lock); in check_nonce_nc() 330 strcpy(connection->daemon->nnc[off].nonce, in check_nonce_nc() 332 connection->daemon->nnc[off].nc = 0; in check_nonce_nc() 333 (void) MHD_mutex_unlock_ (&connection->daemon->nnc_lock); in check_nonce_nc() 336 if ( (nc <= connection->daemon->nnc[off].nc) || in check_nonce_nc() 337 (0 != strcmp(connection->daemon->nnc[off].nonce, nonce)) ) in check_nonce_nc() 339 (void) MHD_mutex_unlock_ (&connection->daemon->nnc_lock); in check_nonce_nc() 341 MHD_DLOG (connection->daemon, in check_nonce_nc() [all …]
|
D | test_postprocessor.c | 124 struct MHD_Connection connection; in test_urlencoding() local 132 memset (&connection, 0, sizeof (struct MHD_Connection)); in test_urlencoding() 134 connection.headers_received = &header; in test_urlencoding() 138 pp = MHD_create_post_processor (&connection, in test_urlencoding() 158 struct MHD_Connection connection; in test_multipart_garbage() local 177 memset (&connection, 0, sizeof (struct MHD_Connection)); in test_multipart_garbage() 179 connection.headers_received = &header; in test_multipart_garbage() 184 pp = MHD_create_post_processor (&connection, in test_multipart_garbage() 199 struct MHD_Connection connection; in test_multipart_splits() local 210 memset (&connection, 0, sizeof (struct MHD_Connection)); in test_multipart_splits() [all …]
|
/external/volley/src/main/java/com/android/volley/toolbox/ |
D | HurlStack.java | 103 HttpURLConnection connection = openConnection(parsedUrl, request); in performRequest() local 105 connection.addRequestProperty(headerName, map.get(headerName)); in performRequest() 107 setConnectionParametersForRequest(connection, request); in performRequest() 110 int responseCode = connection.getResponseCode(); in performRequest() 117 connection.getResponseCode(), connection.getResponseMessage()); in performRequest() 120 response.setEntity(entityFromConnection(connection)); in performRequest() 122 for (Entry<String, List<String>> header : connection.getHeaderFields().entrySet()) { in performRequest() 150 private static HttpEntity entityFromConnection(HttpURLConnection connection) { in entityFromConnection() argument 154 inputStream = connection.getInputStream(); in entityFromConnection() 156 inputStream = connection.getErrorStream(); in entityFromConnection() [all …]
|
/external/libmicrohttpd/src/examples/ |
D | mhd2spdy_spdy.c | 146 struct SPDY_Connection *connection; in spdy_cb_send() local 148 connection = (struct SPDY_Connection*)user_data; in spdy_cb_send() 149 connection->want_io = IO_NONE; in spdy_cb_send() 164 if(connection->is_tls) in spdy_cb_send() 167 rv = SSL_write(connection->ssl, data, length); in spdy_cb_send() 169 int err = SSL_get_error(connection->ssl, rv); in spdy_cb_send() 171 connection->want_io |= (err == SSL_ERROR_WANT_READ ? in spdy_cb_send() 181 rv = write(connection->fd, in spdy_cb_send() 193 connection->want_io |= WANT_WRITE; in spdy_cb_send() 228 struct SPDY_Connection *connection; in spdy_cb_recv() local [all …]
|
/external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
D | CacheAdapterTest.java | 65 private HttpURLConnection connection; field in CacheAdapterTest 73 if (connection != null) { in tearDown() 74 connection.disconnect(); in tearDown() 95 connection = new OkUrlFactory(client).open(serverUrl); in get_httpGet() 96 connection.setRequestProperty("key1", "value1"); in get_httpGet() 98 executeGet(connection); in get_httpGet() 120 connection = new OkUrlFactory(client).open(serverUrl); in get_httpsGet() 121 connection.setRequestProperty("key1", "value1"); in get_httpsGet() 123 executeGet(connection); in get_httpsGet() 136 @Override public CacheRequest put(URI uri, URLConnection connection) throws IOException { in put_httpGet() [all …]
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
D | Spdy3ConnectionTest.java | 77 FramedConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerReplies() local 78 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true); in clientCreatesStreamAndServerReplies() 84 assertEquals(0, connection.openStreamCount()); in clientCreatesStreamAndServerReplies() 106 FramedConnection connection = connection(peer, SPDY3); in headersOnlyStreamIsClosedAfterReplyHeaders() local 107 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, false); in headersOnlyStreamIsClosedAfterReplyHeaders() 108 assertEquals(1, connection.openStreamCount()); in headersOnlyStreamIsClosedAfterReplyHeaders() 110 connection.ping().roundTripTime(); // Ensure that inFinished has been received. in headersOnlyStreamIsClosedAfterReplyHeaders() 111 assertEquals(0, connection.openStreamCount()); in headersOnlyStreamIsClosedAfterReplyHeaders() 123 FramedConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerRepliesWithFin() local 124 connection.newStream(headerEntries("b", "banana"), false, true); in clientCreatesStreamAndServerRepliesWithFin() [all …]
|
D | Http2ConnectionTest.java | 67 connection(peer, HTTP_2); in serverPingsClientHttp2() 87 FramedConnection connection = connection(peer, HTTP_2); in clientPingsServerHttp2() local 88 Ping ping = connection.ping(); in clientPingsServerHttp2() 115 FramedConnection connection = connection(peer, HTTP_2); 118 assertEquals(65535, connection.peerSettings.getInitialWindowSize(-1)); 131 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true); 133 assertEquals(3368, connection.peerSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE)); 134 assertEquals(1684, connection.bytesLeftInWriteWindow); // initial wasn't affected. 144 FramedConnection connection = sendHttp2SettingsAndCheckForAck(client, settings); 147 assertEquals(0, connection.peerSettings.getHeaderTableSize()); [all …]
|
D | HttpOverSpdyTest.java | 77 protected HttpURLConnection connection; field in HttpOverSpdyTest 100 connection = client.open(server.getUrl("/foo")); in get() 101 assertContent("ABCDE", connection, Integer.MAX_VALUE); in get() 102 assertEquals(200, connection.getResponseCode()); in get() 103 assertEquals("Sweet", connection.getResponseMessage()); in get() 114 connection = client.open(server.getUrl("/foo")); in emptyResponse() 115 assertEquals(-1, connection.getInputStream().read()); in emptyResponse() 123 connection = client.open(server.getUrl("/foo")); in noDefaultContentLengthOnStreamingPost() 124 connection.setDoOutput(true); in noDefaultContentLengthOnStreamingPost() 125 connection.setChunkedStreamingMode(0); in noDefaultContentLengthOnStreamingPost() [all …]
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
D | URLConnectionTest.java | 110 private HttpURLConnection connection; field in URLConnectionTest 135 connection = client.open(server.getUrl("/")); in requestHeaders() 136 connection.addRequestProperty("D", "e"); in requestHeaders() 137 connection.addRequestProperty("D", "f"); in requestHeaders() 138 assertEquals("f", connection.getRequestProperty("D")); in requestHeaders() 139 assertEquals("f", connection.getRequestProperty("d")); in requestHeaders() 140 Map<String, List<String>> requestHeaders = connection.getRequestProperties(); in requestHeaders() 154 connection.setRequestProperty(null, "j"); in requestHeaders() 159 connection.addRequestProperty(null, "k"); in requestHeaders() 163 connection.setRequestProperty("NullValue", null); in requestHeaders() [all …]
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
D | ConnectionPool.java | 134 for (RealConnection connection : connections) { in getIdleConnectionCount() 135 if (connection.allocations.isEmpty()) total++; in getIdleConnectionCount() 159 for (RealConnection connection : connections) { in getMultiplexedConnectionCount() 160 if (connection.isMultiplexed()) total++; in getMultiplexedConnectionCount() 173 for (RealConnection connection : connections) { in get() 176 if (connection.allocations.size() < connection.allocationLimit() in get() 177 && address.equals(connection.getRoute().address) in get() 178 && !connection.noNewStreams) { in get() 179 streamAllocation.acquire(connection); in get() 180 return connection; in get() [all …]
|
/external/ksoap2/ksoap2-j2se/src/main/java/org/ksoap2/transport/ |
D | HttpsServiceConnectionSE.java | 41 private HttpsURLConnection connection; field in HttpsServiceConnectionSE 54 connection = (HttpsURLConnection) new URL(HttpsTransportSE.PROTOCOL, host, port, file) in HttpsServiceConnectionSE() 60 connection.setConnectTimeout(timeout); in updateConnectionParameters() 61 …connection.setReadTimeout(timeout); // even if we connect fine we want to time out if we cant read… in updateConnectionParameters() 62 connection.setUseCaches(false); in updateConnectionParameters() 63 connection.setDoOutput(true); in updateConnectionParameters() 64 connection.setDoInput(true); in updateConnectionParameters() 68 connection.connect(); in connect() 72 connection.disconnect(); in disconnect() 76 Map properties = connection.getHeaderFields(); in getResponseProperties() [all …]
|
D | ServiceConnectionSE.java | 39 private HttpURLConnection connection; field in ServiceConnectionSE 65 connection = (proxy == null) in ServiceConnectionSE() 68 connection.setUseCaches(false); in ServiceConnectionSE() 69 connection.setDoOutput(true); in ServiceConnectionSE() 70 connection.setDoInput(true); in ServiceConnectionSE() 71 connection.setConnectTimeout(timeout); in ServiceConnectionSE() 72 …connection.setReadTimeout(timeout); // even if we connect fine we want to time out if we cant read… in ServiceConnectionSE() 76 connection.connect(); in connect() 80 connection.disconnect(); in disconnect() 84 Map properties = connection.getHeaderFields(); in getResponseProperties() [all …]
|
D | HttpTransportSE.java | 153 ServiceConnection connection = getServiceConnection(); in call() local 154 System.out.println("connection:" + connection); in call() 156 connection.setRequestProperty("User-Agent", USER_AGENT); in call() 163 connection.setRequestProperty("SOAPAction", soapAction); in call() 167 connection.setRequestProperty("Content-Type", CONTENT_TYPE_SOAP_XML_CHARSET_UTF_8); in call() 169 connection.setRequestProperty("Content-Type", CONTENT_TYPE_XML_CHARSET_UTF_8); in call() 172 connection.setRequestProperty("Connection", "close"); in call() 173 connection.setRequestProperty("Accept-Encoding", "gzip"); in call() 174 connection.setRequestProperty("Content-Length", "" + requestData.length); in call() 183 connection.setRequestProperty(hp.getKey(), hp.getValue()); in call() [all …]
|
/external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/util/ |
D | AsyncHttpURLConnection.java | 64 HttpURLConnection connection = in sendHttpMessage() local 70 connection.setRequestMethod(method); in sendHttpMessage() 71 connection.setUseCaches(false); in sendHttpMessage() 72 connection.setDoInput(true); in sendHttpMessage() 73 connection.setConnectTimeout(HTTP_TIMEOUT_MS); in sendHttpMessage() 74 connection.setReadTimeout(HTTP_TIMEOUT_MS); in sendHttpMessage() 76 connection.addRequestProperty("origin", HTTP_ORIGIN); in sendHttpMessage() 80 connection.setDoOutput(true); in sendHttpMessage() 81 connection.setFixedLengthStreamingMode(postData.length); in sendHttpMessage() 84 connection.setRequestProperty("Content-Type", "text/plain; charset=utf-8"); in sendHttpMessage() [all …]
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
D | StreamAllocation.java | 81 private RealConnection connection; field in StreamAllocation 156 RealConnection allocatedConnection = this.connection; in findConnection() 164 this.connection = pooledConnection; in findConnection() 180 this.connection = newConnection; in findConnection() 210 public synchronized RealConnection connection() { in connection() method in StreamAllocation 211 return connection; in connection() 236 if (connection != null) { in deallocate() 238 connection.noNewStreams = true; in deallocate() 240 if (this.stream == null && (this.released || connection.noNewStreams)) { in deallocate() 241 release(connection); in deallocate() [all …]
|
/external/conscrypt/openjdk-integ-tests/src/test/java/libcore/javax/net/ssl/ |
D | HttpsURLConnectionTest.java | 50 HttpsURLConnection connection = in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() local 53 assertSame(originalHostnameVerifier, connection.getHostnameVerifier()); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 55 connection.disconnect(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 61 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 63 assertSame(anotherVerifier, connection.getHostnameVerifier()); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 65 connection.disconnect(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 69 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 71 assertSame(originalHostnameVerifier, connection.getHostnameVerifier()); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 73 connection.disconnect(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() 88 HttpsURLConnection connection = in testDefaultSSLSocketFactoryUsedForNewConnectionsByDefault() local [all …]
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
D | FramedStream.java | 56 private final FramedConnection connection; field in FramedStream 76 FramedStream(int id, FramedConnection connection, boolean outFinished, boolean inFinished, in FramedStream() argument 78 if (connection == null) throw new NullPointerException("connection == null"); in FramedStream() 81 this.connection = connection; in FramedStream() 83 connection.peerSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE); in FramedStream() 85 connection.okHttpSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE)); in FramedStream() 121 return connection.client == streamIsClient; in isLocallyInitiated() 125 return connection; in getConnection() 179 connection.writeSynReply(id, outFinished, responseHeaders); in reply() 182 connection.flush(); in reply() [all …]
|
/external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
D | ConscryptSocketTest.java | 307 TestConnection connection = new TestConnection(new X509Certificate[] {cert, ca}, certKey); in test_handshake() local 308 connection.doHandshake(); in test_handshake() 310 assertTrue(connection.clientHooks.isHandshakeCompleted); in test_handshake() 311 assertTrue(connection.serverHooks.isHandshakeCompleted); in test_handshake() 316 TestConnection connection = in test_handshakeWithEmbeddedSCT() local 319 connection.doHandshake(); in test_handshakeWithEmbeddedSCT() 321 assertTrue(connection.clientHooks.isHandshakeCompleted); in test_handshakeWithEmbeddedSCT() 322 assertTrue(connection.serverHooks.isHandshakeCompleted); in test_handshakeWithEmbeddedSCT() 327 TestConnection connection = new TestConnection(new X509Certificate[] {cert, ca}, certKey); in test_handshakeWithSCTFromOCSPResponse() local 329 connection.serverHooks.ocspResponse = readTestFile("ocsp-response.der"); in test_handshakeWithSCTFromOCSPResponse() [all …]
|
/external/webrtc/webrtc/p2p/base/ |
D | p2ptransportchannel.cc | 261 void P2PTransportChannel::AddConnection(Connection* connection) { in AddConnection() argument 262 connections_.push_back(connection); in AddConnection() 263 connection->set_remote_ice_mode(remote_ice_mode_); in AddConnection() 264 connection->set_receiving_timeout(receiving_timeout_); in AddConnection() 265 connection->SignalReadPacket.connect( in AddConnection() 267 connection->SignalReadyToSend.connect( in AddConnection() 269 connection->SignalStateChange.connect( in AddConnection() 271 connection->SignalDestroyed.connect( in AddConnection() 273 connection->SignalNominated.connect(this, &P2PTransportChannel::OnNominated); in AddConnection() 311 for (Connection* connection : connections_) { in ComputeState() [all …]
|
/external/oauth/core/src/main/java/net/oauth/client/ |
D | URLConnectionResponse.java | 44 byte[] requestExcerpt, URLConnection connection) throws IOException { in URLConnectionResponse() argument 49 this.connection = connection; in URLConnectionResponse() 56 private final URLConnection connection; field in URLConnectionResponse 60 if (connection instanceof HttpURLConnection) { in getStatusCode() 61 return ((HttpURLConnection) connection).getResponseCode(); in getStatusCode() 69 return connection.getInputStream(); in openBody() 79 for (int i = 0; (value = connection.getHeaderField(i)) != null; ++i) { in getHeaders() 80 String name = connection.getHeaderFieldKey(i); in getHeaders() 89 headers.add(new OAuth.Parameter(CONTENT_TYPE, connection in getHeaders() 107 …HttpURLConnection http = (connection instanceof HttpURLConnection) ? (HttpURLConnection) connection in dump() [all …]
|
/external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
D | OkUrlFactoryTest.java | 68 HttpURLConnection connection = factory.open(server.getUrl("/")); in networkResponseSourceHeader() local 69 assertResponseHeader(connection, "NETWORK 200"); in networkResponseSourceHeader() 70 assertResponseBody(connection, "Isla Sorna"); in networkResponseSourceHeader() 76 HttpURLConnection connection = factory.open(server.getUrl("/")); in networkFailureResponseSourceHeader() local 77 assertResponseHeader(connection, "NETWORK 404"); in networkFailureResponseSourceHeader() 78 connection.getErrorStream().close(); in networkFailureResponseSourceHeader() 148 HttpURLConnection connection = factory.open(server.getUrl("/a")); in setInstanceFollowRedirectsFalse() local 149 connection.setInstanceFollowRedirects(false); in setInstanceFollowRedirectsFalse() 150 assertResponseBody(connection, "A"); in setInstanceFollowRedirectsFalse() 151 assertResponseCode(connection, 302); in setInstanceFollowRedirectsFalse() [all …]
|
/external/skia/tools/skiaserve/urlhandlers/ |
D | UrlHandler.h | 19 virtual int handle(Request* request, MHD_Connection* connection, 27 int handle(Request* request, MHD_Connection* connection, 35 int handle(Request* request, MHD_Connection* connection, 43 int handle(Request* request, MHD_Connection* connection, 55 int handle(Request* request, MHD_Connection* connection, 67 int handle(Request* request, MHD_Connection* connection, 79 int handle(Request* request, MHD_Connection* connection, 87 int handle(Request* request, MHD_Connection* connection, 95 int handle(Request* request, MHD_Connection* connection, 103 int handle(Request* request, MHD_Connection* connection, [all …]
|
/external/libmojo/mojo/public/js/ |
D | connection.js | 93 var connection = new BaseConnection(undefined, proxy, router); 94 ProxyBindings(proxy).connection = connection; 115 var connection = new BaseConnection(stub, undefined, router); 116 StubBindings(stub).connection = connection; 131 var connection = new BaseConnection(undefined, proxy, router); 132 ProxyBindings(proxy).connection = connection; 146 var connection = new BaseConnection(stub, undefined, router); 147 StubBindings(stub).connection = connection; 161 var connection = new BaseConnection(obj, undefined, router); 162 obj.connection = connection;
|