/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 114 private ConcurrentLinkedQueue<Operation> opQueue; field in class:ParallelWorkQueue 153 opQueue = new ConcurrentLinkedQueue<Operation>(); 204 opQueue.removeAll(pendingOperations); 284 opQueue.add(operation); 392 nextOperation = opQueue.poll(); 469 return opQueue.remove(operation); 501 return opQueue.size(); 578 if (opQueue.size() > 0) {
|
H A D | TraditionalWorkQueue.java | 134 private LinkedBlockingQueue<Operation> opQueue; field in class:TraditionalWorkQueue 192 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity); 198 opQueue = new LinkedBlockingQueue<Operation>(); 263 opQueue.removeAll(pendingOperations); 390 while (!opQueue.offer(operation, 1, TimeUnit.SECONDS)) 417 if (!opQueue.offer(operation)) 500 Operation nextOperation = opQueue.poll(5, TimeUnit.SECONDS); 665 return opQueue.size(); 763 oldOpQueue = opQueue; 764 opQueue [all...] |
/forgerock/opendj2/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 113 private ConcurrentLinkedQueue<Operation> opQueue; field in class:ParallelWorkQueue 152 opQueue = new ConcurrentLinkedQueue<Operation>(); 203 opQueue.removeAll(pendingOperations); 283 opQueue.add(operation); 391 nextOperation = opQueue.poll(); 468 return opQueue.remove(operation); 500 return opQueue.size(); 577 if (opQueue.size() > 0) {
|
H A D | TraditionalWorkQueue.java | 133 private LinkedBlockingQueue<Operation> opQueue; field in class:TraditionalWorkQueue 191 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity); 197 opQueue = new LinkedBlockingQueue<Operation>(); 262 opQueue.removeAll(pendingOperations); 389 while (!opQueue.offer(operation, 1, TimeUnit.SECONDS)) 416 if (!opQueue.offer(operation)) 499 Operation nextOperation = opQueue.poll(5, TimeUnit.SECONDS); 664 return opQueue.size(); 762 oldOpQueue = opQueue; 763 opQueue [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 114 private ConcurrentLinkedQueue<Operation> opQueue; field in class:ParallelWorkQueue 153 opQueue = new ConcurrentLinkedQueue<Operation>(); 204 opQueue.removeAll(pendingOperations); 284 opQueue.add(operation); 392 nextOperation = opQueue.poll(); 469 return opQueue.remove(operation); 501 return opQueue.size(); 578 if (opQueue.size() > 0) {
|
H A D | TraditionalWorkQueue.java | 134 private LinkedBlockingQueue<Operation> opQueue; field in class:TraditionalWorkQueue 192 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity); 198 opQueue = new LinkedBlockingQueue<Operation>(); 263 opQueue.removeAll(pendingOperations); 390 while (!opQueue.offer(operation, 1, TimeUnit.SECONDS)) 417 if (!opQueue.offer(operation)) 500 Operation nextOperation = opQueue.poll(5, TimeUnit.SECONDS); 665 return opQueue.size(); 763 oldOpQueue = opQueue; 764 opQueue [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 114 private ConcurrentLinkedQueue<Operation> opQueue; field in class:ParallelWorkQueue 153 opQueue = new ConcurrentLinkedQueue<Operation>(); 204 opQueue.removeAll(pendingOperations); 284 opQueue.add(operation); 392 nextOperation = opQueue.poll(); 469 return opQueue.remove(operation); 501 return opQueue.size(); 578 if (opQueue.size() > 0) {
|
H A D | TraditionalWorkQueue.java | 134 private LinkedBlockingQueue<Operation> opQueue; field in class:TraditionalWorkQueue 192 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity); 198 opQueue = new LinkedBlockingQueue<Operation>(); 263 opQueue.removeAll(pendingOperations); 390 while (!opQueue.offer(operation, 1, TimeUnit.SECONDS)) 417 if (!opQueue.offer(operation)) 500 Operation nextOperation = opQueue.poll(5, TimeUnit.SECONDS); 665 return opQueue.size(); 763 oldOpQueue = opQueue; 764 opQueue [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 113 private ConcurrentLinkedQueue<Operation> opQueue; field in class:ParallelWorkQueue 152 opQueue = new ConcurrentLinkedQueue<Operation>(); 203 opQueue.removeAll(pendingOperations); 283 opQueue.add(operation); 391 nextOperation = opQueue.poll(); 468 return opQueue.remove(operation); 500 return opQueue.size(); 577 if (opQueue.size() > 0) {
|
H A D | TraditionalWorkQueue.java | 133 private LinkedBlockingQueue<Operation> opQueue; field in class:TraditionalWorkQueue 191 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity); 197 opQueue = new LinkedBlockingQueue<Operation>(); 262 opQueue.removeAll(pendingOperations); 389 while (!opQueue.offer(operation, 1, TimeUnit.SECONDS)) 416 if (!opQueue.offer(operation)) 499 Operation nextOperation = opQueue.poll(5, TimeUnit.SECONDS); 664 return opQueue.size(); 762 oldOpQueue = opQueue; 763 opQueue [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 103 private ConcurrentLinkedQueue<Operation> opQueue; field in class:ParallelWorkQueue 140 opQueue = new ConcurrentLinkedQueue<>(); 182 opQueue.removeAll(pendingOperations); 252 opQueue.add(operation); 356 nextOperation = opQueue.poll(); 426 return opQueue.remove(operation); 458 return opQueue.size(); 525 if (!opQueue.isEmpty()) {
|
H A D | TraditionalWorkQueue.java | 123 private LinkedBlockingQueue<Operation> opQueue; field in class:TraditionalWorkQueue 179 opQueue = new LinkedBlockingQueue<>(maxCapacity); 185 opQueue = new LinkedBlockingQueue<>(); 241 opQueue.removeAll(pendingOperations); 358 while (!opQueue.offer(operation, 1, TimeUnit.SECONDS)) 385 if (!opQueue.offer(operation)) 467 Operation nextOperation = opQueue.poll(5, TimeUnit.SECONDS); 627 return opQueue.size(); 716 oldOpQueue = opQueue; 717 opQueue [all...] |