Lines Matching refs:workers_
167 workers_.clear(); in ~ConnectionHandler()
176 for (auto &worker : workers_) { in set_ticket_keys_to_worker()
186 for (auto &worker : workers_) { in worker_reopen_log_files()
198 for (auto &worker : workers_) { in worker_replace_downstream()
253 assert(workers_.size() == 0); in create_worker_thread()
309 workers_.push_back(std::move(worker)); in create_worker_thread()
312 LLOG(NOTICE, this) << "Created worker thread #" << workers_.size() - 1; in create_worker_thread()
315 for (auto &worker : workers_) { in create_worker_thread()
330 << workers_.size(); in join_worker()
333 for (auto &worker : workers_) { in join_worker()
355 for (auto &worker : workers_) { in graceful_shutdown_worker()
409 worker = workers_[0].get(); in handle_connection()
415 worker = workers_[worker_round_robin_cnt_].get(); in handle_connection()
421 if (++worker_round_robin_cnt_ == workers_.size()) { in handle_connection()