| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | MessageDeframerTest.java | 126 deframer.deframe(buffer(new byte[]{0, 0, 0, 0, 2, 3, 14})); in simplePayload()
137 deframer.deframe(buffer(new byte[]{0, 0, 0, 0, 1, 3, 0, 0, 0, 0, 2, 14, 15})); in smallCombinedPayloads()
151 deframer.deframe(buffer(new byte[]{0, 0, 0, 0, 1, 3})); in endOfStreamWithPayloadShouldNotifyEndOfStream()
163 deframer.deframe(buffer(new byte[0])); in endOfStreamShouldNotifyEndOfStream()
178 deframer.deframe(buffer(new byte[1])); in endOfStreamWithPartialMessageShouldNotifyDeframerClosedWithPartialMessage()
195 deframer.deframe(buffer(new byte[1])); in endOfStreamWithInvalidGzipBlockShouldNotifyDeframerClosedWithPartialMessage()
205 deframer.deframe(buffer(new byte[]{0, 0, 0, 0, 7, 3, 14, 1, 5, 9})); in payloadSplitBetweenBuffers()
208 deframer.deframe(buffer(new byte[]{2, 6})); in payloadSplitBetweenBuffers()
230 deframer.deframe(buffer(new byte[]{0, 0})); in frameHeaderSplitBetweenBuffers()
233 deframer.deframe(buffer(new byte[]{0, 0, 1, 3})); in frameHeaderSplitBetweenBuffers()
[all …]
|
| D | ApplicationThreadDeframerTest.java | 68 applicationThreadDeframer.deframe(frame); in deframeInvokesMessagesAvailableOnListener()
71 verify(mockDeframer).deframe(frame); in deframeInvokesMessagesAvailableOnListener()
|
| D | AbstractClientStreamTest.java | 328 stream.transportState().deframe(ReadableBuffers.wrap(new byte[] {0, 0, 0, 0, 2, 1})); in rstStreamClosesStream()
347 stream.transportState().deframe(ReadableBuffers.wrap(new byte[] {0, 0, 0, 0, 2, 1})); in trailerOkWithTruncatedMessage()
364 stream.transportState().deframe(ReadableBuffers.wrap(new byte[] {0, 0, 0, 0, 2, 1})); in trailerNotOkWithTruncatedMessage()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ApplicationThreadDeframer.java | 92 public void deframe(final ReadableBuffer data) { in deframe() method in ApplicationThreadDeframer
99 deframer.deframe(data); in deframe()
|
| D | AbstractStream.java | 191 protected final void deframe(final ReadableBuffer frame) { in deframe() method in AbstractStream.TransportState
193 deframer.deframe(frame); in deframe()
|
| D | Deframer.java | 58 void deframe(ReadableBuffer data); in deframe() method
|
| D | AbstractServerStream.java | 266 deframe(frame); in inboundDataReceived()
|
| D | MessageDeframer.java | 165 public void deframe(ReadableBuffer data) { in deframe() method in MessageDeframer
|
| D | AbstractClientStream.java | 356 deframe(frame); in inboundDataReceived()
|
| /external/grpc-grpc/test/core/tsi/alts/frame_protector/ |
| D | frame_handler_test.cc | 80 static size_t deframe(frame_handler* handler, unsigned char* bytes, in deframe() function
102 size_t deframed_payload_length = deframe(handler, bytes, read_length); in frame_n_deframe()
|