Searched refs:earliestNextRunTime (Results 1 – 13 of 13) sorted by relevance
222 .earliestNextRunTime( in onTrainerStartCalled()247 .earliestNextRunTime( in onTrainerStartCalled()252 long earliestNextRunTime = in onTrainerStartCalled() local269 .earliestNextRunTime() in onTrainerStartCalled()270 .equals(earliestNextRunTime)); in onTrainerStartCalled()274 newTaskBuilder.earliestNextRunTime( in onTrainerStartCalled()275 shouldSchedule ? earliestNextRunTime : existingTask.earliestNextRunTime()); in onTrainerStartCalled()467 long earliestNextRunTime = in rescheduleFederatedTaskAfterTraining() local473 .earliestNextRunTime(earliestNextRunTime); in rescheduleFederatedTaskAfterTraining()
96 .setMinimumLatency(task.earliestNextRunTime() - nowMillis) in convertToJobInfo()
122 long existingTaskMinLatencyMillis = existingTask.earliestNextRunTime() - nowMs; in getEarliestRuntimeForExistingTask()
198 .earliestNextRunTime(1000 + DEFAULT_SCHEDULING_PERIOD_MILLIS) in testOnTrainerStartCalledSuccess()258 .earliestNextRunTime(1000 + DEFAULT_SCHEDULING_PERIOD_MILLIS) in testOnTrainerStartCalledFailureDueToTaskLimit()285 .earliestNextRunTime(1000 + DEFAULT_SCHEDULING_PERIOD_MILLIS) in testOnTrainerStartCalled_firstTime()292 .earliestNextRunTime(2000 + DEFAULT_SCHEDULING_PERIOD_MILLIS) in testOnTrainerStartCalled_firstTime()339 .earliestNextRunTime(CURRENT_TIME_MILLIS + expectedInterval) in testOnTrainerStartCalledFLWithInterval()377 .earliestNextRunTime(1000 + DEFAULT_SCHEDULING_PERIOD_MILLIS) in testOnTrainerStartCalled_multipleTimes_sameParams()427 .earliestNextRunTime(1000 + minIntervalMills) in testOnTrainerStartCalled_multipleTimes_sameParamsFLWithIntervalLargerThanServerMax()470 .earliestNextRunTime(1000L + minIntervalMills) in testOnTrainerStartCalled_multipleTimes_sameParamsFLWithIntervalDifferentMax()505 .earliestNextRunTime(2000L + newMinIntervalMills) in testOnTrainerStartCalled_multipleTimes_sameParamsFLWithIntervalDifferentMax()545 .earliestNextRunTime(1000L + minTrainingIntervalMillsByFederatedCompute) in testOnTrainerStartCalled_fLCustomerSpecifiedIntervalSmallerThanDefinedMin()[all …]
100 .earliestNextRunTime(nowMillis + 1000000) in checkAndScheduleTest()116 .earliestNextRunTime(nowMillis + 1000000) in checkAndScheduleTest()
82 .earliestNextRunTime(NEXT_RUNTIME_MILLSECONDS)
140 public abstract Long earliestNextRunTime(); in earliestNextRunTime() method in FederatedTrainingTask210 public abstract Builder earliestNextRunTime(Long earliestNextRunTime); in earliestNextRunTime() method in FederatedTrainingTask.Builder268 values.put(FederatedTrainingTaskColumns.EARLIEST_NEXT_RUN_TIME, earliestNextRunTime()); in addToDatabase()375 .earliestNextRunTime( in readFederatedTrainingTasksFromDatabase()
35 assertThat(task1.earliestNextRunTime()).isEqualTo(task2.earliestNextRunTime()); in isEqualTask()
155 assertThat(trainingTask.earliestNextRunTime()).isEqualTo(EARLIEST_NEXT_RUN_TIME); in buildFederatedTrainingTask()189 .earliestNextRunTime(EARLIEST_NEXT_RUN_TIME) in createFederatedTrainingTaskWithAllFields()208 .earliestNextRunTime(EARLIEST_NEXT_RUN_TIME) in createFederatedTrainingTaskWithRequiredFields()
367 .earliestNextRunTime(EARLIEST_NEXT_RUN_TIME) in createDefaultFederatedTrainingTask()
86 .earliestNextRunTime(123L)
456 .earliestNextRunTime(1200L) in createDefaultFederatedTrainingTask()
284 .earliestNextRunTime(TASK_EARLIEST_NEXT_RUN_TIME_MS)