Searched refs:OkHttpClientStream (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OutboundFlowController.java | 64 for (OkHttpClientStream stream : transport.getActiveStreams()) { in initialOutboundWindowSize()
84 int windowUpdate(@Nullable OkHttpClientStream stream, int delta) { in windowUpdate()
110 OkHttpClientStream stream = transport.getStream(streamId); in data()
158 private OutboundFlowState state(OkHttpClientStream stream) { in state()
173 OkHttpClientStream[] streams = transport.getActiveStreams(); in writeStreams()
179 OkHttpClientStream stream = streams[index]; in writeStreams()
199 for (OkHttpClientStream stream : transport.getActiveStreams()) { in writeStreams()
234 OkHttpClientStream stream;
241 OutboundFlowState(OkHttpClientStream stream) { in OutboundFlowState()
|
| D | OkHttpClientTransport.java | 105 private static final OkHttpClientStream[] EMPTY_STREAM_ARRAY = new OkHttpClientStream[0];
151 private final Map<Integer, OkHttpClientStream> streams =
152 new HashMap<Integer, OkHttpClientStream>();
182 private LinkedList<OkHttpClientStream> pendingStreams = new LinkedList<OkHttpClientStream>();
334 public OkHttpClientStream newStream(final MethodDescriptor<?, ?> method, in newStream()
339 return new OkHttpClientStream( in newStream()
354 void streamReadyToStart(OkHttpClientStream clientStream) { in streamReadyToStart()
367 private void startStream(OkHttpClientStream stream) { in startStream()
369 stream.id() == OkHttpClientStream.ABSENT_ID, "StreamId already assigned"); in startStream()
396 OkHttpClientStream stream = pendingStreams.poll(); in startPendingStreams()
[all …]
|
| D | OkHttpClientStream.java | 44 class OkHttpClientStream extends AbstractClientStream { class
65 OkHttpClientStream( in OkHttpClientStream() method in OkHttpClientStream
213 super(maxMessageSize, statsTraceCtx, OkHttpClientStream.this.getTransportTracer()); in TransportState()
345 transport.removePendingStream(OkHttpClientStream.this); in cancel()
380 transport.streamReadyToStart(OkHttpClientStream.this); in streamReady()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 250 OkHttpClientStream stream = in maxMessageSizeShouldBeEnforced()
276 OkHttpClientStream stream1 = in nextFrameThrowIoException()
280 OkHttpClientStream stream2 = in nextFrameThrowIoException()
310 OkHttpClientStream stream = in nextFrameThrowsError()
331 OkHttpClientStream stream = in nextFrameReturnFalse()
349 OkHttpClientStream stream = in readMessages()
399 OkHttpClientStream stream = in invalidInboundHeadersCancelStream()
423 OkHttpClientStream stream = in invalidInboundTrailersPropagateToMetadata()
443 OkHttpClientStream stream = in readStatus()
457 OkHttpClientStream stream = in receiveReset()
[all …]
|
| D | OkHttpClientStreamTest.java | 70 private OkHttpClientStream stream;
82 stream = new OkHttpClientStream( in setUp()
150 stream = new OkHttpClientStream(methodDescriptor, metaData, frameWriter, transport, in start_userAgentRemoved()
165 stream = new OkHttpClientStream(methodDescriptor, metaData, frameWriter, transport, in start_headerFieldOrder()
193 stream = new OkHttpClientStream(getMethod, new Metadata(), frameWriter, transport, in getUnaryRequest()
201 verify(transport, times(0)).streamReadyToStart(isA(OkHttpClientStream.class)); in getUnaryRequest()
|