Home
last modified time | relevance | path

Searched refs:endOfStream (Results 1 – 18 of 18) sorted by relevance

/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java150 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in writeFrame() argument
163 state.sendBuffer(buffer, endOfStream, flush); in writeFrame()
235 outboundFlow.data(data.endOfStream, id, data.buffer, false); in start()
297 public void transportHeadersReceived(List<Header> headers, boolean endOfStream) { in transportHeadersReceived() argument
298 if (endOfStream) { in transportHeadersReceived()
309 public void transportDataReceived(okio.Buffer frame, boolean endOfStream) { in transportDataReceived() argument
323 super.transportDataReceived(new OkHttpReadableBuffer(frame), endOfStream); in transportDataReceived()
362 private void sendBuffer(Buffer buffer, boolean endOfStream, boolean flush) { in sendBuffer() argument
368 pendingData.add(new PendingData(buffer, endOfStream, flush)); in sendBuffer()
373 outboundFlow.data(endOfStream, id(), buffer, flush); in sendBuffer()
[all …]
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientStream.java165 WritableBuffer buffer, boolean endOfStream, boolean flush, int numMessages) { in writeFrame() argument
179 state.enqueuePendingData(new PendingData(byteBuffer, endOfStream, flush)); in writeFrame()
181 streamWrite(byteBuffer, endOfStream, flush); in writeFrame()
280 private void transportHeadersReceived(Metadata metadata, boolean endOfStream) { in transportHeadersReceived() argument
281 if (endOfStream) { in transportHeadersReceived()
289 private void transportDataReceived(ByteBuffer buffer, boolean endOfStream) { in transportDataReceived() argument
291 super.transportDataReceived(ReadableBuffers.wrap(buffer), endOfStream); in transportDataReceived() local
310 streamWrite(data.buffer, data.endOfStream, data.flush); in writeAllPendingData()
347 private void streamWrite(ByteBuffer buffer, boolean endOfStream, boolean flush) { in streamWrite() argument
351 stream.write(buffer, endOfStream); in streamWrite()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractServerStream.java119 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame() argument
122 abstractServerStreamSink().writeFrame(frame, endOfStream ? false : flush, numMessages); in deliverFrame()
194 private boolean endOfStream = false; field in AbstractServerStream.TransportState
231 if (endOfStream) { in deframerClosed()
263 public void inboundDataReceived(ReadableBuffer frame, boolean endOfStream) { in inboundDataReceived() argument
264 Preconditions.checkState(!this.endOfStream, "Past end of stream"); in inboundDataReceived()
267 if (endOfStream) { in inboundDataReceived()
268 this.endOfStream = true; in inboundDataReceived()
DHttp2ClientStreamTransportState.java129 protected void transportDataReceived(ReadableBuffer frame, boolean endOfStream) { in transportDataReceived() argument
136 if (transportError.getDescription().length() > 1000 || endOfStream) { in transportDataReceived()
148 if (endOfStream) { in transportDataReceived()
DAbstractClientStream.java77 @Nullable WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); in writeFrame() argument
182 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame() argument
183 Preconditions.checkArgument(frame != null || endOfStream, "null frame before EOS"); in deliverFrame()
184 abstractClientStreamSink().writeFrame(frame, endOfStream, flush, numMessages); in deliverFrame()
DMessageFramer.java62 boolean endOfStream, in deliverFrame() argument
347 private void commitToSink(boolean endOfStream, boolean flush) { in commitToSink() argument
350 sink.deliverFrame(buf, endOfStream, flush, messagesBuffered); in commitToSink()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientStream.java161 WritableBuffer frame, boolean endOfStream, boolean flush, final int numMessages) { in writeFrame() argument
168 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush) in writeFrame()
184 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush); in writeFrame()
293 void transportHeadersReceived(Http2Headers headers, boolean endOfStream) { in transportHeadersReceived() argument
294 if (endOfStream) { in transportHeadersReceived()
304 void transportDataReceived(ByteBuf frame, boolean endOfStream) { in transportDataReceived() argument
305 transportDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); in transportDataReceived()
DNettyServerStream.java197 void inboundDataReceived(ByteBuf frame, boolean endOfStream) { in inboundDataReceived() argument
198 super.inboundDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); in inboundDataReceived()
DNettyServerHandler.java459 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) in onDataRead() argument
464 stream.inboundDataReceived(data, endOfStream); in onDataRead()
635 if (cmd.endOfStream()) { in sendResponseHeaders()
638 encoder().writeHeaders(ctx, streamId, cmd.headers(), 0, cmd.endOfStream(), promise); in sendResponseHeaders()
720 boolean endOfStream) throws Http2Exception { in onDataRead() argument
724 NettyServerHandler.this.onDataRead(streamId, data, padding, endOfStream); in onDataRead()
DSendResponseHeadersCommand.java56 boolean endOfStream() { in endOfStream() method in SendResponseHeadersCommand
DNettyClientHandler.java352 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) { in onDataRead() argument
355 stream.transportDataReceived(data, endOfStream); in onDataRead()
751 boolean endOfStream) throws Http2Exception { in onDataRead() argument
752 NettyClientHandler.this.onDataRead(streamId, data, padding, endOfStream); in onDataRead()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java116 assertThat(sendHeaders.endOfStream()).isFalse(); in writeMessageShouldSendResponse()
142 assertThat(sendHeaders.endOfStream()).isFalse(); in writeHeadersShouldSendHeaders()
162 assertThat(sendHeaders.endOfStream()).isTrue(); in closeBeforeClientHalfCloseShouldSucceed()
190 assertThat(sendHeaders.endOfStream()).isTrue(); in closeWithErrorBeforeClientHalfCloseShouldSucceed()
224 assertThat(cmd.endOfStream()).isTrue(); in closeAfterClientHalfCloseShouldSucceed()
272 assertThat(cmd.endOfStream()).isTrue(); in emptyFramerShouldSendNoPayload()
DNettyHandlerTestBase.java252 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in grpcDataFrame()
/external/brotli/csharp/org/brotli/dec/
DBitReader.cs97 internal static void CheckHealth(Org.Brotli.Dec.BitReader br, bool endOfStream) in CheckHealth() argument
108 if (endOfStream && (byteOffset != br.tailBytes)) in CheckHealth()
/external/brotli/java/org/brotli/dec/
DBitReader.java79 static void checkHealth(State s, int endOfStream) { in checkHealth() argument
87 if ((endOfStream != 0) && (byteOffset != s.tailBytes)) { in checkHealth()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DMessageFramerTest.java332 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {
DAbstractClientStreamTest.java521 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {} in writeFrame() argument
/external/brotli/js/
Ddecode.js1273 function checkHealth(s, endOfStream) { argument
1281 if ((endOfStream != 0) && (byteOffset != s.tailBytes)) {