Searched refs:entryQueue (Results 1 - 11 of 11) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/tools/makeldif/
H A DMakeLDIFInputStream.java75 private LinkedBlockingQueue<TemplateEntry> entryQueue; field in class:MakeLDIFInputStream
97 entryQueue = new LinkedBlockingQueue<TemplateEntry>(10);
219 if (entryQueue.offer(entry, 500, TimeUnit.MILLISECONDS))
263 TemplateEntry entry = entryQueue.poll();
272 entry = entryQueue.poll();
282 entry = entryQueue.poll(500, TimeUnit.MILLISECONDS);
/forgerock/opendj2/src/server/org/opends/server/tools/makeldif/
H A DMakeLDIFInputStream.java74 private LinkedBlockingQueue<TemplateEntry> entryQueue; field in class:MakeLDIFInputStream
96 entryQueue = new LinkedBlockingQueue<TemplateEntry>(10);
218 if (entryQueue.offer(entry, 500, TimeUnit.MILLISECONDS))
262 TemplateEntry entry = entryQueue.poll();
271 entry = entryQueue.poll();
281 entry = entryQueue.poll(500, TimeUnit.MILLISECONDS);
/forgerock/opendj2.6.2/src/server/org/opends/server/tools/makeldif/
H A DMakeLDIFInputStream.java75 private LinkedBlockingQueue<TemplateEntry> entryQueue; field in class:MakeLDIFInputStream
97 entryQueue = new LinkedBlockingQueue<TemplateEntry>(10);
219 if (entryQueue.offer(entry, 500, TimeUnit.MILLISECONDS))
263 TemplateEntry entry = entryQueue.poll();
272 entry = entryQueue.poll();
282 entry = entryQueue.poll(500, TimeUnit.MILLISECONDS);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/tools/makeldif/
H A DMakeLDIFInputStream.java75 private LinkedBlockingQueue<TemplateEntry> entryQueue; field in class:MakeLDIFInputStream
97 entryQueue = new LinkedBlockingQueue<TemplateEntry>(10);
219 if (entryQueue.offer(entry, 500, TimeUnit.MILLISECONDS))
263 TemplateEntry entry = entryQueue.poll();
272 entry = entryQueue.poll();
282 entry = entryQueue.poll(500, TimeUnit.MILLISECONDS);
/forgerock/opendj2-hg/src/server/org/opends/server/tools/makeldif/
H A DMakeLDIFInputStream.java74 private LinkedBlockingQueue<TemplateEntry> entryQueue; field in class:MakeLDIFInputStream
96 entryQueue = new LinkedBlockingQueue<TemplateEntry>(10);
218 if (entryQueue.offer(entry, 500, TimeUnit.MILLISECONDS))
262 TemplateEntry entry = entryQueue.poll();
271 entry = entryQueue.poll();
281 entry = entryQueue.poll(500, TimeUnit.MILLISECONDS);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tools/makeldif/
H A DMakeLDIFInputStream.java79 private LinkedBlockingQueue<TemplateEntry> entryQueue; field in class:MakeLDIFInputStream
101 entryQueue = new LinkedBlockingQueue<>(10);
217 if (entryQueue.offer(entry, 500, TimeUnit.MILLISECONDS))
259 TemplateEntry entry = entryQueue.poll();
268 entry = entryQueue.poll();
278 entry = entryQueue.poll(500, TimeUnit.MILLISECONDS);
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/
H A DEntryCachePreloader.java142 private LinkedBlockingQueue<PreloadEntry> entryQueue; field in class:EntryCachePreloader
164 entryQueue =
206 while (!entryQueue.isEmpty() || collector.isAlive()) {
275 while (!entryQueue.isEmpty() || collector.isAlive()) {
287 PreloadEntry preloadEntry = entryQueue.poll();
373 entryQueue.put(new PreloadEntry(data.getData(),
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/
H A DEntryCachePreloader.java143 private LinkedBlockingQueue<PreloadEntry> entryQueue; field in class:EntryCachePreloader
165 entryQueue =
207 while (!entryQueue.isEmpty() || collector.isAlive()) {
276 while (!entryQueue.isEmpty() || collector.isAlive()) {
288 PreloadEntry preloadEntry = entryQueue.poll();
374 entryQueue.put(new PreloadEntry(data.getData(),
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/
H A DEntryCachePreloader.java143 private LinkedBlockingQueue<PreloadEntry> entryQueue; field in class:EntryCachePreloader
165 entryQueue =
207 while (!entryQueue.isEmpty() || collector.isAlive()) {
276 while (!entryQueue.isEmpty() || collector.isAlive()) {
288 PreloadEntry preloadEntry = entryQueue.poll();
374 entryQueue.put(new PreloadEntry(data.getData(),
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/
H A DEntryCachePreloader.java142 private LinkedBlockingQueue<PreloadEntry> entryQueue; field in class:EntryCachePreloader
164 entryQueue =
206 while (!entryQueue.isEmpty() || collector.isAlive()) {
275 while (!entryQueue.isEmpty() || collector.isAlive()) {
287 PreloadEntry preloadEntry = entryQueue.poll();
373 entryQueue.put(new PreloadEntry(data.getData(),
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/
H A DEntryCachePreloader.java143 private LinkedBlockingQueue<PreloadEntry> entryQueue; field in class:EntryCachePreloader
165 entryQueue =
207 while (!entryQueue.isEmpty() || collector.isAlive()) {
276 while (!entryQueue.isEmpty() || collector.isAlive()) {
288 PreloadEntry preloadEntry = entryQueue.poll();
374 entryQueue.put(new PreloadEntry(data.getData(),

Completed in 444 milliseconds