/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
H A D | VerifyJob.java | 98 /** Indicates whether dn2id is to be verified. */ 106 private DN2ID dn2id; field in class:VerifyJob 244 dn2id = entryContainer.getDN2ID(); 453 try(final Cursor<ByteString, ByteString> cursor = txn.openCursor(dn2id.getName())) 468 logger.trace("File dn2id has malformed ID for DN <%s>", key, e); 803 // Check the ID is in dn2id with the correct DN. 806 EntryID id = dn2id.get(txn, dn); 823 logger.trace("File dn2id has error reading key %s: %s.%n", dn, e.getMessage()); 828 // Check the parent DN is in dn2id. 834 EntryID id = dn2id [all...] |
H A D | EntryContainer.java | 156 private final DN2ID dn2id; field in class:EntryContainer 418 this.dn2id = new DN2ID(getIndexName(DN2ID_TREE_NAME), baseDN); 457 dn2id.open(txn, shouldCreate); 535 return dn2id; 643 try (final SequentialCursor<?, ?> cursor = dn2id.openChildrenCursor(txn, dn)) 673 final EntryID entryID = dn2id.get(txn, entryDN); 971 try (final SequentialCursor<?, EntryID> scopeCursor = dn2id.openCursor(txn, aBaseDN)) 977 try (final SequentialCursor<?, EntryID> scopeCursor = dn2id.openChildrenCursor(txn, aBaseDN)) 984 try (final SequentialCursor<?, EntryID> scopeCursor = dn2id.openSubordinatesCursor(txn, aBaseDN)) 1143 * We will iterate forwards through a range of the dn2id key [all...] |
H A D | OnDiskMergeImporter.java | 236 int indexCount = 2; // dn2id, dn2uri 360 // Always rebuild id2childrencount with dn2id. 1074 * the given entry has an existing parent. To do so, the dn2id is directly imported into the database in addition of 2274 * This task optionally copy the dn2id chunk into the database and takes advantages of it's cursoring to compute the 2283 private final DN2ID dn2id; field in class:OnDiskMergeImporter.DN2IDImporterTask 2290 DN2ID dn2id, Chunk dn2IdChunk, ID2ChildrenCount id2count, Collector<?, ByteString> id2countCollector, 2297 this.dn2id = dn2id; 2301 this.dn2IdDestination = dn2idAlreadyImported ? nullChunk() : asChunk(dn2id.getName(), importer); 2315 dn2id 2289 DN2IDImporterTask(PhaseTwoProgressReporter progressReporter, Importer importer, File tempDir, BufferPool bufferPool, DN2ID dn2id, Chunk dn2IdChunk, ID2ChildrenCount id2count, Collector<?, ByteString> id2countCollector, boolean dn2idAlreadyImported) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/ |
H A D | VerifyJob.java | 135 DN2ID dn2id = null; field in class:VerifyJob 225 if (lowerName.equals("dn2id")) 303 dn2id = entryContainer.getDN2ID(); 578 DiskOrderedCursor cursor = dn2id.openCursor(new DiskOrderedCursorConfig()); 601 TRACER.debugError("File dn2id has malformed ID for DN <%s>:%n%s%n", 628 TRACER.debugError("File dn2id has DN <%s> referencing unknown " + 641 TRACER.debugError("File dn2id has DN <%s> referencing entry " + 1291 // Check the ID is in dn2id with the correct DN. 1294 EntryID id = dn2id.get(null, dn, LockMode.DEFAULT); 1299 TRACER.debugError("File dn2id i [all...] |
H A D | EntryContainer.java | 84 public static final String DN2ID_DATABASE_NAME = "dn2id"; 149 private DN2ID dn2id; field in class:EntryContainer 530 dn2id = new DN2ID(databasePrefix + "_" + DN2ID_DATABASE_NAME, env, this); 531 dn2id.open(); 619 dn2id.close(); 665 return dn2id; 820 EntryID entryID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1003 // Read the ID from dn2id. 1004 EntryID baseID = dn2id.get(null, aBaseDN, LockMode.DEFAULT); 1234 * We will iterate forwards through a range of the dn2id key [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/ |
H A D | VerifyJob.java | 136 DN2ID dn2id = null; field in class:VerifyJob 226 if (lowerName.equals("dn2id")) 304 dn2id = entryContainer.getDN2ID(); 579 DiskOrderedCursor cursor = dn2id.openCursor(new DiskOrderedCursorConfig()); 602 TRACER.debugError("File dn2id has malformed ID for DN <%s>:%n%s%n", 629 TRACER.debugError("File dn2id has DN <%s> referencing unknown " + 642 TRACER.debugError("File dn2id has DN <%s> referencing entry " + 1292 // Check the ID is in dn2id with the correct DN. 1295 EntryID id = dn2id.get(null, dn, LockMode.DEFAULT); 1300 TRACER.debugError("File dn2id i [all...] |
H A D | EntryContainer.java | 94 public static final String DN2ID_DATABASE_NAME = "dn2id"; 159 private DN2ID dn2id; field in class:EntryContainer 532 dn2id = new DN2ID(databasePrefix + "_" + DN2ID_DATABASE_NAME, env, this); 533 dn2id.open(); 621 dn2id.close(); 667 return dn2id; 822 EntryID entryID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1005 // Read the ID from dn2id. 1006 EntryID baseID = dn2id.get(null, aBaseDN, LockMode.DEFAULT); 1236 * We will iterate forwards through a range of the dn2id key [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/ |
H A D | TestVerifyJob.java | 62 private DN2ID dn2id; field in class:TestVerifyJob 90 {"dn2id"} 210 * Runs clean verify against the dn2id index after adding 224 assertTrue(dn2id.insert(txn, testDN, id)); 228 assertTrue(dn2id.insert(txn, testDN, id)); 234 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 238 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 242 assertTrue(dn2id.insert(txn, DN.decode(junkDN3), id)); 243 performBECleanVerify("dn2id", 5); 473 * Runs complete verify against the dn2id inde [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/ |
H A D | TestVerifyJob.java | 61 private DN2ID dn2id; field in class:TestVerifyJob 89 {"dn2id"} 209 * Runs clean verify against the dn2id index after adding 223 assertTrue(dn2id.insert(txn, testDN, id)); 227 assertTrue(dn2id.insert(txn, testDN, id)); 233 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 237 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 241 assertTrue(dn2id.insert(txn, DN.decode(junkDN3), id)); 242 performBECleanVerify("dn2id", 5); 472 * Runs complete verify against the dn2id inde [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/ |
H A D | VerifyJob.java | 136 DN2ID dn2id = null; field in class:VerifyJob 226 if (lowerName.equals("dn2id")) 304 dn2id = entryContainer.getDN2ID(); 579 DiskOrderedCursor cursor = dn2id.openCursor(new DiskOrderedCursorConfig()); 602 TRACER.debugError("File dn2id has malformed ID for DN <%s>:%n%s%n", 629 TRACER.debugError("File dn2id has DN <%s> referencing unknown " + 642 TRACER.debugError("File dn2id has DN <%s> referencing entry " + 1292 // Check the ID is in dn2id with the correct DN. 1295 EntryID id = dn2id.get(null, dn, LockMode.DEFAULT); 1300 TRACER.debugError("File dn2id i [all...] |
H A D | EntryContainer.java | 94 public static final String DN2ID_DATABASE_NAME = "dn2id"; 159 private DN2ID dn2id; field in class:EntryContainer 532 dn2id = new DN2ID(databasePrefix + "_" + DN2ID_DATABASE_NAME, env, this); 533 dn2id.open(); 621 dn2id.close(); 667 return dn2id; 822 EntryID entryID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1005 // Read the ID from dn2id. 1006 EntryID baseID = dn2id.get(null, aBaseDN, LockMode.DEFAULT); 1236 * We will iterate forwards through a range of the dn2id key [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/ |
H A D | TestVerifyJob.java | 62 private DN2ID dn2id; field in class:TestVerifyJob 90 {"dn2id"} 210 * Runs clean verify against the dn2id index after adding 224 assertTrue(dn2id.insert(txn, testDN, id)); 228 assertTrue(dn2id.insert(txn, testDN, id)); 234 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 238 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 242 assertTrue(dn2id.insert(txn, DN.decode(junkDN3), id)); 243 performBECleanVerify("dn2id", 5); 473 * Runs complete verify against the dn2id inde [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/ |
H A D | TestVerifyJob.java | 61 private DN2ID dn2id; field in class:TestVerifyJob 89 {"dn2id"} 209 * Runs clean verify against the dn2id index after adding 223 assertTrue(dn2id.insert(txn, testDN, id)); 227 assertTrue(dn2id.insert(txn, testDN, id)); 233 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 237 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 241 assertTrue(dn2id.insert(txn, DN.decode(junkDN3), id)); 242 performBECleanVerify("dn2id", 5); 472 * Runs complete verify against the dn2id inde [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/ |
H A D | TestVerifyJob.java | 62 private DN2ID dn2id; field in class:TestVerifyJob 90 {"dn2id"} 210 * Runs clean verify against the dn2id index after adding 224 assertTrue(dn2id.insert(txn, testDN, id)); 228 assertTrue(dn2id.insert(txn, testDN, id)); 234 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 238 assertEquals(dn2id.put(txn, key, data), OperationStatus.SUCCESS); 242 assertTrue(dn2id.insert(txn, DN.decode(junkDN3), id)); 243 performBECleanVerify("dn2id", 5); 473 * Runs complete verify against the dn2id inde [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/ |
H A D | VerifyJob.java | 135 DN2ID dn2id = null; field in class:VerifyJob 225 if (lowerName.equals("dn2id")) 303 dn2id = entryContainer.getDN2ID(); 578 DiskOrderedCursor cursor = dn2id.openCursor(new DiskOrderedCursorConfig()); 601 TRACER.debugError("File dn2id has malformed ID for DN <%s>:%n%s%n", 628 TRACER.debugError("File dn2id has DN <%s> referencing unknown " + 641 TRACER.debugError("File dn2id has DN <%s> referencing entry " + 1291 // Check the ID is in dn2id with the correct DN. 1294 EntryID id = dn2id.get(null, dn, LockMode.DEFAULT); 1299 TRACER.debugError("File dn2id i [all...] |
H A D | EntryContainer.java | 84 public static final String DN2ID_DATABASE_NAME = "dn2id"; 149 private DN2ID dn2id; field in class:EntryContainer 530 dn2id = new DN2ID(databasePrefix + "_" + DN2ID_DATABASE_NAME, env, this); 531 dn2id.open(); 619 dn2id.close(); 665 return dn2id; 820 EntryID entryID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1003 // Read the ID from dn2id. 1004 EntryID baseID = dn2id.get(null, aBaseDN, LockMode.DEFAULT); 1234 * We will iterate forwards through a range of the dn2id key [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/ |
H A D | VerifyJob.java | 136 DN2ID dn2id = null; field in class:VerifyJob 226 if (lowerName.equals("dn2id")) 304 dn2id = entryContainer.getDN2ID(); 579 DiskOrderedCursor cursor = dn2id.openCursor(new DiskOrderedCursorConfig()); 602 TRACER.debugError("File dn2id has malformed ID for DN <%s>:%n%s%n", 629 TRACER.debugError("File dn2id has DN <%s> referencing unknown " + 642 TRACER.debugError("File dn2id has DN <%s> referencing entry " + 1292 // Check the ID is in dn2id with the correct DN. 1295 EntryID id = dn2id.get(null, dn, LockMode.DEFAULT); 1300 TRACER.debugError("File dn2id i [all...] |
H A D | EntryContainer.java | 94 public static final String DN2ID_DATABASE_NAME = "dn2id"; 159 private DN2ID dn2id; field in class:EntryContainer 532 dn2id = new DN2ID(databasePrefix + "_" + DN2ID_DATABASE_NAME, env, this); 533 dn2id.open(); 621 dn2id.close(); 667 return dn2id; 822 EntryID entryID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1005 // Read the ID from dn2id. 1006 EntryID baseID = dn2id.get(null, aBaseDN, LockMode.DEFAULT); 1236 * We will iterate forwards through a range of the dn2id key [all...] |
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/importLDIF/ |
H A D | Importer.java | 369 int indexes = 2; // dn2id, dn2uri 451 // since it will be needed for dn2id queries. 478 // No need to differentiate between append/clear backend, since dn2id is 1516 DN2ID dn2id = suffix.getDN2ID(); 1517 EntryID oldID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1676 //If the backend was not cleared, then the dn2id needs to checked first 1678 //the suffixes dn2id DB, then the dn cache is used. 1873 DN2ID dn2id = suffix.getDN2ID(); 1877 processKey(dn2id, dnBytes, entryID, indexComparator, new IndexKey( 3177 private DN2ID dn2id field in class:Importer.RebuildIndexManager [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/importLDIF/ |
H A D | Importer.java | 351 int indexes = 2; // dn2id, dn2uri 433 // since it will be needed for dn2id queries. 460 // No need to differentiate between append/clear backend, since dn2id is 1484 DN2ID dn2id = suffix.getDN2ID(); 1485 EntryID oldID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1644 //If the backend was not cleared, then the dn2id needs to checked first 1646 //the suffixes dn2id DB, then the dn cache is used. 1839 DN2ID dn2id = suffix.getDN2ID(); 1843 processKey(dn2id, dnBytes, entryID, indexComparator, new IndexKey( 3143 private DN2ID dn2id field in class:Importer.RebuildIndexManager [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/importLDIF/ |
H A D | Importer.java | 351 int indexes = 2; // dn2id, dn2uri 433 // since it will be needed for dn2id queries. 460 // No need to differentiate between append/clear backend, since dn2id is 1484 DN2ID dn2id = suffix.getDN2ID(); 1485 EntryID oldID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1644 //If the backend was not cleared, then the dn2id needs to checked first 1646 //the suffixes dn2id DB, then the dn cache is used. 1839 DN2ID dn2id = suffix.getDN2ID(); 1843 processKey(dn2id, dnBytes, entryID, indexComparator, new IndexKey( 3143 private DN2ID dn2id field in class:Importer.RebuildIndexManager [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/importLDIF/ |
H A D | Importer.java | 369 int indexes = 2; // dn2id, dn2uri 451 // since it will be needed for dn2id queries. 478 // No need to differentiate between append/clear backend, since dn2id is 1516 DN2ID dn2id = suffix.getDN2ID(); 1517 EntryID oldID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1676 //If the backend was not cleared, then the dn2id needs to checked first 1678 //the suffixes dn2id DB, then the dn cache is used. 1873 DN2ID dn2id = suffix.getDN2ID(); 1877 processKey(dn2id, dnBytes, entryID, indexComparator, new IndexKey( 3177 private DN2ID dn2id field in class:Importer.RebuildIndexManager [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/importLDIF/ |
H A D | Importer.java | 351 int indexes = 2; // dn2id, dn2uri 433 // since it will be needed for dn2id queries. 460 // No need to differentiate between append/clear backend, since dn2id is 1484 DN2ID dn2id = suffix.getDN2ID(); 1485 EntryID oldID = dn2id.get(null, entryDN, LockMode.DEFAULT); 1644 //If the backend was not cleared, then the dn2id needs to checked first 1646 //the suffixes dn2id DB, then the dn cache is used. 1839 DN2ID dn2id = suffix.getDN2ID(); 1843 processKey(dn2id, dnBytes, entryID, indexComparator, new IndexKey( 3143 private DN2ID dn2id field in class:Importer.RebuildIndexManager [all...] |