Lines Matching defs:worker
1803 auto worker = static_cast<Worker *>(w->data);
1804 auto &sessions = worker->sessions;
1808 std::lock_guard<std::mutex> lock(worker->m);
1809 q.swap(worker->q);
1819 void run_worker(Worker *worker) {
1820 auto loop = worker->sessions->get_loop();
1847 auto worker = std::make_unique<Worker>();
1849 worker->sessions = std::make_unique<Sessions>(sv, loop, config_,
1851 ev_async_init(&worker->w, worker_acceptcb);
1852 worker->w.data = worker.get();
1853 ev_async_start(loop, &worker->w);
1855 auto t = std::thread(run_worker, worker.get());
1857 workers_.push_back(std::move(worker));
1866 // Dispatch client to the one of the worker threads, in a round
1868 auto &worker = workers_[next_worker_];
1875 std::lock_guard<std::mutex> lock(worker->m);
1876 worker->q.push_back({fd});
1878 ev_async_send(worker->sessions->get_loop(), &worker->w);