Searched refs:current_worker (Results 1 – 2 of 2) sorted by relevance
165 struct current_worker : public worker_interface struct169 current_worker(const this_type&);171 current_worker() in current_worker() argument174 virtual ~current_worker() in ~current_worker() argument237 std::shared_ptr<current_worker> wi;241 : wi(std::make_shared<current_worker>()) in current_thread()
280 WorkerState* current_worker = &workers_[current_worker_index]; in GetNextInternal() local281 can_produce_elements |= current_worker->MayHaveElements(); in GetNextInternal()282 if (!current_worker->outputs.empty()) { in GetNextInternal()300 Status s = current_worker->outputs.front().status; in GetNextInternal()301 current_worker->outputs.front().output.swap(*out_tensors); in GetNextInternal()302 current_worker->outputs.pop_front(); in GetNextInternal()303 current_worker->cond_var.notify_one(); in GetNextInternal()305 } else if (current_worker->is_producing && !dataset()->sloppy_) { in GetNextInternal()314 } else if (!current_worker->is_producing) { in GetNextInternal()325 current_worker->SetInputs(s, std::move(args)); in GetNextInternal()