| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocketCall.java | 147 StreamAllocation streamAllocation = Internal.instance.callEngineGetStreamAllocation(call); in createWebSocket() local
149 streamAllocation, response, random, listener); in createWebSocket()
159 static RealWebSocket create(StreamAllocation streamAllocation, Response response, in create() argument
167 return new StreamWebSocket(streamAllocation, random, replyExecutor, listener, url); in create()
170 private final StreamAllocation streamAllocation; field in WebSocketCall.StreamWebSocket
173 private StreamWebSocket(StreamAllocation streamAllocation, in StreamWebSocket() argument
175 super(true /* is client */, streamAllocation.connection().source, in StreamWebSocket()
176 streamAllocation.connection().sink, random, replyExecutor, listener, url); in StreamWebSocket()
177 this.streamAllocation = streamAllocation; in StreamWebSocket()
183 streamAllocation.noNewStreams(); in close()
[all …]
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| D | Http1xStream.java | 71 private final StreamAllocation streamAllocation; field in Http1xStream
77 public Http1xStream(StreamAllocation streamAllocation, BufferedSource source, BufferedSink sink) { in Http1xStream() argument
78 this.streamAllocation = streamAllocation; in Http1xStream()
103 RealConnection connection = streamAllocation.connection(); in cancel()
201 IOException exception = new IOException("unexpected end of stream on " + streamAllocation); in readResponse()
249 if (streamAllocation == null) throw new IllegalStateException("streamAllocation == null"); in newUnknownLengthSource()
251 streamAllocation.noNewStreams(); in newUnknownLengthSource()
361 if (streamAllocation != null) { in endOfInput()
362 streamAllocation.streamFinished(Http1xStream.this); in endOfInput()
370 if (streamAllocation != null) { in unexpectedEndOfInput()
[all …]
|
| D | HttpEngine.java | 108 public final StreamAllocation streamAllocation; field in HttpEngine
173 boolean callerWritesRequestBody, boolean forWebSocket, StreamAllocation streamAllocation, in HttpEngine() argument
180 this.streamAllocation = streamAllocation != null in HttpEngine()
181 ? streamAllocation in HttpEngine()
281 return streamAllocation.newStream(client.getConnectTimeout(), in connect()
337 return streamAllocation.connection(); in getConnection()
346 if (!streamAllocation.recover(e)) { in recover()
354 StreamAllocation streamAllocation = close(); in recover() local
358 forWebSocket, streamAllocation, (RetryableSink) requestBodyOut, priorResponse); in recover()
368 if (!streamAllocation.recover(e, requestBodyOut)) { in recover()
[all …]
|
| D | Http2xStream.java | 108 private final StreamAllocation streamAllocation; field in Http2xStream
113 public Http2xStream(StreamAllocation streamAllocation, FramedConnection framedConnection) { in Http2xStream() argument
114 this.streamAllocation = streamAllocation; in Http2xStream()
292 streamAllocation.streamFinished(Http2xStream.this); in close()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | Call.java | 316 StreamAllocation streamAllocation = engine.close(); in getResponse() local
317 streamAllocation.release(); in getResponse()
331 StreamAllocation streamAllocation = engine.close(); in getResponse() local
334 streamAllocation.release(); in getResponse()
339 streamAllocation.release(); in getResponse()
340 streamAllocation = null; in getResponse()
344 engine = new HttpEngine(client, request, false, false, forWebSocket, streamAllocation, null, in getResponse()
|
| D | ConnectionPool.java | 171 RealConnection get(Address address, StreamAllocation streamAllocation) { in get() argument
179 streamAllocation.acquire(connection); in get()
|
| D | OkHttpClient.java | 84 ConnectionPool pool, Address address, StreamAllocation streamAllocation) {
85 return pool.get(address, streamAllocation);
102 return call.engine.streamAllocation;
|
| /external/okhttp/okhttp-urlconnection/src/main/java/com/squareup/okhttp/internal/huc/ |
| D | HttpURLConnectionImpl.java | 339 private HttpEngine newHttpEngine(String method, StreamAllocation streamAllocation, in newHttpEngine() argument
385 return new HttpEngine(engineClient, request, bufferRequestBody, true, false, streamAllocation, in newHttpEngine()
439 StreamAllocation streamAllocation = httpEngine.close(); in getResponse() local
441 streamAllocation.release(); in getResponse()
442 streamAllocation = null; in getResponse()
445 httpEngine = newHttpEngine(followUp.method(), streamAllocation, (RetryableSink) requestBody, in getResponse()
509 StreamAllocation streamAllocation = httpEngine.close(); in execute() local
510 streamAllocation.release(); in execute()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | ConnectionPoolTest.java | 84 StreamAllocation streamAllocation = new StreamAllocation(pool, addressA); in inUseConnectionsNotEvicted() local
85 streamAllocation.acquire(c1); in inUseConnectionsNotEvicted()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| D | Internal.java | 57 ConnectionPool pool, Address address, StreamAllocation streamAllocation); in get() argument
|