| /external/volley/src/main/java/com/android/volley/toolbox/ |
| D | HurlStack.java | 88 HttpURLConnection connection = openConnection(parsedUrl, request); in executeRequest() local
92 connection.setRequestProperty(headerName, map.get(headerName)); in executeRequest()
94 setConnectionParametersForRequest(connection, request); in executeRequest()
96 int responseCode = connection.getResponseCode(); in executeRequest()
104 return new HttpResponse(responseCode, convertHeaders(connection.getHeaderFields())); in executeRequest()
112 convertHeaders(connection.getHeaderFields()), in executeRequest()
113 connection.getContentLength(), in executeRequest()
114 new UrlConnectionInputStream(connection)); in executeRequest()
117 connection.disconnect(); in executeRequest()
159 UrlConnectionInputStream(HttpURLConnection connection) { in UrlConnectionInputStream() argument
[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/ |
| 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-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/ksoap2/ksoap2-j2se/src/main/java/org/ksoap2/transport/ |
| D | HttpsServiceConnectionSE.java | 38 private HttpsURLConnection connection; field in HttpsServiceConnectionSE
68 connection = (HttpsURLConnection) new URL(HttpsTransportSE.PROTOCOL, host, port, in HttpsServiceConnectionSE()
71 connection = in HttpsServiceConnectionSE()
80 connection.setConnectTimeout(timeout); in updateConnectionParameters()
81 connection.setReadTimeout( in updateConnectionParameters()
83 connection.setUseCaches(false); in updateConnectionParameters()
84 connection.setDoOutput(true); in updateConnectionParameters()
85 connection.setDoInput(true); in updateConnectionParameters()
89 connection.connect(); in connect()
93 connection.disconnect(); in disconnect()
[all …]
|
| D | ServiceConnectionSE.java | 39 private HttpURLConnection connection; field in ServiceConnectionSE
66 connection = (proxy == null) in ServiceConnectionSE()
69 connection.setUseCaches(false); in ServiceConnectionSE()
70 connection.setDoOutput(true); in ServiceConnectionSE()
71 connection.setDoInput(true); in ServiceConnectionSE()
72 connection.setConnectTimeout(timeout); in ServiceConnectionSE()
73 connection.setReadTimeout( in ServiceConnectionSE()
78 connection.connect(); in connect()
82 connection.disconnect(); in disconnect()
88 Map properties = connection.getHeaderFields(); in getResponseProperties()
[all …]
|
| D | HttpTransportSE.java | 156 ServiceConnection connection = getServiceConnection(); in call() local
158 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()
174 connection.setRequestProperty("Accept-Encoding", "gzip"); in call()
181 connection.setRequestProperty(hp.getKey(), hp.getValue()); in call()
185 connection.setRequestMethod("POST"); in call()
186 sendData(requestData, connection, envelope); in call()
194 int status = connection.getResponseCode(); in call()
[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/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | ConnectionPool.java | 140 for (RealConnection connection : connections) { in getIdleConnectionCount()
141 if (connection.allocations.isEmpty()) total++; in getIdleConnectionCount()
165 for (RealConnection connection : connections) { in getMultiplexedConnectionCount()
166 if (connection.isMultiplexed()) total++; in getMultiplexedConnectionCount()
179 for (RealConnection connection : connections) { in get()
182 if (connection.allocations.size() < connection.allocationLimit() in get()
183 && address.equals(connection.getRoute().address) in get()
184 && !connection.noNewStreams) { in get()
185 streamAllocation.acquire(connection); in get()
186 return connection; in get()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | publish.cpp | 187 rx::composite_subscription connection; variable
190 [connection, &ys](const rxsc::schedulable&){ in __anon7a8c47411502()
191 ys.connect(connection); in __anon7a8c47411502()
194 [connection](const rxsc::schedulable&){ in __anon7a8c47411602()
195 connection.unsubscribe(); in __anon7a8c47411602()
200 rx::composite_subscription connection; variable
203 [connection, &ys](const rxsc::schedulable&){ in __anon7a8c47411702()
204 ys.connect(connection); in __anon7a8c47411702()
207 [connection](const rxsc::schedulable&){ in __anon7a8c47411802()
208 connection.unsubscribe(); in __anon7a8c47411802()
[all …]
|
| D | replay.cpp | 49 rx::composite_subscription connection; variable
52 [connection, &ys](const rxsc::schedulable&){ in __anondb524a570402()
53 ys.connect(connection); in __anondb524a570402()
56 [connection](const rxsc::schedulable&){ in __anondb524a570502()
57 connection.unsubscribe(); in __anondb524a570502()
62 rx::composite_subscription connection; variable
65 [connection, &ys](const rxsc::schedulable&){ in __anondb524a570602()
66 ys.connect(connection); in __anondb524a570602()
69 [connection](const rxsc::schedulable&){ in __anondb524a570702()
70 connection.unsubscribe(); in __anondb524a570702()
[all …]
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/ |
| D | StreamAllocation.java | 83 private RealConnection connection; field in StreamAllocation
158 RealConnection allocatedConnection = this.connection; in findConnection()
166 this.connection = pooledConnection; in findConnection()
182 this.connection = newConnection; in findConnection()
212 public synchronized RealConnection connection() { in connection() method in StreamAllocation
213 return connection; in connection()
238 if (connection != null) { in deallocate()
240 connection.noNewStreams = true; in deallocate()
242 if (this.stream == null && (this.released || connection.noNewStreams)) { in deallocate()
243 release(connection); in deallocate()
[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/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/conscrypt/repackaged/openjdk-integ-tests/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | HttpsURLConnectionTest.java | 54 HttpsURLConnection connection = in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() local
57 assertSame(originalHostnameVerifier, connection.getHostnameVerifier()); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
59 connection.disconnect(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
65 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
67 assertSame(anotherVerifier, connection.getHostnameVerifier()); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
69 connection.disconnect(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
73 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
75 assertSame(originalHostnameVerifier, connection.getHostnameVerifier()); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
77 connection.disconnect(); in testDefaultHostnameVerifierUsedForNewConnectionsByDefault()
92 HttpsURLConnection connection = in testDefaultSSLSocketFactoryUsedForNewConnectionsByDefault() local
[all …]
|
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/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/wayland/src/ |
| D | connection.c | 164 struct wl_connection *connection; in wl_connection_create() local
166 connection = zalloc(sizeof *connection); in wl_connection_create()
167 if (connection == NULL) in wl_connection_create()
170 connection->fd = fd; in wl_connection_create()
172 return connection; in wl_connection_create()
195 wl_connection_destroy(struct wl_connection *connection) in wl_connection_destroy() argument
197 int fd = connection->fd; in wl_connection_destroy()
199 close_fds(&connection->fds_out, -1); in wl_connection_destroy()
200 close_fds(&connection->fds_in, -1); in wl_connection_destroy()
201 free(connection); in wl_connection_destroy()
[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/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | FramedStream.java | 58 private final FramedConnection connection; field in FramedStream
78 FramedStream(int id, FramedConnection connection, boolean outFinished, boolean inFinished, in FramedStream() argument
80 if (connection == null) throw new NullPointerException("connection == null"); in FramedStream()
83 this.connection = connection; in FramedStream()
85 connection.peerSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE); in FramedStream()
87 connection.okHttpSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE)); in FramedStream()
123 return connection.client == streamIsClient; in isLocallyInitiated()
127 return connection; in getConnection()
181 connection.writeSynReply(id, outFinished, responseHeaders); in reply()
184 connection.flush(); in reply()
[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/python/cpython2/Modules/_sqlite/ |
| D | cursor.c | 73 pysqlite_Connection* connection; in pysqlite_cursor_init() local
75 if (!PyArg_ParseTuple(args, "O!", &pysqlite_ConnectionType, &connection)) in pysqlite_cursor_init()
80 Py_INCREF(connection); in pysqlite_cursor_init()
81 Py_XSETREF(self->connection, connection); in pysqlite_cursor_init()
105 if (!pysqlite_check_thread(self->connection)) { in pysqlite_cursor_init()
109 if (!pysqlite_connection_register_cursor(connection, (PyObject*)self)) { in pysqlite_cursor_init()
126 Py_XDECREF(self->connection); in pysqlite_cursor_dealloc()
168 if (!self->connection->detect_types) { in pysqlite_build_row_cast_map()
177 if (self->connection->detect_types & PARSE_COLNAMES) { in pysqlite_build_row_cast_map()
200 if (!converter && self->connection->detect_types & PARSE_DECLTYPES) { in pysqlite_build_row_cast_map()
[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/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 …]
|