| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 150 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/ |
| D | CronetClientStream.java | 165 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/ |
| D | AbstractServerStream.java | 119 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()
|
| D | Http2ClientStreamTransportState.java | 129 protected void transportDataReceived(ReadableBuffer frame, boolean endOfStream) { in transportDataReceived() argument
136 if (transportError.getDescription().length() > 1000 || endOfStream) { in transportDataReceived()
148 if (endOfStream) { in transportDataReceived()
|
| D | AbstractClientStream.java | 77 @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()
|
| D | MessageFramer.java | 62 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/ |
| D | NettyClientStream.java | 161 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()
|
| D | NettyServerStream.java | 197 void inboundDataReceived(ByteBuf frame, boolean endOfStream) { in inboundDataReceived() argument
198 super.inboundDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); in inboundDataReceived()
|
| D | NettyServerHandler.java | 459 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()
|
| D | SendResponseHeadersCommand.java | 56 boolean endOfStream() { in endOfStream() method in SendResponseHeadersCommand
|
| D | NettyClientHandler.java | 352 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/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/source/chunk/ |
| D | ChunkHolder.java | 31 public boolean endOfStream; field in ChunkHolder
38 endOfStream = false; in clear()
|
| D | ChunkSampleStream.java | 540 boolean endOfStream = nextChunkHolder.endOfStream; in continueLoading()
544 if (endOfStream) { in continueLoading()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerStreamTest.java | 116 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()
|
| /external/angle/src/libANGLE/ |
| D | BinaryStream_unittest.cpp | 39 ASSERT_TRUE(stream.endOfStream()); in TEST()
50 ASSERT_TRUE(stream.endOfStream()); in TEST()
|
| D | BinaryStream.h | 154 bool endOfStream() const { return mOffset == mLength; } in endOfStream() function
|
| /external/brotli/csharp/org/brotli/dec/ |
| D | BitReader.cs | 97 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/ |
| D | BitReader.java | 84 static void checkHealth(State s, int endOfStream) { in checkHealth() argument
92 if ((endOfStream != 0) && (byteOffset != s.tailBytes)) { in checkHealth()
|
| /external/exoplayer/tree/library/hls/src/main/java/com/google/android/exoplayer2/source/hls/ |
| D | HlsChunkSource.java | 65 public boolean endOfStream; field in HlsChunkSource.HlsChunkHolder
75 endOfStream = false; in clear()
309 out.endOfStream = true; in getNextChunk()
|
| D | HlsSampleStreamWrapper.java | 654 boolean endOfStream = nextChunkHolder.endOfStream;
659 if (endOfStream) {
|
| /external/exoplayer/tree/library/smoothstreaming/src/main/java/com/google/android/exoplayer2/source/smoothstreaming/ |
| D | DefaultSsChunkSource.java | 201 out.endOfStream = !manifest.isLive;
220 out.endOfStream = !manifest.isLive;
|
| /external/v4l2_codec2/components/ |
| D | V4L2EncodeComponent.cpp | 472 bool endOfStream = work->input.flags & C2FrameData::FLAG_END_OF_STREAM; in queueTask() local
474 timestamp, endOfStream); in queueTask()
478 if (work->input.buffers.empty() && !endOfStream) { in queueTask()
518 if (endOfStream) { in queueTask()
|
| /external/exoplayer/tree/library/dash/src/main/java/com/google/android/exoplayer2/source/dash/ |
| D | DefaultDashChunkSource.java | 329 out.endOfStream = periodEnded;
356 out.endOfStream = periodEnded;
362 out.endOfStream = true;
|
| /external/exoplayer/tree/testutils/src/main/java/com/google/android/exoplayer2/testutil/ |
| D | FakeChunkSource.java | 124 out.endOfStream = true;
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | MessageFramerTest.java | 332 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {
|