Home
last modified time | relevance | path

Searched refs:substream (Results 1 – 25 of 47) sorted by relevance

12

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DRetriableStream.java134 for (Substream substream : savedDrainedSubstreams) { in commit()
135 if (substream != winningSubstream) { in commit()
136 substream.stream.cancel(CANCELLED_BECAUSE_COMMITTED); in commit()
198 private void drain(Substream substream) { in drain() argument
208 if (savedState.winningSubstream != null && savedState.winningSubstream != substream) { in drain()
213 state = savedState.substreamDrained(substream); in drain()
217 if (substream.closed) { in drain()
233 if (savedState.winningSubstream != null && savedState.winningSubstream != substream) { in drain()
239 savedState.winningSubstream == substream, in drain()
243 bufferEntry.runWith(substream); in drain()
[all …]
/external/nanopb-c/
Dpb_decode.c372 bool checkreturn pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream) in pb_make_string_substream() argument
378 *substream = *stream; in pb_make_string_substream()
379 if (substream->bytes_left < size) in pb_make_string_substream()
382 substream->bytes_left = size; in pb_make_string_substream()
387 bool checkreturn pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream) in pb_close_string_substream() argument
389 if (substream->bytes_left) { in pb_close_string_substream()
390 if (!pb_read(substream, NULL, substream->bytes_left)) in pb_close_string_substream()
394 stream->state = substream->state; in pb_close_string_substream()
397 stream->errmsg = substream->errmsg; in pb_close_string_substream()
432 pb_istream_t substream; in decode_static_field() local
[all …]
Dpb_encode.c720 pb_ostream_t substream = PB_OSTREAM_SIZING; in pb_encode_submessage() local
724 if (!pb_encode(&substream, fields, src_struct)) in pb_encode_submessage()
727 stream->errmsg = substream.errmsg; in pb_encode_submessage()
732 size = substream.bytes_written; in pb_encode_submessage()
745 substream.callback = stream->callback; in pb_encode_submessage()
746 substream.state = stream->state; in pb_encode_submessage()
747 substream.max_size = size; in pb_encode_submessage()
748 substream.bytes_written = 0; in pb_encode_submessage()
750 substream.errmsg = NULL; in pb_encode_submessage()
753 status = pb_encode(&substream, fields, src_struct); in pb_encode_submessage()
[all …]
Dpb_decode.h171 bool pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream);
172 bool pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream);
/external/tensorflow/tensorflow/compiler/xla/service/
Dtransfer_manager.cc55 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralFromDevice() local
56 substream->ThenWaitFor(stream); in TransferLiteralFromDevice()
57 absl::Cleanup cleanup = [&]() { stream->ReturnSubStream(substream); }; in TransferLiteralFromDevice()
63 substream, device_buffer, &literal, in TransferLiteralFromDevice()
80 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralFromDevice() local
81 absl::Cleanup cleanup = [&]() { stream->ReturnSubStream(substream); }; in TransferLiteralFromDevice()
86 substream, device_buffer, literal, in TransferLiteralFromDevice()
103 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralToDevice() local
104 substream->ThenWaitFor(stream); in TransferLiteralToDevice()
105 absl::Cleanup cleanup = [&]() { stream->ReturnSubStream(substream); }; in TransferLiteralToDevice()
[all …]
/external/grpc-grpc/third_party/nanopb/
Dpb_decode.c321 bool checkreturn pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream) in pb_make_string_substream() argument
327 *substream = *stream; in pb_make_string_substream()
328 if (substream->bytes_left < size) in pb_make_string_substream()
331 substream->bytes_left = size; in pb_make_string_substream()
336 void pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream) in pb_close_string_substream() argument
338 stream->state = substream->state; in pb_close_string_substream()
341 stream->errmsg = substream->errmsg; in pb_close_string_substream()
373 pb_istream_t substream; in decode_static_field() local
374 if (!pb_make_string_substream(stream, &substream)) in decode_static_field()
377 while (substream.bytes_left > 0 && *size < iter->pos->array_size) in decode_static_field()
[all …]
Dpb_encode.c524 pb_ostream_t substream = PB_OSTREAM_SIZING; in pb_encode_submessage() local
528 if (!pb_encode(&substream, fields, src_struct)) in pb_encode_submessage()
531 stream->errmsg = substream.errmsg; in pb_encode_submessage()
536 size = substream.bytes_written; in pb_encode_submessage()
549 substream.callback = stream->callback; in pb_encode_submessage()
550 substream.state = stream->state; in pb_encode_submessage()
551 substream.max_size = size; in pb_encode_submessage()
552 substream.bytes_written = 0; in pb_encode_submessage()
554 substream.errmsg = NULL; in pb_encode_submessage()
557 status = pb_encode(&substream, fields, src_struct); in pb_encode_submessage()
[all …]
Dpb_decode.h142 bool pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream);
143 void pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream);
/external/grpc-grpc/third_party/nanopb/examples/using_union_messages/
Ddecode.c47 pb_istream_t substream; in decode_unionmessage_contents() local
49 if (!pb_make_string_substream(stream, &substream)) in decode_unionmessage_contents()
52 status = pb_decode(&substream, fields, dest_struct); in decode_unionmessage_contents()
53 pb_close_string_substream(stream, &substream); in decode_unionmessage_contents()
/external/nanopb-c/examples/using_union_messages/
Ddecode.c47 pb_istream_t substream; in decode_unionmessage_contents() local
49 if (!pb_make_string_substream(stream, &substream)) in decode_unionmessage_contents()
52 status = pb_decode(&substream, fields, dest_struct); in decode_unionmessage_contents()
53 pb_close_string_substream(stream, &substream); in decode_unionmessage_contents()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_crypto_stream.cc80 CryptoSubstream& substream = in OnCryptoFrame() local
82 substream.sequencer.OnCryptoFrame(frame); in OnCryptoFrame()
84 if (substream.sequencer.NumBytesBuffered() > in OnCryptoFrame()
257 for (const auto& substream : substreams_) { in HasPendingCryptoRetransmission() local
258 if (substream.send_buffer.HasPendingRetransmission()) { in HasPendingCryptoRetransmission()
372 for (const CryptoSubstream& substream : substreams_) { in crypto_bytes_read() local
373 bytes_read += substream.sequencer.NumBytesConsumed(); in crypto_bytes_read()
471 for (const CryptoSubstream& substream : substreams_) { in HasBufferedCryptoFrames() local
472 const QuicStreamSendBuffer& send_buffer = substream.send_buffer; in HasBufferedCryptoFrames()
501 for (const CryptoSubstream& substream : substreams_) { in IsWaitingForAcks() local
[all …]
/external/webrtc/call/
Dvideo_send_stream.cc92 for (const auto& substream : substreams) { in ToString() local
93 if (substream.second.type == in ToString()
95 ss << " {ssrc: " << substream.first << ", "; in ToString()
96 ss << substream.second.ToString(); in ToString()
/external/nanopb-c/spm_headers/nanopb/
Dpb_decode.h171 bool pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream);
172 bool pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream);
/external/webrtc/media/engine/
Dwebrtc_video_engine_unittest.cc5588 auto& substream = stats.substreams[ssrc_1]; in TEST_F() local
5589 substream.frame_counts.key_frames = 1; in TEST_F()
5590 substream.frame_counts.delta_frames = 2; in TEST_F()
5591 substream.width = 3; in TEST_F()
5592 substream.height = 4; in TEST_F()
5593 substream.total_bitrate_bps = 5; in TEST_F()
5594 substream.retransmit_bitrate_bps = 6; in TEST_F()
5595 substream.avg_delay_ms = 7; in TEST_F()
5596 substream.max_delay_ms = 8; in TEST_F()
5597 substream.rtp_stats.transmitted.total_packet_delay = in TEST_F()
[all …]
/external/pdfium/core/fpdfapi/parser/
Dcpdf_syntax_parser.cpp726 RetainPtr<IFX_SeekableReadStream> substream; in ReadStream() local
735 substream = pdfium::MakeRetain<ReadableSubStream>( in ReadStream()
758 substream.Reset(); in ReadStream()
782 substream = pdfium::MakeRetain<ReadableSubStream>( in ReadStream()
789 if (substream) { in ReadStream()
794 FixedUninitDataVector<uint8_t> data(substream->GetSize()); in ReadStream()
795 bool did_read = substream->ReadBlockAtOffset(data.writable_span(), 0); in ReadStream()
/external/webrtc/test/scenario/
Dscenario_unittest.cc189 for (const auto& substream : stats.substreams) { in TEST() local
190 retransmit_packets += substream.second.rtp_stats.retransmitted.packets; in TEST()
Dvideo_stream_unittest.cc138 for (const auto& substream : stats.substreams) { in TEST() local
139 retransmit_packets += substream.second.rtp_stats.retransmitted.packets; in TEST()
/external/swiftshader/third_party/llvm-10.0/llvm/lib/DebugInfo/CodeView/
DSymbolRecordHelpers.cpp92 return Symbols.substream(ScopeBegin, EndOffset); in limitSymbolArrayToScope()
/external/nanopb-c/docs/
Dreference.rst764 Decode the length for a field with wire type *PB_WT_STRING* and create a substream for reading the …
766 bool pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream);
769 :substream: New substream that has limited length. Filled in by the function.
772 …eger from the stream. This is interpreted as a number of bytes, and the substream is set up so tha…
776 Close the substream created with `pb_make_string_substream`_. ::
778 void pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream);
781 :substream: Substream to close
783 This function copies back the state from the substream to the parent stream.
784 It must be called after done with the substream.
/external/grpc-grpc/third_party/nanopb/docs/
Dreference.rst750 Decode the length for a field with wire type *PB_WT_STRING* and create a substream for reading the …
752 bool pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream);
755 :substream: New substream that has limited length. Filled in by the function.
758 …eger from the stream. This is interpreted as a number of bytes, and the substream is set up so tha…
762 Close the substream created with `pb_make_string_substream`_. ::
764 void pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream);
767 :substream: Substream to close
769 This function copies back the state from the substream to the parent stream.
770 It must be called after done with the substream.
/external/kernel-headers/original/uapi/sound/
Demu10k1.h340 unsigned int substream; /* substream number */ member
/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/
DBinaryStreamArray.h115 VarStreamArray<ValueType, Extractor> substream(uint32_t Begin, in substream() function
/external/webrtc/video/
Dsend_statistics_proxy.cc757 for (auto& substream : stats_.substreams) { in GetStats() local
758 uint32_t ssrc = substream.first; in GetStats()
760 substream.second.encode_frame_rate = in GetStats()
/external/cpuinfo/test/dmesg/
Doneplus-3t.log1964 [ 6.675148]@3 msm_pcm_volume_ctl_get substream runtime not found
1965 [ 6.675431]@3 msm_pcm_volume_ctl_get substream runtime not found
1966 [ 6.675687]@3 msm_pcm_volume_ctl_get substream runtime not found
1967 [ 6.677276]@3 msm_pcm_volume_ctl_get substream runtime not found
1968 [ 6.678182]@3 msm_pcm_volume_ctl_get substream runtime not found
1969 [ 6.678275]@3 msm_pcm_volume_ctl_get substream or runtime not found
1970 [ 6.678659]@3 msm_pcm_volume_ctl_get substream runtime not found
2010 [ 7.738211]@2 msm_pcm_volume_ctl_get substream runtime not found
2011 [ 7.738445]@2 msm_pcm_volume_ctl_get substream runtime not found
2015 [ 7.751716]@2 msm_pcm_volume_ctl_get substream runtime not found
[all …]
Dnexus5x.log1452 [ 9.089161] msm_pcm_volume_ctl_get substream runtime not found
1453 [ 9.089291] msm_pcm_volume_ctl_get substream runtime not found
1454 [ 9.089407] msm_pcm_volume_ctl_get substream runtime not found
1456 [ 9.089859] msm_pcm_volume_ctl_get substream runtime not found
1459 [ 9.090531] msm_pcm_volume_ctl_get substream runtime not found
1468 [ 9.365295] msm_pcm_volume_ctl_get substream runtime not found
1469 [ 9.365396] msm_pcm_volume_ctl_get substream runtime not found
1470 [ 9.365499] msm_pcm_volume_ctl_get substream runtime not found
1472 [ 9.365812] msm_pcm_volume_ctl_get substream runtime not found
1475 [ 9.366439] msm_pcm_volume_ctl_get substream runtime not found

12