Home
last modified time | relevance | path

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

/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/tensorflow/tensorflow/compiler/xla/service/
Dtransfer_manager.cc52 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralFromDevice() local
53 substream->ThenWaitFor(stream); in TransferLiteralFromDevice()
55 [&]() { stream->ReturnSubStream(substream); }); in TransferLiteralFromDevice()
61 substream, device_buffer, literal, in TransferLiteralFromDevice()
78 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralFromDevice() local
80 [&]() { stream->ReturnSubStream(substream); }); in TransferLiteralFromDevice()
85 substream, device_buffer, literal, in TransferLiteralFromDevice()
102 se::Stream* substream = stream->GetOrCreateSubStream(); in TransferLiteralToDevice() local
103 substream->ThenWaitFor(stream); in TransferLiteralToDevice()
105 [&]() { stream->ReturnSubStream(substream); }); in TransferLiteralToDevice()
[all …]
/external/nanopb-c/
Dpb_decode.c367 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 …]
Dpb_encode.c685 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 …]
Dpb_decode.h168 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);
DCHANGELOG.txt39 Make string substream API more robust (#230)
/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/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/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/swiftshader/third_party/llvm-7.0/llvm/docs/PDB/
DDbiStream.rst131 number of bytes of the corresponding substream. Each substream's contents will
161 module info substream is an array of variable-length records, each one
255 and consumes ``Header->SectionContributionSize`` bytes. This substream begins
286 and consumes ``Header->SectionMapSize`` bytes. This substream begins with an ``8``
325 and consumes ``Header->SourceInfoSize`` bytes. This substream defines the mapping
327 modules can use the same source file (for example, a header file), this substream
330 directly. The format of this substream is as follows:
345 contained within this substream. Should match the corresponding value from the
349 files for which this substream contains information. But that would present a
380 of this substream is understood, although it is assumed to related somehow to the
[all …]
DModiStream.rst20 there is a "global refs" substream which is not well understood.
68 - **GlobalRefs** - The meaning of this substream is not understood.
/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/nanopb-c/docs/
Dreference.rst760 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.
Dmigration.rst36 **Rationale:** If the substream functions were called directly and the caller
/external/swiftshader/third_party/llvm-7.0/llvm/docs/CommandGuide/
Dllvm-pdbutil.rst474 Dump the edit and continue map substream of the DBI stream.
478 Dump the file info substream of the DBI stream.
482 Dump the modi substream of the DBI stream.
486 Dump section contributions substream of the DBI stream.
515 Dump the symbol record substream from each module.
/external/kernel-headers/original/uapi/sound/
Demu10k1.h341 unsigned int substream; /* substream number */ member
/external/libvpx/libvpx/
DCHANGELOG342 for each substream.