| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | AsyncFrameWriter.java | 40 private FrameWriter frameWriter; field in AsyncFrameWriter
63 void becomeConnected(FrameWriter frameWriter, Socket socket) { in becomeConnected() argument
64 Preconditions.checkState(this.frameWriter == null, in becomeConnected()
66 this.frameWriter = Preconditions.checkNotNull(frameWriter, "frameWriter"); in becomeConnected()
75 frameWriter.connectionPreface(); in connectionPreface()
85 frameWriter.ackSettings(peerSettings); in ackSettings()
96 frameWriter.pushPromise(streamId, promisedStreamId, requestHeaders); in pushPromise()
112 frameWriter.flush(); in flush()
124 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, headerBlock); in synStream()
135 frameWriter.synReply(outFinished, streamId, headerBlock); in synReply()
[all …]
|
| D | OkHttpClientStream.java | 68 AsyncFrameWriter frameWriter, in OkHttpClientStream() argument
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow, in OkHttpClientStream()
200 private final AsyncFrameWriter frameWriter; field in OkHttpClientStream.TransportState
210 AsyncFrameWriter frameWriter, in TransportState() argument
215 this.frameWriter = frameWriter; in TransportState()
228 frameWriter.synStream(useGet, false, id, 0, requestHeaders); in start()
274 frameWriter.windowUpdate(id(), delta); in bytesRead()
315 frameWriter.rstStream(id(), ErrorCode.FLOW_CONTROL_ERROR); in transportDataReceived()
|
| D | OutboundFlowController.java | 39 private final FrameWriter frameWriter; field in OutboundFlowController
43 OutboundFlowController(OkHttpClientTransport transport, FrameWriter frameWriter) { in OutboundFlowController() argument
45 this.frameWriter = Preconditions.checkNotNull(frameWriter, "frameWriter"); in OutboundFlowController()
152 frameWriter.flush(); in flush()
382 int frameBytes = min(bytesToWrite, frameWriter.maxDataLength()); in write()
388 frameWriter.data(endStream, streamId, data, bytesToWrite); in write()
|
| D | OkHttpClientTransport.java | 144 private AsyncFrameWriter frameWriter; field in OkHttpClientTransport
301 checkState(frameWriter != null); in ping()
326 frameWriter.ping(false, (int) (data >>> 32), (int) data); in ping()
342 frameWriter, in newStream()
376 frameWriter.flush(); in startStream()
424 frameWriter = new AsyncFrameWriter(this, serializingExecutor); in start()
425 outboundFlow = new OutboundFlowController(this, frameWriter); in start()
441 frameWriter.becomeConnected(testFrameWriter, socket); in start()
514 frameWriter.becomeConnected(rawFrameWriter, socket); in start()
757 frameWriter.goAway(0, errorCode, new byte[0]); in startGoAway()
[all …]
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | AsyncFrameWriterTest.java | 47 @Mock private FrameWriter frameWriter; field in AsyncFrameWriterTest
57 asyncFrameWriter.becomeConnected(frameWriter, socket); in setUp()
66 verify(frameWriter, times(1)).ping(anyBoolean(), anyInt(), anyInt()); in noCoalesceRequired()
67 verify(frameWriter, times(1)).flush(); in noCoalesceRequired()
80 verify(frameWriter, times(2)).ping(anyBoolean(), anyInt(), anyInt()); in flushCoalescing_shouldNotMergeTwoDistinctFlushes()
81 verify(frameWriter, times(2)).flush(); in flushCoalescing_shouldNotMergeTwoDistinctFlushes()
93 InOrder inOrder = inOrder(frameWriter); in flushCoalescing_shouldMergeTwoQueuedFlushes()
94 inOrder.verify(frameWriter, times(2)).ping(anyBoolean(), anyInt(), anyInt()); in flushCoalescing_shouldMergeTwoQueuedFlushes()
95 inOrder.verify(frameWriter).flush(); in flushCoalescing_shouldMergeTwoQueuedFlushes()
|
| D | OkHttpClientStreamTest.java | 61 @Mock private AsyncFrameWriter frameWriter; field in OkHttpClientStreamTest
85 frameWriter, in setUp()
143 verifyNoMoreInteractions(frameWriter); in start_alreadyCancelled()
150 stream = new OkHttpClientStream(methodDescriptor, metaData, frameWriter, transport, in start_userAgentRemoved()
156 verify(frameWriter).synStream(eq(false), eq(false), eq(3), eq(0), headersCaptor.capture()); in start_userAgentRemoved()
165 stream = new OkHttpClientStream(methodDescriptor, metaData, frameWriter, transport, in start_headerFieldOrder()
171 verify(frameWriter).synStream(eq(false), eq(false), eq(3), eq(0), headersCaptor.capture()); in start_headerFieldOrder()
193 stream = new OkHttpClientStream(getMethod, new Metadata(), frameWriter, transport, in getUnaryRequest()
199 verify(frameWriter, times(0)).synStream( in getUnaryRequest()
209 verify(frameWriter) in getUnaryRequest()
|
| D | OkHttpClientTransportTest.java | 141 private FrameWriter frameWriter; field in OkHttpClientTransportTest
167 when(frameWriter.maxDataLength()).thenReturn(Integer.MAX_VALUE); in setUp()
209 frameWriter, in startTransport()
377 verify(frameWriter, timeout(TIME_OUT_MS)) in receivedHeadersForInvalidStreamShouldKillConnection()
388 verify(frameWriter, timeout(TIME_OUT_MS)) in receivedDataForInvalidStreamShouldKillConnection()
410 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in invalidInboundHeadersCancelStream()
477 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in cancelStream()
497 verify(frameWriter, timeout(TIME_OUT_MS)) in addDefaultUserAgent()
516 verify(frameWriter, timeout(TIME_OUT_MS)) in overrideDefaultUserAgent()
530 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in cancelStreamForDeadlineExceeded()
[all …]
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | FramedConnection.java | 126 final FrameWriter frameWriter; field in FramedConnection
171 frameWriter = variant.newWriter(builder.sink, client); in FramedConnection()
259 synchronized (frameWriter) { in newStream()
273 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
278 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders); in newStream()
283 frameWriter.flush(); in newStream()
291 frameWriter.synReply(outFinished, streamId, alternating); in writeSynReply()
309 frameWriter.data(outFinished, streamId, buffer, 0); in writeData()
330 toWrite = Math.min(toWrite, frameWriter.maxDataLength()); in writeData()
335 frameWriter.data(outFinished && byteCount == 0, streamId, buffer, toWrite); in writeData()
[all …]
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | FramedConnection.java | 128 final FrameWriter frameWriter; field in FramedConnection
173 frameWriter = variant.newWriter(builder.sink, client); in FramedConnection()
261 synchronized (frameWriter) { in newStream()
275 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
280 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders); in newStream()
285 frameWriter.flush(); in newStream()
293 frameWriter.synReply(outFinished, streamId, alternating); in writeSynReply()
311 frameWriter.data(outFinished, streamId, buffer, 0); in writeData()
332 toWrite = Math.min(toWrite, frameWriter.maxDataLength()); in writeData()
337 frameWriter.data(outFinished && byteCount == 0, streamId, buffer, toWrite); in writeData()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | MockSpdyPeer.java | 49 private FrameWriter frameWriter = variant.newWriter(bytesOut, client); field in MockSpdyPeer
64 this.frameWriter = variant.newWriter(bytesOut, client); in setVariantAndClient()
73 return frameWriter.maxDataLength(); in maxOutboundDataLength()
83 return frameWriter; in sendFrame()
112 return frameWriter; in truncateLastFrame()
|
| D | Http2ConnectionTest.java | 174 assertEquals(newMaxFrameSize, connection.frameWriter.maxDataLength());
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 89 private Http2FrameWriter frameWriter; field in NettyHandlerTestBase
116 frameWriter = mock(Http2FrameWriter.class, delegatesTo(new DefaultHttp2FrameWriter())); in initChannel()
218 protected final Http2FrameWriter frameWriter() { in frameWriter() method in NettyHandlerTestBase
219 return frameWriter; in frameWriter()
235 return verify(frameWriter); in verifyWrite()
239 return verify(frameWriter, verificationMode); in verifyWrite()
|
| D | NettyClientHandlerTest.java | 717 frameWriter(), in newHandler()
|
| D | NettyServerHandlerTest.java | 1064 frameWriter(), in newHandler()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 125 Http2FrameWriter frameWriter = new DefaultHttp2FrameWriter(); in newHandler() local
136 frameWriter, in newHandler()
152 Http2FrameWriter frameWriter, in newHandler() argument
174 frameWriter = new Http2OutboundFrameLogger(frameWriter, frameLogger); in newHandler()
177 new DefaultHttp2ConnectionEncoder(connection, frameWriter)); in newHandler()
|
| D | NettyServerHandler.java | 153 Http2FrameWriter frameWriter = in newHandler() local
158 frameWriter, in newHandler()
179 Http2FrameWriter frameWriter, in newHandler() argument
211 frameWriter = new WriteMonitoringFrameWriter(frameWriter, keepAliveEnforcer); in newHandler()
212 Http2ConnectionEncoder encoder = new DefaultHttp2ConnectionEncoder(connection, frameWriter); in newHandler()
|
| D | AbstractNettyHandler.java | 169 frameWriter().writeSettings(ctx(), settings, ctx().newPromise()); in updateWindow()
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsProtocolNegotiatorTest.java | 390 Http2FrameWriter frameWriter = new DefaultHttp2FrameWriter(); in capturingGrpcHandler() local
393 new DefaultHttp2ConnectionEncoder(connection, frameWriter); in capturingGrpcHandler()
|