Searched refs:InvocationResult (Results 1 – 8 of 8) sorted by relevance
173 std::shared_ptr<InvocationResult> result; in GetNextInternal()249 invocation_results_.push_back(std::make_shared<InvocationResult>()); in RestoreInternal()293 struct InvocationResult { struct in tensorflow::data::ParallelFilterDatasetOp::Dataset::Iterator294 InvocationResult() : uid(tensorflow::EnvTime::NowNanos()) {} in InvocationResult() function326 const std::shared_ptr<InvocationResult>& result) in CallCompleted()335 const std::shared_ptr<InvocationResult>& result) in CallFunction()399 const std::shared_ptr<InvocationResult>& result, in ProcessResult()422 std::vector<std::shared_ptr<InvocationResult>> new_calls; in RunnerThread()444 invocation_results_.push_back(std::make_shared<InvocationResult>()); in RunnerThread()461 std::shared_ptr<InvocationResult>* result) in ShouldWait()[all …]
276 std::shared_ptr<InvocationResult> result; in GetNextInternal()357 invocation_results_.push_back(std::make_shared<InvocationResult>()); in RestoreInternal()413 struct InvocationResult { struct in tensorflow::data::ParallelMapDatasetOp::Dataset::Iterator414 InvocationResult() : uid(tensorflow::EnvTime::NowNanos()) {} in InvocationResult() function450 const std::shared_ptr<InvocationResult>& result) in CallCompleted()459 const std::shared_ptr<InvocationResult>& result) in CallFunction()515 const std::shared_ptr<InvocationResult>& result, in ProcessResult()547 std::vector<std::shared_ptr<InvocationResult>> new_calls; in RunnerThread()569 invocation_results_.push_back(std::make_shared<InvocationResult>()); in RunnerThread()584 bool ShouldWait(std::shared_ptr<InvocationResult>* result) in ShouldWait()[all …]
325 struct InvocationResult { struct in tensorflow::data::WindowDatasetOp::Dataset::Iterator326 InvocationResult() = default;327 InvocationResult(std::vector<Tensor>&& result, const Status& status) in InvocationResult() function377 std::deque<InvocationResult> buffer_ TF_GUARDED_BY(mu_);
397 std::shared_ptr<InvocationResult> result; in GetNextInternal()478 invocation_results_.push_back(std::make_shared<InvocationResult>()); in RestoreInternal()535 struct InvocationResult { struct in tensorflow::data::experimental::__anon499ed3a90111::ParseExampleDatasetOp::Dataset::Iterator536 InvocationResult() = default;537 explicit InvocationResult(int64_t id) : id(id) {} in InvocationResult() argument572 const std::shared_ptr<InvocationResult>& result) in CallCompleted()582 const std::shared_ptr<InvocationResult>& result) in CallFunction()729 const std::shared_ptr<InvocationResult>& result, in ProcessResult()754 std::vector<std::shared_ptr<InvocationResult>> new_calls; in RunnerThread()779 std::make_shared<InvocationResult>(num_total_calls++)); in RunnerThread()[all …]
294 struct InvocationResult { struct in tensorflow::data::experimental::__anon2193e91d0111::ChooseFastestDatasetOp::Dataset::ChooseFastestIterator302 std::unique_ptr<InvocationResult> result;320 threads[i].result = std::make_unique<InvocationResult>(); in StartThreads()329 void RunnerThread(IteratorContext* ctx, InvocationResult* result, int i) { in RunnerThread()
54 static interface InvocationResult { interface in InvokableTypeImpl110 InvocationResult ret; in invokeMethod()293 abstract InvocationResult waitForReply(PacketStream stream) throws JDWPException; in waitForReply()
39 private static class IResult implements InvocationResult {110 InvocationResult waitForReply(PacketStream stream) throws JDWPException { in waitForReply()
35 private static class IResult implements InvocationResult {287 InvocationResult waitForReply(PacketStream stream) throws JDWPException { in waitForReply()