Home
last modified time | relevance | path

Searched refs:deliverFrame (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DMessageFramerTest.java83 verify(sink).deliverFrame(toWriteBuffer(new byte[] {0, 0, 0, 0, 2, 3, 14}), false, true, 1); in simplePayload()
94 verify(sink).deliverFrame(toWriteBuffer(new byte[] {0, 0, 0, 0, 2}), false, false, 0); in simpleUnknownLengthPayload()
95 verify(sink).deliverFrame(toWriteBuffer(new byte[] {3, 14}), false, true, 1); in simpleUnknownLengthPayload()
108 verify(sink).deliverFrame( in smallPayloadsShouldBeCombined()
120 verify(sink).deliverFrame( in closeCombinedWithFullSink()
130 verify(sink).deliverFrame(null, true, true, 0); in closeWithoutBufferedFrameGivesNullBuffer()
141 verify(sink).deliverFrame( in payloadSplitBetweenSinks()
146 verify(sink).deliverFrame(toWriteBuffer(new byte[] {5}), false, true, 0); in payloadSplitBetweenSinks()
158 verify(sink).deliverFrame( in frameHeaderSplitBetweenSinks()
163 verify(sink).deliverFrame(toWriteBufferWithMinSize(new byte[] {1, 3}, 12), false, true, 0); in frameHeaderSplitBetweenSinks()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DMessageFramer.java60 void deliverFrame( in deliverFrame() method
252 sink.deliverFrame(writeableHeader, false, false, messagesBuffered - 1); in writeBufferChain()
257 sink.deliverFrame(bufferList.get(i), false, false, 0); in writeBufferChain()
350 sink.deliverFrame(buf, endOfStream, flush, messagesBuffered); in commitToSink()
DAbstractServerStream.java118 public final void deliverFrame( in deliverFrame() method in AbstractServerStream
DAbstractClientStream.java181 public final void deliverFrame( in deliverFrame() method in AbstractClientStream
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyHandlerTestBase.java251 public void deliverFrame( in grpcDataFrame()