Home
last modified time | relevance | path

Searched refs:windowUpdate (Results 1 – 25 of 25) sorted by relevance

/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DSpdy3Test.java41 windowUpdate(0); in badWindowSizeIncrement()
47 windowUpdate(0x80000000L); in badWindowSizeIncrement()
91 private void windowUpdate(long increment) throws IOException { in windowUpdate() method in Spdy3Test
92 new Spdy3.Writer(new Buffer(), true).windowUpdate(expectedStreamId, increment); in windowUpdate()
DHttp2Test.java537 assertEquals(frame, windowUpdate(expectedWindowSizeIncrement)); in windowUpdateRoundTrip()
540 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdateRoundTrip()
549 windowUpdate(0); in badWindowSizeIncrement()
556 windowUpdate(0x80000000L); in badWindowSizeIncrement()
687 private Buffer windowUpdate(long windowSizeIncrement) throws IOException { in windowUpdate() method in Http2Test
689 new Http2.Writer(out, true).windowUpdate(expectedStreamId, windowSizeIncrement); in windowUpdate()
DHttp2ConnectionTest.java265 MockSpdyPeer.InFrame windowUpdate = peer.takeFrame();
266 assertEquals(TYPE_WINDOW_UPDATE, windowUpdate.type);
267 windowUpdateStreamIds.add(windowUpdate.streamId);
268 assertEquals(windowUpdateThreshold, windowUpdate.windowSizeIncrement);
DBaseTestHandler.java57 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate() method in BaseTestHandler
DSpdy3ConnectionTest.java994 peer.sendFrame().windowUpdate(1, 5);
1142 MockSpdyPeer.InFrame windowUpdate = peer.takeFrame();
1143 assertEquals(TYPE_WINDOW_UPDATE, windowUpdate.type);
1144 windowUpdateStreamIds.add(windowUpdate.streamId);
1145 assertEquals(windowUpdateThreshold, windowUpdate.windowSizeIncrement);
1244 connection.readerRunnable.windowUpdate(0, 3);
DMockSpdyPeer.java296 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate() method in MockSpdyPeer.InFrame
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java573 frameHandler().windowUpdate(0, 1000); in transportTracer_windowSize_remote()
581 public void windowUpdate() throws Exception { in windowUpdate() method in OkHttpClientTransportTest
614 .windowUpdate(eq(0), eq((long) 2 * messageFrameLength)); in windowUpdate()
622 .windowUpdate(eq(3), eq((long) 2 * messageFrameLength)); in windowUpdate()
629 .windowUpdate(eq(5), eq((long) 2 * messageFrameLength)); in windowUpdate()
631 .windowUpdate(eq(0), eq((long) 2 * messageFrameLength)); in windowUpdate()
662 verify(frameWriter, timeout(TIME_OUT_MS)).windowUpdate( in windowUpdateWithInboundFlowControl()
670 verify(frameWriter, timeout(TIME_OUT_MS)).windowUpdate(eq(3), eq(messageFrameLength)); in windowUpdateWithInboundFlowControl()
706 frameHandler().windowUpdate(3, Utils.DEFAULT_WINDOW_SIZE); in outboundFlowControl()
707 frameHandler().windowUpdate(0, Utils.DEFAULT_WINDOW_SIZE); in outboundFlowControl()
[all …]
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java197 public void windowUpdate(final int streamId, final long windowSizeIncrement) { in windowUpdate() method in AsyncFrameWriter
201 frameWriter.windowUpdate(streamId, windowSizeIncrement); in windowUpdate()
DOkHttpClientTransport.java276 long remote = outboundFlow == null ? -1 : outboundFlow.windowUpdate(null, 0); in initTransportTracer()
1026 frameWriter.windowUpdate(0, connectionUnacknowledgedBytesRead); in data()
1163 public void windowUpdate(int streamId, long delta) { in windowUpdate() method in OkHttpClientTransport.ClientFrameHandler
1179 outboundFlow.windowUpdate(null, (int) delta); in windowUpdate()
1185 outboundFlow.windowUpdate(stream, (int) delta); in windowUpdate()
DOutboundFlowController.java84 int windowUpdate(@Nullable OkHttpClientStream stream, int delta) { in windowUpdate() method in OutboundFlowController
DOkHttpClientStream.java274 frameWriter.windowUpdate(id(), delta); in bytesRead()
/external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/
DFrameWriter.java106 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate() method
DFrameReader.java88 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate() method
DHttp2.java361 handler.windowUpdate(streamId, increment); in readWindowUpdate()
552 @Override public synchronized void windowUpdate(int streamId, long windowSizeIncrement) in windowUpdate() method in Http2.Writer
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFrameWriter.java102 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate() method
DFrameReader.java84 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate() method
DFramedConnection.java367 frameWriter.windowUpdate(streamId, unacknowledgedBytesRead); in writeWindowUpdateLater()
518 frameWriter.windowUpdate(0, windowSize - Settings.DEFAULT_INITIAL_WINDOW_SIZE); in sendConnectionPreface()
795 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate() method in FramedConnection.Reader
DSpdy3.java239 handler.windowUpdate(streamId, increment); in readWindowUpdate()
469 @Override public synchronized void windowUpdate(int streamId, long increment) in windowUpdate() method in Spdy3.Writer
DHttp2.java355 handler.windowUpdate(streamId, increment); in readWindowUpdate()
546 @Override public synchronized void windowUpdate(int streamId, long windowSizeIncrement) in windowUpdate() method in Http2.Writer
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFrameReader.java86 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate() method
DFrameWriter.java104 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate() method
DFramedConnection.java369 frameWriter.windowUpdate(streamId, unacknowledgedBytesRead); in writeWindowUpdateLater()
520 frameWriter.windowUpdate(0, windowSize - Settings.DEFAULT_INITIAL_WINDOW_SIZE); in sendConnectionPreface()
800 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate() method in FramedConnection.Reader
DSpdy3.java241 handler.windowUpdate(streamId, increment); in readWindowUpdate()
471 @Override public synchronized void windowUpdate(int streamId, long increment) in windowUpdate() method in Spdy3.Writer
DHttp2.java357 handler.windowUpdate(streamId, increment); in readWindowUpdate()
548 @Override public synchronized void windowUpdate(int streamId, long windowSizeIncrement) in windowUpdate() method in Http2.Writer
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyHandlerTestBase.java312 protected final ByteBuf windowUpdate(int streamId, int delta) { in windowUpdate() method in NettyHandlerTestBase
474 ByteBuf serializedSettings = windowUpdate(0, 1000); in transportTracer_windowUpdate_remote()