| /forgerock/opendj2/src/server/org/opends/server/backends/jeb/ |
| H A D | EntryCachePreloader.java | 70 * - Worker threads which are responsible for monitoring the collector feed
136 private EntryCacheCollector collector = field in class:EntryCachePreloader
176 // Start collector thread first.
177 collector.start();
206 while (!entryQueue.isEmpty() || collector.isAlive()) {
233 // Join the collector.
234 if (collector.isAlive()) {
235 collector.join();
252 // Interrupt the collector.
253 collector
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/ |
| H A D | EntryCachePreloader.java | 71 * - Worker threads which are responsible for monitoring the collector feed
137 private EntryCacheCollector collector = field in class:EntryCachePreloader
177 // Start collector thread first.
178 collector.start();
207 while (!entryQueue.isEmpty() || collector.isAlive()) {
234 // Join the collector.
235 if (collector.isAlive()) {
236 collector.join();
253 // Interrupt the collector.
254 collector
[all...] |
| /forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/ |
| H A D | EntryCachePreloader.java | 71 * - Worker threads which are responsible for monitoring the collector feed
137 private EntryCacheCollector collector = field in class:EntryCachePreloader
177 // Start collector thread first.
178 collector.start();
207 while (!entryQueue.isEmpty() || collector.isAlive()) {
234 // Join the collector.
235 if (collector.isAlive()) {
236 collector.join();
253 // Interrupt the collector.
254 collector
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/ |
| H A D | EntryCachePreloader.java | 70 * - Worker threads which are responsible for monitoring the collector feed
136 private EntryCacheCollector collector = field in class:EntryCachePreloader
176 // Start collector thread first.
177 collector.start();
206 while (!entryQueue.isEmpty() || collector.isAlive()) {
233 // Join the collector.
234 if (collector.isAlive()) {
235 collector.join();
252 // Interrupt the collector.
253 collector
[all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/ |
| H A D | EntryCachePreloader.java | 71 * - Worker threads which are responsible for monitoring the collector feed
137 private EntryCacheCollector collector = field in class:EntryCachePreloader
177 // Start collector thread first.
178 collector.start();
207 while (!entryQueue.isEmpty() || collector.isAlive()) {
234 // Join the collector.
235 if (collector.isAlive()) {
236 collector.join();
253 // Interrupt the collector.
254 collector
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
| H A D | OnDiskMergeImporter.java | 1426 ExternalSortChunk(File tempDir, String name, BufferPool bufferPool, Collector<?, ByteString> collector, argument
1448 this.deduplicator = collector;
1981 private final Collector<A, V> collector; field in class:OnDiskMergeImporter.ExternalSortChunk.CollectorCursor
1986 CollectorCursor(MeteredCursor<K, ? extends V> cursor, Collector<A, V> collector) argument
1989 this.collector = collector;
2011 A resultContainer = collector.get();
2014 resultContainer = collector.accept(resultContainer, delegate.getValue());
2017 value = collector.merge(resultContainer);
|
| /forgerock/opendj-b2.6/ext/ |
| H A D | junit.jar | META-INF/ META-INF/MANIFEST.MF junit/ junit/awtui/ junit/extensions/ junit/framework/ junit/runner/ junit/ ... |
| /forgerock/opendj2/ext/ |
| H A D | junit.jar | META-INF/ META-INF/MANIFEST.MF junit/ junit/awtui/ junit/extensions/ junit/framework/ junit/runner/ junit/ ... |
| /forgerock/opendj2.6.2/ext/ |
| H A D | junit.jar | META-INF/ META-INF/MANIFEST.MF junit/ junit/awtui/ junit/extensions/ junit/framework/ junit/runner/ junit/ ... |
| /forgerock/opendj2-jel-hg/ext/ |
| H A D | junit.jar | META-INF/ META-INF/MANIFEST.MF junit/ junit/awtui/ junit/extensions/ junit/framework/ junit/runner/ junit/ ... |
| /forgerock/opendj2-hg/ext/ |
| H A D | junit.jar | META-INF/ META-INF/MANIFEST.MF junit/ junit/awtui/ junit/extensions/ junit/framework/ junit/runner/ junit/ ... |