Searched defs:msgQueue (Results 1 - 9 of 9) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DDbHandler.java68 // The msgQueue holds all the updates not yet saved to stable storage.
81 private final LinkedList<UpdateMsg> msgQueue = field in class:DbHandler
84 // The High and low water mark for the max size of the msgQueue.
86 // msgQueue becomes larger than the queueHimark and will resume
87 // only when the size of the msgQueue goes below queueLowmark.
173 synchronized (msgQueue)
175 int size = msgQueue.size();
177 msgQueue.notify();
183 msgQueue.wait(500);
188 size = msgQueue
[all...]
H A DMessageHandler.java73 private final MsgQueue msgQueue = new MsgQueue(); field in class:MessageHandler
166 synchronized (msgQueue)
172 if (msgQueue.isEmpty())
173 msgQueue.notify();
175 msgQueue.add(update);
180 while ((msgQueue.count() > maxQueueSize) ||
181 (msgQueue.bytesCount() > maxQueueBytesSize))
184 msgQueue.removeFirst();
241 Attributes.create("queue-size", String.valueOf(msgQueue.count())));
244 "queue-size-bytes", String.valueOf(msgQueue
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DMessageHandler.java75 private final MsgQueue msgQueue = new MsgQueue(); field in class:MessageHandler
151 synchronized (msgQueue)
157 if (msgQueue.isEmpty())
159 msgQueue.notify();
162 msgQueue.add(update);
170 msgQueue.removeFirst();
177 return msgQueue.count() > maxQueueSize
178 || msgQueue.bytesCount() > maxQueueBytesSize;
237 attributes.add(create("queue-size", String.valueOf(msgQueue.count())));
238 attributes.add(create("queue-size-bytes", String.valueOf(msgQueue
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DDbHandler.java68 // The msgQueue holds all the updates not yet saved to stable storage.
81 private final LinkedList<UpdateMsg> msgQueue = field in class:DbHandler
84 // The High and low water mark for the max size of the msgQueue.
86 // msgQueue becomes larger than the queueHimark and will resume
87 // only when the size of the msgQueue goes below queueLowmark.
171 synchronized (msgQueue)
173 int size = msgQueue.size();
175 msgQueue.notify();
181 msgQueue.wait(500);
186 size = msgQueue
[all...]
H A DMessageHandler.java73 private final MsgQueue msgQueue = new MsgQueue(); field in class:MessageHandler
166 synchronized (msgQueue)
172 if (msgQueue.isEmpty())
173 msgQueue.notify();
175 msgQueue.add(update);
180 while ((msgQueue.count() > maxQueueSize) ||
181 (msgQueue.bytesCount() > maxQueueBytesSize))
184 msgQueue.removeFirst();
241 Attributes.create("queue-size", String.valueOf(msgQueue.count())));
244 "queue-size-bytes", String.valueOf(msgQueue
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DDbHandler.java68 // The msgQueue holds all the updates not yet saved to stable storage.
81 private final LinkedList<UpdateMsg> msgQueue = field in class:DbHandler
84 // The High and low water mark for the max size of the msgQueue.
86 // msgQueue becomes larger than the queueHimark and will resume
87 // only when the size of the msgQueue goes below queueLowmark.
173 synchronized (msgQueue)
175 int size = msgQueue.size();
177 msgQueue.notify();
183 msgQueue.wait(500);
188 size = msgQueue
[all...]
H A DMessageHandler.java73 private final MsgQueue msgQueue = new MsgQueue(); field in class:MessageHandler
166 synchronized (msgQueue)
172 if (msgQueue.isEmpty())
173 msgQueue.notify();
175 msgQueue.add(update);
180 while ((msgQueue.count() > maxQueueSize) ||
181 (msgQueue.bytesCount() > maxQueueBytesSize))
184 msgQueue.removeFirst();
241 Attributes.create("queue-size", String.valueOf(msgQueue.count())));
244 "queue-size-bytes", String.valueOf(msgQueue
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DMessageHandler.java75 private final MsgQueue msgQueue = new MsgQueue(); field in class:MessageHandler
151 synchronized (msgQueue)
157 if (msgQueue.isEmpty())
159 msgQueue.notify();
162 msgQueue.add(update);
170 msgQueue.removeFirst();
177 return msgQueue.count() > maxQueueSize
178 || msgQueue.bytesCount() > maxQueueBytesSize;
237 attributes.add(create("queue-size", String.valueOf(msgQueue.count())));
238 attributes.add(create("queue-size-bytes", String.valueOf(msgQueue
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DMessageHandler.java74 private final MsgQueue msgQueue = new MsgQueue(); field in class:MessageHandler
130 synchronized (msgQueue)
136 if (msgQueue.isEmpty())
138 msgQueue.notify();
141 msgQueue.add(update);
147 msgQueue.removeFirst();
154 final long count = msgQueue.count();
157 || (count >= MINIMUM_TRESHOLD_MSG_QUEUE_SIZE && msgQueue.bytesCount() > maxQueueBytesSize);
217 attributes.add(create("queue-size", String.valueOf(msgQueue.count())));
218 attributes.add(create("queue-size-bytes", String.valueOf(msgQueue
[all...]

Completed in 81 milliseconds