Searched refs:taskScheduler (Results 1 - 24 of 24) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/backends/task/
H A DTaskThread.java62 private TaskScheduler taskScheduler; field in class:TaskThread
75 * @param taskScheduler The reference to the task scheduler with which this
79 public TaskThread(TaskScheduler taskScheduler, int threadID) argument
84 this.taskScheduler = taskScheduler;
228 if (! taskScheduler.threadDone(this, completedTask, taskState))
239 taskScheduler.threadDone(this, task, taskState);
H A DTaskBackend.java115 private TaskScheduler taskScheduler; field in class:TaskBackend
239 taskScheduler = new TaskScheduler(this);
240 taskScheduler.start();
276 taskScheduler.stopScheduler();
291 taskScheduler.interruptRunningTasks(TaskState.STOPPED_BY_SHUTDOWN,
330 if (taskScheduler != null)
332 return taskScheduler.getEntryCount();
401 return taskScheduler.getScheduledTaskCount() +
402 taskScheduler.getRecurringTaskCount() + 2;
407 return taskScheduler
[all...]
H A DTask.java135 private TaskScheduler taskScheduler; field in class:Task
170 * @param taskScheduler The scheduler with which this task is associated.
176 public final void initializeTaskInternal(TaskScheduler taskScheduler, argument
180 this.taskScheduler = taskScheduler;
186 taskBackend = taskScheduler.getTaskBackend();
606 boolean needLock = (! taskScheduler.holdsSchedulerLock());
610 lock = taskScheduler.writeLockEntry(taskEntryDN);
626 taskScheduler.unlockEntry(taskEntryDN, lock);
698 boolean needLock = (! taskScheduler
[all...]
H A DRecurringTask.java93 private final TaskScheduler taskScheduler; field in class:RecurringTask
135 * @param taskScheduler A reference to the task scheduler that may be
143 public RecurringTask(TaskScheduler taskScheduler, Entry recurringTaskEntry) argument
146 this.taskScheduler = taskScheduler;
333 task.initializeTaskInternal(taskScheduler, recurringTaskEntry);
446 taskScheduler.getTaskBackend().getScheduledTasksParentDN());
457 nextTask.initializeTaskInternal(taskScheduler, nextTaskEntry);
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/task/
H A DTaskThread.java68 private TaskScheduler taskScheduler; field in class:TaskThread
79 * @param taskScheduler The reference to the task scheduler with which this
83 public TaskThread(TaskScheduler taskScheduler, int threadID) argument
88 this.taskScheduler = taskScheduler;
232 if (! taskScheduler.threadDone(this, completedTask, taskState))
243 taskScheduler.threadDone(this, task, taskState);
H A DTaskBackend.java119 private TaskScheduler taskScheduler; field in class:TaskBackend
256 taskScheduler = new TaskScheduler(this);
257 taskScheduler.start();
295 taskScheduler.stopScheduler();
310 taskScheduler.interruptRunningTasks(TaskState.STOPPED_BY_SHUTDOWN,
353 if (taskScheduler != null)
355 return taskScheduler.getEntryCount();
432 return taskScheduler.getScheduledTaskCount() +
433 taskScheduler.getRecurringTaskCount() + 2;
438 return taskScheduler
[all...]
H A DTask.java136 private TaskScheduler taskScheduler; field in class:Task
171 * @param taskScheduler The scheduler with which this task is associated.
177 public final void initializeTaskInternal(TaskScheduler taskScheduler, argument
181 this.taskScheduler = taskScheduler;
187 taskBackend = taskScheduler.getTaskBackend();
607 boolean needLock = (! taskScheduler.holdsSchedulerLock());
611 lock = taskScheduler.writeLockEntry(taskEntryDN);
627 taskScheduler.unlockEntry(taskEntryDN, lock);
699 boolean needLock = (! taskScheduler
[all...]
H A DRecurringTask.java98 private final TaskScheduler taskScheduler; field in class:RecurringTask
145 * @param taskScheduler A reference to the task scheduler that may be
153 public RecurringTask(TaskScheduler taskScheduler, Entry recurringTaskEntry) argument
156 this.taskScheduler = taskScheduler;
343 task.initializeTaskInternal(taskScheduler, recurringTaskEntry);
456 taskScheduler.getTaskBackend().getScheduledTasksParentDN());
467 nextTask.initializeTaskInternal(taskScheduler, nextTaskEntry);
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/task/
H A DTaskThread.java68 private TaskScheduler taskScheduler; field in class:TaskThread
79 * @param taskScheduler The reference to the task scheduler with which this
83 public TaskThread(TaskScheduler taskScheduler, int threadID) argument
88 this.taskScheduler = taskScheduler;
232 if (! taskScheduler.threadDone(this, completedTask, taskState))
243 taskScheduler.threadDone(this, task, taskState);
H A DTaskBackend.java119 private TaskScheduler taskScheduler; field in class:TaskBackend
256 taskScheduler = new TaskScheduler(this);
257 taskScheduler.start();
295 taskScheduler.stopScheduler();
310 taskScheduler.interruptRunningTasks(TaskState.STOPPED_BY_SHUTDOWN,
353 if (taskScheduler != null)
355 return taskScheduler.getEntryCount();
432 return taskScheduler.getScheduledTaskCount() +
433 taskScheduler.getRecurringTaskCount() + 2;
438 return taskScheduler
[all...]
H A DTask.java136 private TaskScheduler taskScheduler; field in class:Task
171 * @param taskScheduler The scheduler with which this task is associated.
177 public final void initializeTaskInternal(TaskScheduler taskScheduler, argument
181 this.taskScheduler = taskScheduler;
187 taskBackend = taskScheduler.getTaskBackend();
607 boolean needLock = (! taskScheduler.holdsSchedulerLock());
611 lock = taskScheduler.writeLockEntry(taskEntryDN);
627 taskScheduler.unlockEntry(taskEntryDN, lock);
699 boolean needLock = (! taskScheduler
[all...]
H A DRecurringTask.java98 private final TaskScheduler taskScheduler; field in class:RecurringTask
145 * @param taskScheduler A reference to the task scheduler that may be
153 public RecurringTask(TaskScheduler taskScheduler, Entry recurringTaskEntry) argument
156 this.taskScheduler = taskScheduler;
343 task.initializeTaskInternal(taskScheduler, recurringTaskEntry);
456 taskScheduler.getTaskBackend().getScheduledTasksParentDN());
467 nextTask.initializeTaskInternal(taskScheduler, nextTaskEntry);
/forgerock/opendj2-hg/src/server/org/opends/server/backends/task/
H A DTaskThread.java62 private TaskScheduler taskScheduler; field in class:TaskThread
75 * @param taskScheduler The reference to the task scheduler with which this
79 public TaskThread(TaskScheduler taskScheduler, int threadID) argument
84 this.taskScheduler = taskScheduler;
228 if (! taskScheduler.threadDone(this, completedTask, taskState))
239 taskScheduler.threadDone(this, task, taskState);
H A DTaskBackend.java115 private TaskScheduler taskScheduler; field in class:TaskBackend
239 taskScheduler = new TaskScheduler(this);
240 taskScheduler.start();
276 taskScheduler.stopScheduler();
291 taskScheduler.interruptRunningTasks(TaskState.STOPPED_BY_SHUTDOWN,
330 if (taskScheduler != null)
332 return taskScheduler.getEntryCount();
401 return taskScheduler.getScheduledTaskCount() +
402 taskScheduler.getRecurringTaskCount() + 2;
407 return taskScheduler
[all...]
H A DTask.java135 private TaskScheduler taskScheduler; field in class:Task
170 * @param taskScheduler The scheduler with which this task is associated.
176 public final void initializeTaskInternal(TaskScheduler taskScheduler, argument
180 this.taskScheduler = taskScheduler;
186 taskBackend = taskScheduler.getTaskBackend();
606 boolean needLock = (! taskScheduler.holdsSchedulerLock());
610 lock = taskScheduler.writeLockEntry(taskEntryDN);
626 taskScheduler.unlockEntry(taskEntryDN, lock);
698 boolean needLock = (! taskScheduler
[all...]
H A DRecurringTask.java93 private final TaskScheduler taskScheduler; field in class:RecurringTask
135 * @param taskScheduler A reference to the task scheduler that may be
143 public RecurringTask(TaskScheduler taskScheduler, Entry recurringTaskEntry) argument
146 this.taskScheduler = taskScheduler;
333 task.initializeTaskInternal(taskScheduler, recurringTaskEntry);
446 taskScheduler.getTaskBackend().getScheduledTasksParentDN());
457 nextTask.initializeTaskInternal(taskScheduler, nextTaskEntry);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/task/
H A DTaskThread.java68 private TaskScheduler taskScheduler; field in class:TaskThread
79 * @param taskScheduler The reference to the task scheduler with which this
83 public TaskThread(TaskScheduler taskScheduler, int threadID) argument
88 this.taskScheduler = taskScheduler;
232 if (! taskScheduler.threadDone(this, completedTask, taskState))
243 taskScheduler.threadDone(this, task, taskState);
H A DTaskBackend.java119 private TaskScheduler taskScheduler; field in class:TaskBackend
256 taskScheduler = new TaskScheduler(this);
257 taskScheduler.start();
295 taskScheduler.stopScheduler();
310 taskScheduler.interruptRunningTasks(TaskState.STOPPED_BY_SHUTDOWN,
353 if (taskScheduler != null)
355 return taskScheduler.getEntryCount();
432 return taskScheduler.getScheduledTaskCount() +
433 taskScheduler.getRecurringTaskCount() + 2;
438 return taskScheduler
[all...]
H A DTask.java136 private TaskScheduler taskScheduler; field in class:Task
171 * @param taskScheduler The scheduler with which this task is associated.
177 public final void initializeTaskInternal(TaskScheduler taskScheduler, argument
181 this.taskScheduler = taskScheduler;
187 taskBackend = taskScheduler.getTaskBackend();
607 boolean needLock = (! taskScheduler.holdsSchedulerLock());
611 lock = taskScheduler.writeLockEntry(taskEntryDN);
627 taskScheduler.unlockEntry(taskEntryDN, lock);
699 boolean needLock = (! taskScheduler
[all...]
H A DRecurringTask.java98 private final TaskScheduler taskScheduler; field in class:RecurringTask
145 * @param taskScheduler A reference to the task scheduler that may be
153 public RecurringTask(TaskScheduler taskScheduler, Entry recurringTaskEntry) argument
156 this.taskScheduler = taskScheduler;
343 task.initializeTaskInternal(taskScheduler, recurringTaskEntry);
456 taskScheduler.getTaskBackend().getScheduledTasksParentDN());
467 nextTask.initializeTaskInternal(taskScheduler, nextTaskEntry);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/task/
H A DTaskThread.java56 private TaskScheduler taskScheduler; field in class:TaskThread
69 * @param taskScheduler The reference to the task scheduler with which this
73 public TaskThread(TaskScheduler taskScheduler, int threadID) argument
78 this.taskScheduler = taskScheduler;
206 if (! taskScheduler.threadDone(this, completedTask, taskState))
217 taskScheduler.threadDone(this, task, taskState);
H A DTaskBackend.java123 private TaskScheduler taskScheduler; field in class:TaskBackend
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
[all...]
H A DTask.java128 private TaskScheduler taskScheduler; field in class:Task
176 * @param taskScheduler The scheduler with which this task is associated.
182 public final void initializeTaskInternal(ServerContext serverContext, TaskScheduler taskScheduler, argument
187 this.taskScheduler = taskScheduler;
193 taskBackend = taskScheduler.getTaskBackend();
496 if (!taskScheduler.holdsSchedulerLock())
498 lock = taskScheduler.writeLockEntry(taskEntryDN);
575 if (!taskScheduler.holdsSchedulerLock())
577 lock = taskScheduler
[all...]
H A DRecurringTask.java90 private final TaskScheduler taskScheduler; field in class:RecurringTask
137 * @param taskScheduler A reference to the task scheduler that may be
145 public RecurringTask(ServerContext serverContext, TaskScheduler taskScheduler, Entry recurringTaskEntry) argument
149 this.taskScheduler = taskScheduler;
306 task.initializeTaskInternal(serverContext, taskScheduler, recurringTaskEntry);
409 taskScheduler.getTaskBackend().getScheduledTasksParentDN());
417 nextTask.initializeTaskInternal(serverContext, taskScheduler, nextTaskEntry);

Completed in 94 milliseconds