Cross Reference: /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/task/TaskBackend.java

Lines Matching refs:taskScheduler
123   private TaskScheduler taskScheduler;
242     taskScheduler = new TaskScheduler(serverContext, this);
243     taskScheduler.start();
275       taskScheduler.stopScheduler();
286       taskScheduler.interruptRunningTasks(TaskState.STOPPED_BY_SHUTDOWN,
319     if (taskScheduler != null)
321       return taskScheduler.getEntryCount();
382         return taskScheduler.getScheduledTaskCount() +
383             taskScheduler.getRecurringTaskCount() + 2;
388       return taskScheduler.getScheduledTaskCount();
392       return taskScheduler.getRecurringTaskCount();
402         taskScheduler.getScheduledTask(entryDN) != null)
407         taskScheduler.getRecurringTask(entryDN) != null)
429     DNLock lock = taskScheduler.readLockEntry(entryDN);
434         return taskScheduler.getTaskRootEntry();
438         return taskScheduler.getScheduledTaskParentEntry();
442         return taskScheduler.getRecurringTaskParentEntry();
453         return taskScheduler.getScheduledTaskEntry(entryDN);
457         return taskScheduler.getRecurringTaskEntry(entryDN);
496       Task task = taskScheduler.entryToScheduledTask(e, addOperation);
497       taskScheduler.scheduleTask(task, true);
505       RecurringTask recurringTask = taskScheduler.entryToRecurringTask(e);
506       taskScheduler.addRecurringTask(recurringTask, true);
534       Task t = taskScheduler.getScheduledTask(entryDN);
548           taskScheduler.removePendingTask(t.getTaskID());
556           taskScheduler.scheduleNextRecurringTaskIteration(t,
559           taskScheduler.removePendingTask(t.getTaskID());
564         taskScheduler.removeCompletedTask(t.getTaskID());
575       RecurringTask rt = taskScheduler.getRecurringTask(entryDN);
582       taskScheduler.removeRecurringTask(rt.getRecurringTaskID());
600     if (! taskScheduler.holdsSchedulerLock())
623         Task t = taskScheduler.getScheduledTask(entryDN);
637           Task newTask = taskScheduler.entryToScheduledTask(newEntry,
639           taskScheduler.removePendingTask(t.getTaskID());
640           taskScheduler.scheduleTask(newTask, true);
669             Task newTask = taskScheduler.entryToScheduledTask(newEntry,
674               taskScheduler.removePendingTask(t.getTaskID());
682               taskScheduler.scheduleNextRecurringTaskIteration(
875         DNLock lock = taskScheduler.readLockEntry(baseDN);
878           Entry e = taskScheduler.getScheduledTaskEntry(baseDN);
901         DNLock lock = taskScheduler.readLockEntry(baseDN);
904           Entry e = taskScheduler.getRecurringTaskEntry(baseDN);
935       Entry e = taskScheduler.getTaskRootEntry();
945       Entry e = taskScheduler.getScheduledTaskParentEntry();
954         && !taskScheduler.searchScheduledTasks(searchOperation))
962       Entry e = taskScheduler.getRecurringTaskParentEntry();
971         && !taskScheduler.searchRecurringTasks(searchOperation))
1280         taskScheduler.writeState();
1416     return taskScheduler.getScheduledTask(taskEntryDN);
1432     return taskScheduler.getRecurringTask(taskEntryDN);