Searched refs:freeBufferQueue (Results 1 - 5 of 5) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java168 private final BlockingQueue<IndexOutputBuffer> freeBufferQueue = field in class:Importer
624 freeBufferQueue.add(b);
1146 freeBufferQueue.clear();
1485 freeBufferQueue.add(indexBuffer);
1613 freeBufferQueue.add(indexBuffer);
1851 indexBuffer = freeBufferQueue.take();
2683 freeBufferQueue.add(id);
2698 freeBufferQueue.add(indexBuffer);
3733 freeBufferQueue.clear();
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java156 private final BlockingQueue<IndexOutputBuffer> freeBufferQueue = field in class:Importer
609 freeBufferQueue.add(b);
1114 freeBufferQueue.clear();
1453 freeBufferQueue.add(indexBuffer);
1581 freeBufferQueue.add(indexBuffer);
1817 indexBuffer = freeBufferQueue.take();
2649 freeBufferQueue.add(id);
2664 freeBufferQueue.add(indexBuffer);
3695 freeBufferQueue.clear();
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java156 private final BlockingQueue<IndexOutputBuffer> freeBufferQueue = field in class:Importer
609 freeBufferQueue.add(b);
1114 freeBufferQueue.clear();
1453 freeBufferQueue.add(indexBuffer);
1581 freeBufferQueue.add(indexBuffer);
1817 indexBuffer = freeBufferQueue.take();
2649 freeBufferQueue.add(id);
2664 freeBufferQueue.add(indexBuffer);
3695 freeBufferQueue.clear();
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java168 private final BlockingQueue<IndexOutputBuffer> freeBufferQueue = field in class:Importer
624 freeBufferQueue.add(b);
1146 freeBufferQueue.clear();
1485 freeBufferQueue.add(indexBuffer);
1613 freeBufferQueue.add(indexBuffer);
1851 indexBuffer = freeBufferQueue.take();
2683 freeBufferQueue.add(id);
2698 freeBufferQueue.add(indexBuffer);
3733 freeBufferQueue.clear();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java156 private final BlockingQueue<IndexOutputBuffer> freeBufferQueue = field in class:Importer
609 freeBufferQueue.add(b);
1114 freeBufferQueue.clear();
1453 freeBufferQueue.add(indexBuffer);
1581 freeBufferQueue.add(indexBuffer);
1817 indexBuffer = freeBufferQueue.take();
2649 freeBufferQueue.add(id);
2664 freeBufferQueue.add(indexBuffer);
3695 freeBufferQueue.clear();

Completed in 79 milliseconds