Searched refs:workers_ (Results 1 – 5 of 5) sorted by relevance
36 : workers_(workers) {} in AgentWorkerInspectorDelegate()42 workers_->WorkerCreated(title, url, waiting, target); in WorkerCreated()46 std::shared_ptr<NodeWorkers> workers_; member in node::inspector::protocol::__anonc0e9eb9d0111::AgentWorkerInspectorDelegate53 : id_(id), workers_(workers) {} in ParentInspectorSessionDelegate()56 workers_->Detached(id_); in ~ParentInspectorSessionDelegate()61 workers_->Send(id_, message); in SendMessageToFrontend()66 std::shared_ptr<NodeWorkers> workers_; member in node::inspector::protocol::__anonc0e9eb9d0111::ParentInspectorSessionDelegate89 workers_ = in Wire()95 workers_->Receive(sessionId, message); in sendMessageToWorker()106 new AgentWorkerInspectorDelegate(workers_)); in enable()[all …]
34 std::shared_ptr<NodeWorkers> workers_; variable
185 workers_.clear(); in ~ConnectionHandler()194 for (auto &worker : workers_) { in set_ticket_keys_to_worker()200 for (auto &worker : workers_) { in worker_reopen_log_files()211 for (auto &worker : workers_) { in worker_replace_downstream()311 assert(workers_.size() == 0); in create_worker_thread()411 workers_.push_back(std::move(worker)); in create_worker_thread()414 LLOG(NOTICE, this) << "Created worker thread #" << workers_.size() - 1; in create_worker_thread()417 for (auto &worker : workers_) { in create_worker_thread()432 << workers_.size(); in join_worker()435 for (auto &worker : workers_) { in join_worker()[all …]
282 std::vector<std::unique_ptr<Worker>> workers_; variable
1857 workers_.push_back(std::move(worker)); in AcceptHandler()1868 auto &worker = workers_[next_worker_]; in accept_connection()1882 std::vector<std::unique_ptr<Worker>> workers_; member in nghttp2::AcceptHandler