Lines Matching defs:worker
194 for (auto &worker : workers_) {
195 worker->set_ticket_keys(ticket_keys);
200 for (auto &worker : workers_) {
205 worker->send(std::move(wev));
211 for (auto &worker : workers_) {
217 worker->send(std::move(wev));
354 // We have dedicated worker for API request processing.
388 auto worker = std::make_unique<Worker>(
399 if (worker->create_mruby_context() != 0) {
406 worker->setup_quic_server_socket() != 0) {
411 workers_.push_back(std::move(worker));
414 LLOG(NOTICE, this) << "Created worker thread #" << workers_.size() - 1;
417 for (auto &worker : workers_) {
418 worker->run_async();
431 LLOG(INFO, this) << "Waiting for worker thread to join: n="
435 for (auto &worker : workers_) {
436 worker->wait();
451 LLOG(INFO, this) << "Sending graceful shutdown signal to worker";
454 for (auto &worker : workers_) {
458 worker->send(std::move(wev));
508 Worker *worker;
511 worker = workers_[0].get();
514 LOG(INFO) << "Dispatch connection to API worker #0";
517 worker = workers_[worker_round_robin_cnt_].get();
520 LOG(INFO) << "Dispatch connection to worker #" << worker_round_robin_cnt_;
541 worker->send(std::move(wev));
964 // Mmake sure that none of worker uses
1026 for (auto &worker : workers_) {
1028 worker->get_cid_prefix())) {
1037 worker->send(std::move(wev));
1297 for (auto &worker : workers_) {
1300 worker->get_cid_prefix())) {
1308 worker->send(std::move(wev));
1314 LOG(INFO) << "No worker to match CID prefix";