Searched refs:InvocationResult (Results 1 – 6 of 6) sorted by relevance
87 std::shared_ptr<InvocationResult> result; in GetNextInternal()152 invocation_results_.push_back(std::make_shared<InvocationResult>()); in RestoreInternal()183 struct InvocationResult { struct in tensorflow::data::__anonbcbac4e00111::ParallelMapIterator201 const std::shared_ptr<InvocationResult>& result) in CallCompleted()218 const std::shared_ptr<InvocationResult>& result) in CallFunction()242 const std::shared_ptr<InvocationResult>& result, in ProcessResult()274 std::vector<std::shared_ptr<InvocationResult>> new_calls; in RunnerThread()296 invocation_results_.push_back(std::make_shared<InvocationResult>()); in RunnerThread()318 bool ShouldWait(std::shared_ptr<InvocationResult>* result) in ShouldWait()397 std::deque<std::shared_ptr<InvocationResult>> invocation_results_
311 struct InvocationResult { struct in tensorflow::data::__anon4ffa73280111::WindowDatasetOp::Dataset::Iterator312 InvocationResult() = default;313 InvocationResult(std::vector<Tensor>&& result, const Status& status) in InvocationResult() argument362 std::deque<InvocationResult> buffer_ GUARDED_BY(mu_);
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()
276 struct InvocationResult { struct in tensorflow::data::__anonaf8e7be70111::ChooseFastestDatasetOp::Dataset::ChooseFastestIterator284 std::unique_ptr<InvocationResult> result;302 threads[i].result = absl::make_unique<InvocationResult>(); in StartThreads()311 void RunnerThread(IteratorContext* ctx, InvocationResult* result, int i) { in RunnerThread()