Searched defs:opQueue (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java114 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 DTraditionalWorkQueue.java134 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 DParallelWorkQueue.java113 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 DTraditionalWorkQueue.java133 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 DParallelWorkQueue.java114 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 DTraditionalWorkQueue.java134 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 DParallelWorkQueue.java114 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 DTraditionalWorkQueue.java134 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 DParallelWorkQueue.java113 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 DTraditionalWorkQueue.java133 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 DParallelWorkQueue.java103 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 DTraditionalWorkQueue.java123 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...]

Completed in 102 milliseconds