| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | RetriableStream.java | 134 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/ |
| D | pb_decode.c | 367 bool checkreturn pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream) in pb_make_string_substream() argument
373 *substream = *stream; in pb_make_string_substream()
374 if (substream->bytes_left < size) in pb_make_string_substream()
377 substream->bytes_left = size; in pb_make_string_substream()
382 bool checkreturn pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream) in pb_close_string_substream() argument
384 if (substream->bytes_left) { in pb_close_string_substream()
385 if (!pb_read(substream, NULL, substream->bytes_left)) in pb_close_string_substream()
389 stream->state = substream->state; in pb_close_string_substream()
392 stream->errmsg = substream->errmsg; in pb_close_string_substream()
427 pb_istream_t substream; in decode_static_field() local
[all …]
|
| D | pb_encode.c | 685 pb_ostream_t substream = PB_OSTREAM_SIZING; in pb_encode_submessage() local
689 if (!pb_encode(&substream, fields, src_struct)) in pb_encode_submessage()
692 stream->errmsg = substream.errmsg; in pb_encode_submessage()
697 size = substream.bytes_written; in pb_encode_submessage()
710 substream.callback = stream->callback; in pb_encode_submessage()
711 substream.state = stream->state; in pb_encode_submessage()
712 substream.max_size = size; in pb_encode_submessage()
713 substream.bytes_written = 0; in pb_encode_submessage()
715 substream.errmsg = NULL; in pb_encode_submessage()
718 status = pb_encode(&substream, fields, src_struct); in pb_encode_submessage()
[all …]
|
| D | pb_decode.h | 168 bool pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream);
169 bool pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream);
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | transfer_manager.cc | 55 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralFromDevice() local
56 substream->ThenWaitFor(stream); in TransferLiteralFromDevice()
58 [&]() { stream->ReturnSubStream(substream); }); in TransferLiteralFromDevice()
64 substream, device_buffer, &literal, in TransferLiteralFromDevice()
81 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralFromDevice() local
83 [&]() { stream->ReturnSubStream(substream); }); in TransferLiteralFromDevice()
88 substream, device_buffer, literal, in TransferLiteralFromDevice()
105 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralToDevice() local
106 substream->ThenWaitFor(stream); in TransferLiteralToDevice()
108 [&]() { stream->ReturnSubStream(substream); }); in TransferLiteralToDevice()
[all …]
|
| /external/grpc-grpc/third_party/nanopb/ |
| D | pb_decode.c | 321 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 …]
|
| D | pb_encode.c | 524 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 …]
|
| D | pb_decode.h | 142 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/nanopb-c/examples/using_union_messages/ |
| D | decode.c | 47 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/grpc-grpc/third_party/nanopb/examples/using_union_messages/ |
| D | decode.c | 47 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/webrtc/call/ |
| D | video_send_stream.cc | 85 for (const auto& substream : substreams) { in ToString() local
86 if (substream.second.type == in ToString()
88 ss << " {ssrc: " << substream.first << ", "; in ToString()
89 ss << substream.second.ToString(); in ToString()
|
| /external/webrtc/media/engine/ |
| D | webrtc_video_engine_unittest.cc | 5365 auto& substream = stats.substreams[ssrc_1]; in TEST_F() local
5366 substream.frame_counts.key_frames = 1; in TEST_F()
5367 substream.frame_counts.delta_frames = 2; in TEST_F()
5368 substream.width = 3; in TEST_F()
5369 substream.height = 4; in TEST_F()
5370 substream.total_bitrate_bps = 5; in TEST_F()
5371 substream.retransmit_bitrate_bps = 6; in TEST_F()
5372 substream.avg_delay_ms = 7; in TEST_F()
5373 substream.max_delay_ms = 8; in TEST_F()
5374 substream.total_packet_send_delay_ms = 9; in TEST_F()
[all …]
|
| /external/llvm-project/llvm/docs/PDB/ |
| D | DbiStream.rst | 132 number of bytes of the corresponding substream. Each substream's contents will
162 module info substream is an array of variable-length records, each one
264 and consumes ``Header->SectionContributionSize`` bytes. This substream begins
297 and consumes ``Header->SectionMapSize`` bytes. This substream begins with an ``4``
336 and consumes ``Header->SourceInfoSize`` bytes. This substream defines the mapping
338 modules can use the same source file (for example, a header file), this substream
341 directly. The format of this substream is as follows:
356 contained within this substream. Should match the corresponding value from the
360 files for which this substream contains information. But that would present a
391 nor the layout of this substream is understood, although it is assumed to
[all …]
|
| D | ModiStream.rst | 20 there is a "global refs" substream which is not well understood.
68 - **GlobalRefs** - The meaning of this substream is not understood.
|
| /external/webrtc/test/scenario/ |
| D | scenario_unittest.cc | 183 for (const auto& substream : video->send()->GetStats().substreams) { in TEST() local
184 retransmit_packets += substream.second.rtp_stats.retransmitted.packets; in TEST()
|
| D | video_stream_unittest.cc | 131 for (const auto& substream : video->send()->GetStats().substreams) { in TEST() local
132 retransmit_packets += substream.second.rtp_stats.retransmitted.packets; in TEST()
|
| /external/llvm-project/llvm/lib/DebugInfo/CodeView/ |
| D | SymbolRecordHelpers.cpp | 92 return Symbols.substream(ScopeBegin, EndOffset); in limitSymbolArrayToScope()
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/DebugInfo/CodeView/ |
| D | SymbolRecordHelpers.cpp | 92 return Symbols.substream(ScopeBegin, EndOffset); in limitSymbolArrayToScope()
|
| /external/llvm-project/llvm/docs/CommandGuide/ |
| D | llvm-pdbutil.rst | 476 Dump the edit and continue map substream of the DBI stream.
480 Dump the file info substream of the DBI stream.
484 Dump the modi substream of the DBI stream.
488 Dump section contributions substream of the DBI stream.
517 Dump the symbol record substream from each module.
|
| /external/grpc-grpc/third_party/nanopb/docs/ |
| D | reference.rst | 750 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/nanopb-c/docs/ |
| D | reference.rst | 760 Decode the length for a field with wire type *PB_WT_STRING* and create a substream for reading the …
762 bool pb_make_string_substream(pb_istream_t *stream, pb_istream_t *substream);
765 :substream: New substream that has limited length. Filled in by the function.
768 …eger from the stream. This is interpreted as a number of bytes, and the substream is set up so tha…
772 Close the substream created with `pb_make_string_substream`_. ::
774 void pb_close_string_substream(pb_istream_t *stream, pb_istream_t *substream);
777 :substream: Substream to close
779 This function copies back the state from the substream to the parent stream.
780 It must be called after done with the substream.
|
| /external/kernel-headers/original/uapi/sound/ |
| D | emu10k1.h | 356 unsigned int substream; /* substream number */ member
|
| /external/llvm-project/llvm/include/llvm/Support/ |
| D | BinaryStreamArray.h | 116 VarStreamArray<ValueType, Extractor> substream(uint32_t Begin, in substream() function
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| D | BinaryStreamArray.h | 115 VarStreamArray<ValueType, Extractor> substream(uint32_t Begin, in substream() function
|
| /external/cpuinfo/test/dmesg/ |
| D | oneplus-3t.log | 1964 [ 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 …]
|