/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
|