Home
last modified time | relevance | path

Searched refs:connection (Results 1 – 25 of 1021) sorted by relevance

12345678910>>...41

/external/libmicrohttpd/src/microhttpd/
Dconnection.c128 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 …]
Dconnection_https.c46 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 …]
Ddigestauth.c301 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 …]
Dtest_postprocessor.c124 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/
DHurlStack.java103 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/
Dmhd2spdy_spdy.c146 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/
DCacheAdapterTest.java65 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/
DSpdy3ConnectionTest.java77 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 …]
DHttp2ConnectionTest.java67 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 …]
DHttpOverSpdyTest.java77 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/
DURLConnectionTest.java110 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/
DConnectionPool.java134 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/
DHttpsServiceConnectionSE.java41 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 …]
DServiceConnectionSE.java39 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 …]
DHttpTransportSE.java153 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/
DAsyncHttpURLConnection.java64 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/
DStreamAllocation.java81 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/
DHttpsURLConnectionTest.java50 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/
DFramedStream.java56 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/
DConscryptSocketTest.java307 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/
Dp2ptransportchannel.cc261 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/
DURLConnectionResponse.java44 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/
DOkUrlFactoryTest.java68 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/
DUrlHandler.h19 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/
Dconnection.js93 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;

12345678910>>...41