/forgerock/opendj2/src/server/org/opends/server/backends/task/ |
H A D | TaskThread.java | 62 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 D | TaskBackend.java | 115 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 D | Task.java | 135 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 D | RecurringTask.java | 93 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 D | TaskThread.java | 68 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 D | TaskBackend.java | 119 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 D | Task.java | 136 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 D | RecurringTask.java | 98 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 D | TaskThread.java | 68 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 D | TaskBackend.java | 119 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 D | Task.java | 136 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 D | RecurringTask.java | 98 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 D | TaskThread.java | 62 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 D | TaskBackend.java | 115 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 D | Task.java | 135 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 D | RecurringTask.java | 93 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 D | TaskThread.java | 68 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 D | TaskBackend.java | 119 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 D | Task.java | 136 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 D | RecurringTask.java | 98 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 D | TaskThread.java | 56 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 D | TaskBackend.java | 123 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 D | Task.java | 128 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 D | RecurringTask.java | 90 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);
|