Home
last modified time | relevance | path

Searched refs:deframer (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DApplicationThreadDeframer.java40 private final MessageDeframer deframer; field in ApplicationThreadDeframer
49 MessageDeframer deframer) { in ApplicationThreadDeframer() argument
52 deframer.setListener(this); in ApplicationThreadDeframer()
53 this.deframer = deframer; in ApplicationThreadDeframer()
58 deframer.setMaxInboundMessageSize(messageSize); in setMaxInboundMessageSize()
63 deframer.setDecompressor(decompressor); in setDecompressor()
68 deframer.setFullStreamDecompressor(fullStreamDecompressor); in setFullStreamDecompressor()
78 if (deframer.isClosed()) { in request()
82 deframer.request(numMessages); in request()
85 deframer.close(); // unrecoverable state in request()
[all …]
DAbstractStream.java111 private Deframer deframer; field in AbstractStream.TransportState
141 deframer = new MessageDeframer( in TransportState()
150 deframer.setFullStreamDecompressor(fullStreamDecompressor); in setFullStreamDecompressor()
151 deframer = new ApplicationThreadDeframer(this, this, (MessageDeframer) deframer); in setFullStreamDecompressor()
155 deframer.setMaxInboundMessageSize(maxSize); in setMaxInboundMessageSize()
181 deframer.close(); in closeDeframer()
183 deframer.closeWhenComplete(); in closeDeframer()
193 deframer.deframe(frame); in deframe()
205 deframer.request(numMessages); in requestMessagesFromDeframer()
216 deframer.setDecompressor(decompressor); in setDecompressor()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DMessageDeframerTest.java96 private MessageDeframer deframer = new MessageDeframer(listener, Codec.Identity.NONE, field in MessageDeframerTest.WithAndWithoutFullStreamCompressionTests
105 deframer.setFullStreamDecompressor(new GzipInflatingBuffer() { in setUp()
125 deframer.request(1); in simplePayload()
126 deframer.deframe(buffer(new byte[]{0, 0, 0, 0, 2, 3, 14})); in simplePayload()
136 deframer.request(2); in smallCombinedPayloads()
137 deframer.deframe(buffer(new byte[]{0, 0, 0, 0, 1, 3, 0, 0, 0, 0, 2, 14, 15})); in smallCombinedPayloads()
150 deframer.request(1); in endOfStreamWithPayloadShouldNotifyEndOfStream()
151 deframer.deframe(buffer(new byte[]{0, 0, 0, 0, 1, 3})); in endOfStreamWithPayloadShouldNotifyEndOfStream()
152 deframer.closeWhenComplete(); in endOfStreamWithPayloadShouldNotifyEndOfStream()
163 deframer.deframe(buffer(new byte[0])); in endOfStreamShouldNotifyEndOfStream()
[all …]