/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkerThread.java | 79 private Thread workerThread; field in class:ParallelWorkerThread 105 workerThread = null; 145 workerThread = currentThread(); 267 workerThread.interrupt();
|
H A D | TraditionalWorkerThread.java | 79 private Thread workerThread; field in class:TraditionalWorkerThread 105 workerThread = null; 145 workerThread = currentThread(); 269 workerThread.interrupt();
|
H A D | ParallelWorkQueue.java | 305 * @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 D | TraditionalWorkQueue.java | 441 * @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 D | ParallelWorkerThread.java | 78 private Thread workerThread; field in class:ParallelWorkerThread 104 workerThread = null; 144 workerThread = currentThread(); 266 workerThread.interrupt();
|
H A D | TraditionalWorkerThread.java | 76 private Thread workerThread; field in class:TraditionalWorkerThread 102 workerThread = null; 142 workerThread = currentThread(); 266 workerThread.interrupt();
|
H A D | ParallelWorkQueue.java | 304 * @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 D | TraditionalWorkQueue.java | 440 * @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 D | ParallelWorkerThread.java | 79 private Thread workerThread; field in class:ParallelWorkerThread 105 workerThread = null; 145 workerThread = currentThread(); 267 workerThread.interrupt();
|
H A D | TraditionalWorkerThread.java | 79 private Thread workerThread; field in class:TraditionalWorkerThread 105 workerThread = null; 145 workerThread = currentThread(); 269 workerThread.interrupt();
|
H A D | ParallelWorkQueue.java | 305 * @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 D | TraditionalWorkQueue.java | 441 * @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 D | ParallelWorkerThread.java | 79 private Thread workerThread; field in class:ParallelWorkerThread 105 workerThread = null; 145 workerThread = currentThread(); 267 workerThread.interrupt();
|
H A D | TraditionalWorkerThread.java | 79 private Thread workerThread; field in class:TraditionalWorkerThread 105 workerThread = null; 145 workerThread = currentThread(); 269 workerThread.interrupt();
|
H A D | ParallelWorkQueue.java | 305 * @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 D | TraditionalWorkQueue.java | 441 * @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 D | ParallelWorkerThread.java | 78 private Thread workerThread; field in class:ParallelWorkerThread 104 workerThread = null; 144 workerThread = currentThread(); 266 workerThread.interrupt();
|
H A D | TraditionalWorkerThread.java | 76 private Thread workerThread; field in class:TraditionalWorkerThread 102 workerThread = null; 142 workerThread = currentThread(); 266 workerThread.interrupt();
|
H A D | ParallelWorkQueue.java | 304 * @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 D | TraditionalWorkQueue.java | 440 * @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 D | ParallelWorkerThread.java | 72 private Thread workerThread; field in class:ParallelWorkerThread 98 workerThread = null; 138 workerThread = currentThread(); 253 workerThread.interrupt();
|
H A D | TraditionalWorkerThread.java | 70 private Thread workerThread; field in class:TraditionalWorkerThread 96 workerThread = null; 136 workerThread = currentThread(); 253 workerThread.interrupt();
|
H A D | ParallelWorkQueue.java | 273 * @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 D | TraditionalWorkQueue.java | 409 * @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...] |