Home
last modified time | relevance | path

Searched refs:rstStream (Results 1 – 22 of 22) sorted by relevance

/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DSpdy3ConnectionTest.java361 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
362 assertEquals(TYPE_RST_STREAM, rstStream.type);
363 assertEquals(41, rstStream.streamId);
364 assertEquals(INVALID_STREAM, rstStream.errorCode);
381 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
382 assertEquals(TYPE_RST_STREAM, rstStream.type);
383 assertEquals(41, rstStream.streamId);
384 assertEquals(INVALID_STREAM, rstStream.errorCode);
437 peer.sendFrame().rstStream(1, CANCEL);
510 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
[all …]
DHttp2ConnectionTest.java426 MockSpdyPeer.InFrame rstStream = peer.takeFrame();
427 assertEquals(TYPE_RST_STREAM, rstStream.type);
428 assertEquals(2, rstStream.streamId);
429 assertEquals(CANCEL, rstStream.errorCode);
DBaseTestHandler.java37 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() method in BaseTestHandler
DMockSpdyPeer.java273 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() method in MockSpdyPeer.InFrame
DHttp2Test.java227 @Override public void rstStream(int streamId, ErrorCode errorCode) { in readRstStreamFrame()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFramedConnection.java362 frameWriter.rstStream(streamId, statusCode); in writeSynReset()
706 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() method in FramedConnection.Reader
711 FramedStream rstStream = removeStream(streamId); in rstStream() local
712 if (rstStream != null) { in rstStream()
713 rstStream.receiveRstStream(errorCode); in rstStream()
853 frameWriter.rstStream(streamId, ErrorCode.CANCEL); in pushRequestLater()
870 if (cancel) frameWriter.rstStream(streamId, ErrorCode.CANCEL); in pushHeadersLater()
896 if (cancel) frameWriter.rstStream(streamId, ErrorCode.CANCEL); in pushDataLater()
DFrameWriter.java58 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream() method
DFrameReader.java49 void rstStream(int streamId, ErrorCode errorCode); in rstStream() method
DSpdy3.java224 handler.rstStream(streamId, errorCode); in readRstStream()
373 @Override public synchronized void rstStream(int streamId, ErrorCode errorCode) in rstStream() method in Spdy3.Writer
DHttp2.java258 handler.rstStream(streamId, errorCode); in readRstStream()
467 @Override public synchronized void rstStream(int streamId, ErrorCode errorCode) in rstStream() method in Http2.Writer
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFramedConnection.java360 frameWriter.rstStream(streamId, statusCode); in writeSynReset()
701 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() method in FramedConnection.Reader
706 FramedStream rstStream = removeStream(streamId); in rstStream() local
707 if (rstStream != null) { in rstStream()
708 rstStream.receiveRstStream(errorCode); in rstStream()
848 frameWriter.rstStream(streamId, ErrorCode.CANCEL); in pushRequestLater()
865 if (cancel) frameWriter.rstStream(streamId, ErrorCode.CANCEL); in pushHeadersLater()
891 if (cancel) frameWriter.rstStream(streamId, ErrorCode.CANCEL); in pushDataLater()
DFrameWriter.java56 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream() method
DFrameReader.java47 void rstStream(int streamId, ErrorCode errorCode); in rstStream() method
DSpdy3.java222 handler.rstStream(streamId, errorCode); in readRstStream()
371 @Override public synchronized void rstStream(int streamId, ErrorCode errorCode) in rstStream() method in Spdy3.Writer
DHttp2.java256 handler.rstStream(streamId, errorCode); in readRstStream()
465 @Override public synchronized void rstStream(int streamId, ErrorCode errorCode) in rstStream() method in Http2.Writer
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java143 public void rstStream(final int streamId, final ErrorCode errorCode) { in rstStream() method in AsyncFrameWriter
147 frameWriter.rstStream(streamId, errorCode); in rstStream()
DOkHttpClientTransport.java806 frameWriter.rstStream(streamId, ErrorCode.CANCEL); in finishStream()
1006 frameWriter.rstStream(streamId, ErrorCode.INVALID_STREAM); in data()
1046 frameWriter.rstStream(streamId, ErrorCode.INVALID_STREAM); in headers()
1061 public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() method in OkHttpClientTransport.ClientFrameHandler
1159 frameWriter.rstStream(streamId, ErrorCode.PROTOCOL_ERROR); in pushPromise()
DOkHttpClientStream.java315 frameWriter.rstStream(id(), ErrorCode.FLOW_CONTROL_ERROR); in transportDataReceived()
/external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/
DFrameWriter.java60 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream() method
DFrameReader.java51 void rstStream(int streamId, io.grpc.okhttp.internal.framed.ErrorCode errorCode); in rstStream() method
DHttp2.java261 handler.rstStream(streamId, errorCode); in readRstStream()
471 …@Override public synchronized void rstStream(int streamId, io.grpc.okhttp.internal.framed.ErrorCod… in rstStream() method in Http2.Writer
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java410 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in invalidInboundHeadersCancelStream()
461 frameHandler().rstStream(3, ErrorCode.PROTOCOL_ERROR); in receiveReset()
477 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in cancelStream()
530 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in cancelStreamForDeadlineExceeded()
634 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in windowUpdate()
640 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(5), eq(ErrorCode.CANCEL)); in windowUpdate()
673 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in windowUpdateWithInboundFlowControl()
916 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(startId), eq(ErrorCode.CANCEL)); in streamIdExhausted()
1089 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.FLOW_CONTROL_ERROR)); in receivingWindowExceeded()
1193 verify(frameWriter, timeout(TIME_OUT_MS)).rstStream(eq(3), eq(ErrorCode.CANCEL)); in receiveLongEnoughDataWithoutHeaderAndTrailer()
[all …]