Lines Matching refs:workers
244 s->delegate(), s->source(), s->routing_info(), s->workers())); in InitOrCoalescePendingJob()
287 old->source(), old->routing_info(), old->workers())); in SaveJob()
395 s->source(), s->routing_info(), s->workers())); in ScheduleNudgeImpl()
409 std::vector<ModelSafeWorker*>* workers) { in GetModelSafeParamsForTypes() argument
427 iter it2 = std::find_if(workers->begin(), workers->end(), in GetModelSafeParamsForTypes()
429 if (it2 == workers->end()) in GetModelSafeParamsForTypes()
430 workers->push_back(*it); in GetModelSafeParamsForTypes()
444 workers->push_back(*it); in GetModelSafeParamsForTypes()
458 std::vector<ModelSafeWorker*> workers; in ScheduleConfig() local
460 &routes, &workers); in ScheduleConfig()
463 this, &SyncerThread::ScheduleConfigImpl, routes, workers, in ScheduleConfig()
468 const std::vector<ModelSafeWorker*>& workers, in ScheduleConfigImpl() argument
478 routing_info, workers); in ScheduleConfigImpl()
657 old_job.session->workers(), in ScheduleNextSync()
698 old->source(), old->routing_info(), old->workers())); in HandleConsecutiveContinuationError()
796 std::vector<ModelSafeWorker*> workers; in CreateSyncSession() local
798 session_context_->registrar()->GetWorkers(&workers); in CreateSyncSession()
802 routes, workers)); in CreateSyncSession()