Searched defs:workQueue (Results 1 - 25 of 42) sorted by relevance

12

/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java82 private ParallelWorkQueue workQueue; field in class:ParallelWorkerThread
90 * @param workQueue The work queue with which this worker thread is
94 public ParallelWorkerThread(ParallelWorkQueue workQueue, int threadID) argument
99 this.workQueue = workQueue;
153 operation = workQueue.nextOperation(this);
232 else if (! workQueue.shutdownRequested())
H A DTraditionalWorkerThread.java82 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkerThread
90 * @param workQueue The work queue with which this worker thread is
94 public TraditionalWorkerThread(TraditionalWorkQueue workQueue, int threadID) argument
99 this.workQueue = workQueue;
153 operation = workQueue.nextOperation(this);
234 else if (! workQueue.shutdownRequested())
/forgerock/opendj-b2.6/src/server/org/opends/server/monitors/
H A DParallelWorkQueueMonitor.java98 private ParallelWorkQueue workQueue; field in class:ParallelWorkQueueMonitor
107 * @param workQueue The work queue with which this monitor is associated.
109 public ParallelWorkQueueMonitor(ParallelWorkQueue workQueue) argument
111 this.workQueue = workQueue;
147 int backlog = workQueue.size();
169 int backlog = workQueue.size();
179 long opsSubmitted = workQueue.getOpsSubmitted();
H A DTraditionalWorkQueueMonitor.java107 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkQueueMonitor
116 * @param workQueue The work queue with which this monitor is associated.
118 public TraditionalWorkQueueMonitor(TraditionalWorkQueue workQueue) argument
120 this.workQueue = workQueue;
156 int backlog = workQueue.size();
178 int backlog = workQueue.size();
188 long opsSubmitted = workQueue.getOpsSubmitted();
189 long rejectedQueueFull = workQueue.getOpsRejectedDueToQueueFull();
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java81 private ParallelWorkQueue workQueue; field in class:ParallelWorkerThread
89 * @param workQueue The work queue with which this worker thread is
93 public ParallelWorkerThread(ParallelWorkQueue workQueue, int threadID) argument
98 this.workQueue = workQueue;
152 operation = workQueue.nextOperation(this);
231 else if (! workQueue.shutdownRequested())
H A DTraditionalWorkerThread.java79 private final TraditionalWorkQueue workQueue; field in class:TraditionalWorkerThread
87 * @param workQueue The work queue with which this worker thread is
91 public TraditionalWorkerThread(TraditionalWorkQueue workQueue, int threadID) argument
96 this.workQueue = workQueue;
150 operation = workQueue.nextOperation(this);
231 else if (! workQueue.shutdownRequested())
/forgerock/opendj2/src/server/org/opends/server/monitors/
H A DParallelWorkQueueMonitor.java97 private ParallelWorkQueue workQueue; field in class:ParallelWorkQueueMonitor
106 * @param workQueue The work queue with which this monitor is associated.
108 public ParallelWorkQueueMonitor(ParallelWorkQueue workQueue) argument
110 this.workQueue = workQueue;
146 int backlog = workQueue.size();
168 int backlog = workQueue.size();
178 long opsSubmitted = workQueue.getOpsSubmitted();
H A DTraditionalWorkQueueMonitor.java106 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkQueueMonitor
115 * @param workQueue The work queue with which this monitor is associated.
117 public TraditionalWorkQueueMonitor(TraditionalWorkQueue workQueue) argument
119 this.workQueue = workQueue;
155 int backlog = workQueue.size();
177 int backlog = workQueue.size();
187 long opsSubmitted = workQueue.getOpsSubmitted();
188 long rejectedQueueFull = workQueue.getOpsRejectedDueToQueueFull();
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java82 private ParallelWorkQueue workQueue; field in class:ParallelWorkerThread
90 * @param workQueue The work queue with which this worker thread is
94 public ParallelWorkerThread(ParallelWorkQueue workQueue, int threadID) argument
99 this.workQueue = workQueue;
153 operation = workQueue.nextOperation(this);
232 else if (! workQueue.shutdownRequested())
H A DTraditionalWorkerThread.java82 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkerThread
90 * @param workQueue The work queue with which this worker thread is
94 public TraditionalWorkerThread(TraditionalWorkQueue workQueue, int threadID) argument
99 this.workQueue = workQueue;
153 operation = workQueue.nextOperation(this);
234 else if (! workQueue.shutdownRequested())
/forgerock/opendj2.6.2/src/server/org/opends/server/monitors/
H A DParallelWorkQueueMonitor.java98 private ParallelWorkQueue workQueue; field in class:ParallelWorkQueueMonitor
107 * @param workQueue The work queue with which this monitor is associated.
109 public ParallelWorkQueueMonitor(ParallelWorkQueue workQueue) argument
111 this.workQueue = workQueue;
147 int backlog = workQueue.size();
169 int backlog = workQueue.size();
179 long opsSubmitted = workQueue.getOpsSubmitted();
H A DTraditionalWorkQueueMonitor.java107 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkQueueMonitor
116 * @param workQueue The work queue with which this monitor is associated.
118 public TraditionalWorkQueueMonitor(TraditionalWorkQueue workQueue) argument
120 this.workQueue = workQueue;
156 int backlog = workQueue.size();
178 int backlog = workQueue.size();
188 long opsSubmitted = workQueue.getOpsSubmitted();
189 long rejectedQueueFull = workQueue.getOpsRejectedDueToQueueFull();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java82 private ParallelWorkQueue workQueue; field in class:ParallelWorkerThread
90 * @param workQueue The work queue with which this worker thread is
94 public ParallelWorkerThread(ParallelWorkQueue workQueue, int threadID) argument
99 this.workQueue = workQueue;
153 operation = workQueue.nextOperation(this);
232 else if (! workQueue.shutdownRequested())
H A DTraditionalWorkerThread.java82 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkerThread
90 * @param workQueue The work queue with which this worker thread is
94 public TraditionalWorkerThread(TraditionalWorkQueue workQueue, int threadID) argument
99 this.workQueue = workQueue;
153 operation = workQueue.nextOperation(this);
234 else if (! workQueue.shutdownRequested())
/forgerock/opendj2-jel-hg/src/server/org/opends/server/monitors/
H A DParallelWorkQueueMonitor.java98 private ParallelWorkQueue workQueue; field in class:ParallelWorkQueueMonitor
107 * @param workQueue The work queue with which this monitor is associated.
109 public ParallelWorkQueueMonitor(ParallelWorkQueue workQueue) argument
111 this.workQueue = workQueue;
147 int backlog = workQueue.size();
169 int backlog = workQueue.size();
179 long opsSubmitted = workQueue.getOpsSubmitted();
H A DTraditionalWorkQueueMonitor.java107 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkQueueMonitor
116 * @param workQueue The work queue with which this monitor is associated.
118 public TraditionalWorkQueueMonitor(TraditionalWorkQueue workQueue) argument
120 this.workQueue = workQueue;
156 int backlog = workQueue.size();
178 int backlog = workQueue.size();
188 long opsSubmitted = workQueue.getOpsSubmitted();
189 long rejectedQueueFull = workQueue.getOpsRejectedDueToQueueFull();
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DParallelWorkerThread.java81 private ParallelWorkQueue workQueue; field in class:ParallelWorkerThread
89 * @param workQueue The work queue with which this worker thread is
93 public ParallelWorkerThread(ParallelWorkQueue workQueue, int threadID) argument
98 this.workQueue = workQueue;
152 operation = workQueue.nextOperation(this);
231 else if (! workQueue.shutdownRequested())
H A DTraditionalWorkerThread.java79 private final TraditionalWorkQueue workQueue; field in class:TraditionalWorkerThread
87 * @param workQueue The work queue with which this worker thread is
91 public TraditionalWorkerThread(TraditionalWorkQueue workQueue, int threadID) argument
96 this.workQueue = workQueue;
150 operation = workQueue.nextOperation(this);
231 else if (! workQueue.shutdownRequested())
/forgerock/opendj2-hg/src/server/org/opends/server/monitors/
H A DParallelWorkQueueMonitor.java97 private ParallelWorkQueue workQueue; field in class:ParallelWorkQueueMonitor
106 * @param workQueue The work queue with which this monitor is associated.
108 public ParallelWorkQueueMonitor(ParallelWorkQueue workQueue) argument
110 this.workQueue = workQueue;
146 int backlog = workQueue.size();
168 int backlog = workQueue.size();
178 long opsSubmitted = workQueue.getOpsSubmitted();
H A DTraditionalWorkQueueMonitor.java106 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkQueueMonitor
115 * @param workQueue The work queue with which this monitor is associated.
117 public TraditionalWorkQueueMonitor(TraditionalWorkQueue workQueue) argument
119 this.workQueue = workQueue;
155 int backlog = workQueue.size();
177 int backlog = workQueue.size();
187 long opsSubmitted = workQueue.getOpsSubmitted();
188 long rejectedQueueFull = workQueue.getOpsRejectedDueToQueueFull();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/
H A DParallelWorkerThread.java75 private ParallelWorkQueue workQueue; field in class:ParallelWorkerThread
83 * @param workQueue The work queue with which this worker thread is
87 public ParallelWorkerThread(ParallelWorkQueue workQueue, int threadID) argument
92 this.workQueue = workQueue;
146 operation = workQueue.nextOperation(this);
218 else if (! workQueue.shutdownRequested())
H A DTraditionalWorkerThread.java73 private final TraditionalWorkQueue workQueue; field in class:TraditionalWorkerThread
81 * @param workQueue The work queue with which this worker thread is
85 public TraditionalWorkerThread(TraditionalWorkQueue workQueue, int threadID) argument
90 this.workQueue = workQueue;
144 operation = workQueue.nextOperation(this);
218 else if (! workQueue.shutdownRequested())
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/monitors/
H A DParallelWorkQueueMonitor.java77 private ParallelWorkQueue workQueue; field in class:ParallelWorkQueueMonitor
84 * @param workQueue The work queue with which this monitor is associated.
86 public ParallelWorkQueueMonitor(ParallelWorkQueue workQueue) argument
88 this.workQueue = workQueue;
123 int backlog = workQueue.size();
146 int backlog = workQueue.size();
155 long opsSubmitted = workQueue.getOpsSubmitted();
H A DTraditionalWorkQueueMonitor.java80 private TraditionalWorkQueue workQueue; field in class:TraditionalWorkQueueMonitor
88 * @param workQueue The work queue with which this monitor is associated.
90 public TraditionalWorkQueueMonitor(TraditionalWorkQueue workQueue) argument
92 this.workQueue = workQueue;
127 int backlog = workQueue.size();
150 int backlog = workQueue.size();
160 long opsSubmitted = workQueue.getOpsSubmitted();
161 long rejectedQueueFull = workQueue.getOpsRejectedDueToQueueFull();
/forgerock/opendj-b2.6/src/guitools/org/opends/guitools/controlpanel/util/
H A DConfigFromDirContext.java95 private CustomSearchResult workQueue; field in class:ConfigFromDirContext
208 return workQueue;
251 workQueue = null;
741 else if ((workQueue == null) && isWorkQueue(csr))
743 workQueue = csr;

Completed in 114 milliseconds

12