Searched defs:workerThread (Results 1 - 24 of 24) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java79 private Thread workerThread; field in class:ParallelWorkerThread
105 workerThread = null;
145 workerThread = currentThread();
267 workerThread.interrupt();
H A DTraditionalWorkerThread.java79 private Thread workerThread; field in class:TraditionalWorkerThread
105 workerThread = null;
145 workerThread = currentThread();
269 workerThread.interrupt();
H A DParallelWorkQueue.java305 * @param workerThread The worker thread that is requesting the operation.
311 public Operation nextOperation(ParallelWorkerThread workerThread) argument
313 return retryNextOperation(workerThread, 0);
324 * @param workerThread The worker thread that is requesting the operation.
335 ParallelWorkerThread workerThread,
360 workerThread.setStoppedByReducedThreadNumber();
421 workerThread.setStoppedByReducedThreadNumber();
452 return retryNextOperation(workerThread, numFailures + 1);
334 retryNextOperation( ParallelWorkerThread workerThread, int numFailures) argument
H A DTraditionalWorkQueue.java441 * @param workerThread
447 public Operation nextOperation(TraditionalWorkerThread workerThread) argument
449 return retryNextOperation(workerThread, 0);
460 * @param workerThread
470 private Operation retryNextOperation(TraditionalWorkerThread workerThread, argument
484 if (killThreads && tryKillThisWorkerThread(workerThread))
518 if (killThreads && tryKillThisWorkerThread(workerThread))
560 return retryNextOperation(workerThread, numFailures + 1);
569 * @param workerThread
574 private boolean tryKillThisWorkerThread(TraditionalWorkerThread workerThread) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java78 private Thread workerThread; field in class:ParallelWorkerThread
104 workerThread = null;
144 workerThread = currentThread();
266 workerThread.interrupt();
H A DTraditionalWorkerThread.java76 private Thread workerThread; field in class:TraditionalWorkerThread
102 workerThread = null;
142 workerThread = currentThread();
266 workerThread.interrupt();
H A DParallelWorkQueue.java304 * @param workerThread The worker thread that is requesting the operation.
310 public Operation nextOperation(ParallelWorkerThread workerThread) argument
312 return retryNextOperation(workerThread, 0);
323 * @param workerThread The worker thread that is requesting the operation.
334 ParallelWorkerThread workerThread,
359 workerThread.setStoppedByReducedThreadNumber();
420 workerThread.setStoppedByReducedThreadNumber();
451 return retryNextOperation(workerThread, numFailures + 1);
333 retryNextOperation( ParallelWorkerThread workerThread, int numFailures) argument
H A DTraditionalWorkQueue.java440 * @param workerThread
446 public Operation nextOperation(TraditionalWorkerThread workerThread) argument
448 return retryNextOperation(workerThread, 0);
459 * @param workerThread
469 private Operation retryNextOperation(TraditionalWorkerThread workerThread, argument
483 if (killThreads && tryKillThisWorkerThread(workerThread))
517 if (killThreads && tryKillThisWorkerThread(workerThread))
559 return retryNextOperation(workerThread, numFailures + 1);
568 * @param workerThread
573 private boolean tryKillThisWorkerThread(TraditionalWorkerThread workerThread) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java79 private Thread workerThread; field in class:ParallelWorkerThread
105 workerThread = null;
145 workerThread = currentThread();
267 workerThread.interrupt();
H A DTraditionalWorkerThread.java79 private Thread workerThread; field in class:TraditionalWorkerThread
105 workerThread = null;
145 workerThread = currentThread();
269 workerThread.interrupt();
H A DParallelWorkQueue.java305 * @param workerThread The worker thread that is requesting the operation.
311 public Operation nextOperation(ParallelWorkerThread workerThread) argument
313 return retryNextOperation(workerThread, 0);
324 * @param workerThread The worker thread that is requesting the operation.
335 ParallelWorkerThread workerThread,
360 workerThread.setStoppedByReducedThreadNumber();
421 workerThread.setStoppedByReducedThreadNumber();
452 return retryNextOperation(workerThread, numFailures + 1);
334 retryNextOperation( ParallelWorkerThread workerThread, int numFailures) argument
H A DTraditionalWorkQueue.java441 * @param workerThread
447 public Operation nextOperation(TraditionalWorkerThread workerThread) argument
449 return retryNextOperation(workerThread, 0);
460 * @param workerThread
470 private Operation retryNextOperation(TraditionalWorkerThread workerThread, argument
484 if (killThreads && tryKillThisWorkerThread(workerThread))
518 if (killThreads && tryKillThisWorkerThread(workerThread))
560 return retryNextOperation(workerThread, numFailures + 1);
569 * @param workerThread
574 private boolean tryKillThisWorkerThread(TraditionalWorkerThread workerThread) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java79 private Thread workerThread; field in class:ParallelWorkerThread
105 workerThread = null;
145 workerThread = currentThread();
267 workerThread.interrupt();
H A DTraditionalWorkerThread.java79 private Thread workerThread; field in class:TraditionalWorkerThread
105 workerThread = null;
145 workerThread = currentThread();
269 workerThread.interrupt();
H A DParallelWorkQueue.java305 * @param workerThread The worker thread that is requesting the operation.
311 public Operation nextOperation(ParallelWorkerThread workerThread) argument
313 return retryNextOperation(workerThread, 0);
324 * @param workerThread The worker thread that is requesting the operation.
335 ParallelWorkerThread workerThread,
360 workerThread.setStoppedByReducedThreadNumber();
421 workerThread.setStoppedByReducedThreadNumber();
452 return retryNextOperation(workerThread, numFailures + 1);
334 retryNextOperation( ParallelWorkerThread workerThread, int numFailures) argument
H A DTraditionalWorkQueue.java441 * @param workerThread
447 public Operation nextOperation(TraditionalWorkerThread workerThread) argument
449 return retryNextOperation(workerThread, 0);
460 * @param workerThread
470 private Operation retryNextOperation(TraditionalWorkerThread workerThread, argument
484 if (killThreads && tryKillThisWorkerThread(workerThread))
518 if (killThreads && tryKillThisWorkerThread(workerThread))
560 return retryNextOperation(workerThread, numFailures + 1);
569 * @param workerThread
574 private boolean tryKillThisWorkerThread(TraditionalWorkerThread workerThread) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java78 private Thread workerThread; field in class:ParallelWorkerThread
104 workerThread = null;
144 workerThread = currentThread();
266 workerThread.interrupt();
H A DTraditionalWorkerThread.java76 private Thread workerThread; field in class:TraditionalWorkerThread
102 workerThread = null;
142 workerThread = currentThread();
266 workerThread.interrupt();
H A DParallelWorkQueue.java304 * @param workerThread The worker thread that is requesting the operation.
310 public Operation nextOperation(ParallelWorkerThread workerThread) argument
312 return retryNextOperation(workerThread, 0);
323 * @param workerThread The worker thread that is requesting the operation.
334 ParallelWorkerThread workerThread,
359 workerThread.setStoppedByReducedThreadNumber();
420 workerThread.setStoppedByReducedThreadNumber();
451 return retryNextOperation(workerThread, numFailures + 1);
333 retryNextOperation( ParallelWorkerThread workerThread, int numFailures) argument
H A DTraditionalWorkQueue.java440 * @param workerThread
446 public Operation nextOperation(TraditionalWorkerThread workerThread) argument
448 return retryNextOperation(workerThread, 0);
459 * @param workerThread
469 private Operation retryNextOperation(TraditionalWorkerThread workerThread, argument
483 if (killThreads && tryKillThisWorkerThread(workerThread))
517 if (killThreads && tryKillThisWorkerThread(workerThread))
559 return retryNextOperation(workerThread, numFailures + 1);
568 * @param workerThread
573 private boolean tryKillThisWorkerThread(TraditionalWorkerThread workerThread) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/
H A DParallelWorkerThread.java72 private Thread workerThread; field in class:ParallelWorkerThread
98 workerThread = null;
138 workerThread = currentThread();
253 workerThread.interrupt();
H A DTraditionalWorkerThread.java70 private Thread workerThread; field in class:TraditionalWorkerThread
96 workerThread = null;
136 workerThread = currentThread();
253 workerThread.interrupt();
H A DParallelWorkQueue.java273 * @param workerThread The worker thread that is requesting the operation.
279 public Operation nextOperation(ParallelWorkerThread workerThread) argument
281 return retryNextOperation(workerThread, 0);
292 * @param workerThread The worker thread that is requesting the operation.
303 ParallelWorkerThread workerThread,
328 workerThread.setStoppedByReducedThreadNumber();
385 workerThread.setStoppedByReducedThreadNumber();
409 return retryNextOperation(workerThread, numFailures + 1);
302 retryNextOperation( ParallelWorkerThread workerThread, int numFailures) argument
H A DTraditionalWorkQueue.java409 * @param workerThread
415 public Operation nextOperation(TraditionalWorkerThread workerThread) argument
417 return retryNextOperation(workerThread, 0);
428 * @param workerThread
438 private Operation retryNextOperation(TraditionalWorkerThread workerThread, argument
452 if (killThreads && tryKillThisWorkerThread(workerThread))
485 if (killThreads && tryKillThisWorkerThread(workerThread))
522 return retryNextOperation(workerThread, numFailures + 1);
531 * @param workerThread
536 private boolean tryKillThisWorkerThread(TraditionalWorkerThread workerThread) argument
[all...]

Completed in 82 milliseconds