Searched refs:worker_id_ (Results 1 – 9 of 9) sorted by relevance
45 explicit WorkerFinishedRequest(uint64_t worker_id) : worker_id_(worker_id) {} in WorkerFinishedRequest()48 thread->inspector_agent()->GetWorkerManager()->WorkerFinished(worker_id_); in Call()52 uint64_t worker_id_; member in node::inspector::__anoncc11eef80111::WorkerFinishedRequest
167 …: current_op_(current_op), child_idx_(child_idx), worker_id_(worker_id), end_epoch_(false), eof_ha… in ChildIterator()185 RETURN_IF_NOT_OK(current_op_->child(child_idx_)->GetNextRow(out_row, worker_id_)); in FetchNextTensorRow()222 RETURN_IF_NOT_OK(current_op_->child(child_idx_)->GetNextRow(&row, worker_id_)); in Drain()
122 int32_t worker_id_; // The worker id uses for fetching the child data. variable
36 int32_t worker_id_; member
77 host_release_(item.data_ptr_, item.worker_id_); in Front()
129 int32_t worker_id_; member
57 : worker_id_(worker_id), in CsvParser()176 Status s = rows_connector_->Add(worker_id_, std::move(cur_row_)); in PutRow()
92 worker_id_(0) { in CefV8IsolateManager()160 worker_id_ = worker_id; in SetWorkerAttributes()169 int worker_id() const { return worker_id_; } in worker_id()188 int worker_id_; member in __anon8cafeccc0111::CefV8IsolateManager
550 data_item.worker_id_ = worker_id; in WorkerEntry()