Lines Matching defs:workers
244 s->delegate(), s->source(), s->routing_info(), s->workers()));
287 old->source(), old->routing_info(), old->workers()));
395 s->source(), s->routing_info(), s->workers()));
405 // Helper to extract the routing info and workers corresponding to types in
409 std::vector<ModelSafeWorker*>* workers) {
427 iter it2 = std::find_if(workers->begin(), workers->end(),
429 if (it2 == workers->end())
430 workers->push_back(*it);
444 workers->push_back(*it);
458 workers;
460 &routes, &workers);
463 this, &SyncerThread::ScheduleConfigImpl, routes, workers,
468 const std::vector<ModelSafeWorker*>& workers,
478 routing_info, workers);
657 old_job.session->workers(),
698 old->source(), old->routing_info(), old->workers()));
796 std::vector<ModelSafeWorker*> workers;
798 session_context_->registrar()->GetWorkers(&workers);
802 routes, workers));
