| /external/tensorflow/tensorflow/core/data/service/ |
| D | test_util_test.cc | 38 bool end_of_input = false; in TEST() local
41 while (!end_of_input) { in TEST()
43 TF_ASSERT_OK(iterator->GetNext(&outputs, &end_of_input)); in TEST()
44 if (!end_of_input) { in TEST()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | parallel_batch_dataset_op.cc | 290 : end_of_input(false), in BatchResult()
297 bool end_of_input TF_GUARDED_BY(mu);
336 bool end_of_input = false; in CallBatching() local
337 for (int i = 0; i < dataset()->batch_size_ && !end_of_input; ++i) { in CallBatching()
340 &end_of_input); in CallBatching()
343 result->end_of_input = result->end_of_input || end_of_input; in CallBatching()
345 if (result->end_of_input || !result->status.ok()) break; in CallBatching()
347 if (!end_of_input) { in CallBatching()
358 DCHECK(end_of_input); in CallBatching()
445 result->end_of_input = reader->Contains( in ReadBatchResult()
[all …]
|
| D | parallel_map_dataset_op.cc | 305 if (result.end_of_input) { in SaveInternal()
347 result.end_of_input = reader->Contains(element_prefix, kEndOfInput); in RestoreInternal()
380 bool end_of_input = false; member
428 &result->end_of_input); in CallFunction()
429 if (result->end_of_input || !result->status.ok()) { in CallFunction()
478 if (!result->end_of_input && result->status.ok()) { in ProcessResult()
499 *end_of_sequence = result->end_of_input; in ProcessResult()
558 (it == invocation_results_.begin() || !(*it)->end_of_input)) { in ShouldWait()
|
| D | window_dataset_op.cc | 207 bool end_of_input; in GetNextInternal() local
210 input_impl_->GetNext(ctx, &element, &end_of_input).IgnoreError(); in GetNextInternal()
211 if (end_of_input) { in GetNextInternal()
|
| D | iterator_ops.cc | 730 bool end_of_input; in DoCompute() local
732 iterator->GetNext(&iter_ctx, &next_input_element, &end_of_input)); in DoCompute()
733 if (end_of_input) { in DoCompute()
|
| D | parallel_interleave_dataset_op.cc | 951 bool end_of_input = false; in ProcessElement() local
953 &end_of_input); in ProcessElement()
954 if (end_of_input) { in ProcessElement()
|
| /external/tensorflow/tensorflow/core/data/ |
| D | standalone_test.cc | 289 bool end_of_input = false; in TEST() local
290 for (int num_outputs = 0; !end_of_input; ++num_outputs) { in TEST()
292 s = iterator->GetNext(&outputs, &end_of_input); in TEST()
294 if (!end_of_input) { in TEST()
|
| D | standalone.cc | 38 Status Iterator::GetNext(std::vector<Tensor>* outputs, bool* end_of_input) { in GetNext() argument
39 return iterator_->GetNext(ctx_.get(), outputs, end_of_input); in GetNext()
|
| D | standalone.h | 73 Status GetNext(std::vector<Tensor>* outputs, bool* end_of_input);
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | map_and_batch_dataset_op.cc | 340 : end_of_input(false), in BatchResult()
365 bool end_of_input TF_GUARDED_BY(mu);
402 bool end_of_input = false; in CallFunction() local
404 input_impl_->GetNext(ctx.get(), &input_element, &end_of_input); in CallFunction()
408 result->end_of_input = result->end_of_input || end_of_input; in CallFunction()
410 return_early = result->end_of_input || !result->status.ok(); in CallFunction()
597 result->end_of_input = reader->Contains( in ReadBatchResult()
622 if (result->end_of_input) { in WriteBatchResult()
|
| D | sliding_window_dataset_op.cc | 193 bool end_of_input; in GetNextInternal() local
196 input_impl_->GetNext(ctx, &element, &end_of_input)); in GetNextInternal()
197 if (end_of_input) { in GetNextInternal()
|
| D | parse_example_dataset_op.cc | 456 if (result.end_of_input) { in SaveInternal()
502 result.end_of_input = reader->Contains(full_name(strings::StrCat( in RestoreInternal()
536 bool end_of_input = false; member
585 &result->end_of_input); in CallFunction()
586 if (result->end_of_input || !result->status.ok()) { in CallFunction()
721 if (!result->end_of_input && result->status.ok()) { in ProcessResult()
735 *end_of_sequence = result->end_of_input; in ProcessResult()
797 (it == invocation_results_.begin() || !(*it)->end_of_input)) { in ShouldWait()
|
| D | io_ops.cc | 103 bool end_of_input; in WriteData() local
104 TF_RETURN_IF_ERROR(iterator->GetNext(&iter_ctx, &element, &end_of_input)); in WriteData()
105 if (end_of_input) { in WriteData()
|
| D | parallel_interleave_dataset_op.cc | 357 bool end_of_input = false; in GetNextInternal() local
358 Status s = input_impl_->GetNext(ctx, &args, &end_of_input); in GetNextInternal()
359 if (end_of_input) { in GetNextInternal()
663 bool end_of_input = false; in EnsureWorkerThreadsStarted() local
664 Status s = input_impl_->GetNext(ctx, &args, &end_of_input); in EnsureWorkerThreadsStarted()
665 if (end_of_input) { in EnsureWorkerThreadsStarted()
|
| /external/webrtc/modules/audio_coding/neteq/tools/ |
| D | neteq_quality_test.cc | 442 bool end_of_input = false; in Simulate() local
447 while (!end_of_input && decoded_time_ms_ < runtime_ms) { in Simulate()
453 end_of_input = true; in Simulate()
454 ASSERT_TRUE(end_of_input && absl::GetFlag(FLAGS_runtime_ms) < 0); in Simulate()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | lookup_util.cc | 424 bool end_of_input; in Next() local
426 status_ = iterator_->GetNext(iterator_ctx_.get(), &tensors_, &end_of_input); in Next()
427 if (status_.ok() && end_of_input) { in Next()
|
| /external/libwebm/m2ts/ |
| D | vpxpes_parser.cc | 309 const std::uint8_t* const end_of_input = in RemoveStartCodeEmulationPreventionBytes() local
313 if (raw_data + i > end_of_input) in RemoveStartCodeEmulationPreventionBytes()
|