| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| AsyncFrameWriter.java | 22 import io.grpc.okhttp.internal.framed.FrameWriter;
33 class AsyncFrameWriter implements FrameWriter {
35 private FrameWriter frameWriter;
50 * Set the real frameWriter and the corresponding underlying socket, the socket is needed for
55 void becomeConnected(FrameWriter frameWriter, Socket socket) {
56 Preconditions.checkState(this.frameWriter == null,
58 this.frameWriter = Preconditions.checkNotNull(frameWriter, "frameWriter")
[all...] |
| OutboundFlowController.java | 26 import io.grpc.okhttp.internal.framed.FrameWriter;
39 private final FrameWriter frameWriter;
43 OutboundFlowController(OkHttpClientTransport transport, FrameWriter frameWriter) {
45 this.frameWriter = Preconditions.checkNotNull(frameWriter, "frameWriter");
152 frameWriter.flush();
382 int frameBytes = min(bytesToWrite, frameWriter.maxDataLength())
[all...] |
| OkHttpClientStream.java | 68 AsyncFrameWriter frameWriter,
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow,
200 private final AsyncFrameWriter frameWriter;
210 AsyncFrameWriter frameWriter,
215 this.frameWriter = frameWriter;
228 frameWriter.synStream(useGet, false, id, 0, requestHeaders);
274 frameWriter.windowUpdate(id(), delta);
315 frameWriter.rstStream(id(), ErrorCode.FLOW_CONTROL_ERROR);
371 // If buffer > frameWriter.maxDataLength() the flow-controller will ensure that it i
[all...] |
| OkHttpClientTransport.java | 62 import io.grpc.okhttp.internal.framed.FrameWriter;
144 private AsyncFrameWriter frameWriter;
184 private FrameWriter testFrameWriter;
239 FrameWriter testFrameWriter,
301 checkState(frameWriter != null);
326 frameWriter.ping(false, (int) (data >>> 32), (int) data);
342 frameWriter,
376 frameWriter.flush();
424 frameWriter = new AsyncFrameWriter(this, serializingExecutor);
425 outboundFlow = new OutboundFlowController(this, frameWriter);
[all...] |
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| AsyncFrameWriterTest.java | 27 import io.grpc.okhttp.internal.framed.FrameWriter;
44 @Mock private FrameWriter frameWriter;
54 asyncFrameWriter.becomeConnected(frameWriter, socket);
63 verify(frameWriter, times(1)).ping(anyBoolean(), anyInt(), anyInt());
64 verify(frameWriter, times(1)).flush();
77 verify(frameWriter, times(2)).ping(anyBoolean(), anyInt(), anyInt());
78 verify(frameWriter, times(2)).flush();
90 InOrder inOrder = inOrder(frameWriter);
91 inOrder.verify(frameWriter, times(2)).ping(anyBoolean(), anyInt(), anyInt())
[all...] |
| OkHttpClientStreamTest.java | 61 @Mock private AsyncFrameWriter frameWriter;
85 frameWriter,
143 verifyNoMoreInteractions(frameWriter);
150 stream = new OkHttpClientStream(methodDescriptor, metaData, frameWriter, transport,
156 verify(frameWriter).synStream(eq(false), eq(false), eq(3), eq(0), headersCaptor.capture());
165 stream = new OkHttpClientStream(methodDescriptor, metaData, frameWriter, transport,
171 verify(frameWriter).synStream(eq(false), eq(false), eq(3), eq(0), headersCaptor.capture());
193 stream = new OkHttpClientStream(getMethod, new Metadata(), frameWriter, transport,
199 verify(frameWriter, times(0)).synStream(
209 verify(frameWriter)
[all...] |
| OkHttpClientTransportTest.java | 80 import io.grpc.okhttp.internal.framed.FrameWriter;
141 private FrameWriter frameWriter;
167 when(frameWriter.maxDataLength()).thenReturn(Integer.MAX_VALUE);
209 frameWriter,
377 verify(frameWriter, timeout(TIME_OUT_MS))
388 verify(frameWriter, timeout(TIME_OUT_MS))
410 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL));
477 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL));
497 verify(frameWriter, timeout(TIME_OUT_MS)
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| FramedConnection.java | 60 // Socket writes are guarded by frameWriter.
65 // frameWriter (to do blocking I/O) and this (to create streams). Such
126 final FrameWriter frameWriter;
171 frameWriter = variant.newWriter(builder.sink, client);
259 synchronized (frameWriter) {
273 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId,
278 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders);
283 frameWriter.flush();
291 frameWriter.synReply(outFinished, streamId, alternating)
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| FramedConnection.java | 62 // Socket writes are guarded by frameWriter.
67 // frameWriter (to do blocking I/O) and this (to create streams). Such
128 final FrameWriter frameWriter;
173 frameWriter = variant.newWriter(builder.sink, client);
261 synchronized (frameWriter) {
275 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId,
280 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders);
285 frameWriter.flush();
293 frameWriter.synReply(outFinished, streamId, alternating)
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| MockSpdyPeer.java | 47 private FrameWriter frameWriter = variant.newWriter(bytesOut, client);
62 this.frameWriter = variant.newWriter(bytesOut, client);
71 return frameWriter.maxDataLength();
79 public FrameWriter sendFrame() {
81 return frameWriter;
98 public FrameWriter truncateLastFrame(int length) {
110 return frameWriter;
|
| Http2ConnectionTest.java | 150 // TODO: when supported, check the frameWriter's compression table is unaffected.
173 assertEquals(newMaxFrameSize, connection.frameWriter.maxDataLength());
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| NettyHandlerTestBase.java | 89 private Http2FrameWriter frameWriter;
116 frameWriter = mock(Http2FrameWriter.class, delegatesTo(new DefaultHttp2FrameWriter()));
218 protected final Http2FrameWriter frameWriter() {
219 return frameWriter;
235 return verify(frameWriter);
239 return verify(frameWriter, verificationMode);
270 // Need to retain the content since the frameWriter releases it.
|
| NettyClientHandlerTest.java | 717 frameWriter(),
|
| NettyServerHandlerTest.java | [all...] |
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| AbstractNettyHandler.java | 169 frameWriter().writeSettings(ctx(), settings, ctx().newPromise());
|
| NettyClientHandler.java | 125 Http2FrameWriter frameWriter = new DefaultHttp2FrameWriter();
136 frameWriter,
152 Http2FrameWriter frameWriter,
174 frameWriter = new Http2OutboundFrameLogger(frameWriter, frameLogger);
177 new DefaultHttp2ConnectionEncoder(connection, frameWriter));
|
| NettyServerHandler.java | 153 Http2FrameWriter frameWriter =
158 frameWriter,
179 Http2FrameWriter frameWriter,
211 frameWriter = new WriteMonitoringFrameWriter(frameWriter, keepAliveEnforcer);
212 Http2ConnectionEncoder encoder = new DefaultHttp2ConnectionEncoder(connection, frameWriter);
[all...] |
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| AltsProtocolNegotiatorTest.java | 386 Http2FrameWriter frameWriter = new DefaultHttp2FrameWriter();
389 new DefaultHttp2ConnectionEncoder(connection, frameWriter);
|
| /external/grpc-grpc-java/netty/shaded/ |
| grpc-netty-shaded-1.14.0.jar | |
| /external/mockito/lib/ |
| byte-buddy-1.8.15.jar | |
