/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/spi/ |
H A D | Importer.java | 47 * @param treeName name of the tree to clear 49 void clearTree(TreeName treeName); argument 56 * @param treeName 63 void put(TreeName treeName, ByteSequence key, ByteSequence value); argument 68 * @param treeName 74 ByteString read(TreeName treeName, ByteSequence key); argument 81 * @param treeName 85 SequentialCursor<ByteString, ByteString> openCursor(TreeName treeName); argument
|
H A D | ReadableTransaction.java | 39 * @param treeName 45 ByteString read(TreeName treeName, ByteSequence key); argument 50 * @param treeName 54 Cursor<ByteString, ByteString> openCursor(TreeName treeName); argument 59 * @param treeName 63 long getRecordCount(TreeName treeName); argument
|
H A D | TreeName.java | 60 * @param treeName the string representation of the tree name 63 public static TreeName valueOf(String treeName) argument 65 int lastSlash = treeName.lastIndexOf('/'); 66 Reject.ifTrue(lastSlash < 2 || treeName.charAt(0) != '/', "TreeName is not of the form /<name>/<name>"); 67 String baseDN = treeName.substring(1, lastSlash); 68 String indexId = treeName.substring(lastSlash + 1);
|
H A D | WriteableTransaction.java | 56 * @param treeName 63 void put(TreeName treeName, ByteSequence key, ByteSequence value); argument 69 * @param treeName 78 boolean update(TreeName treeName, ByteSequence key, UpdateFunction f); argument 83 * @param treeName 89 boolean delete(TreeName treeName, ByteSequence key); argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
H A D | PersistentCompressedSchema.java | 213 private boolean store(final TreeName treeName, final byte[] key, final ByteStringBuilder value) argument 224 txn.put(treeName, keyEntry, value);
|
H A D | DN2URI.java | 101 * @param treeName 108 DN2URI(TreeName treeName, EntryContainer entryContainer) throws StorageRuntimeException argument 110 super(treeName);
|
H A D | DN2ID.java | 82 * @param treeName The name of the DN tree. 86 DN2ID(TreeName treeName, DN baseDN) throws StorageRuntimeException argument 88 super(treeName);
|
H A D | BackendStat.java | 144 private TreeName treeName; field in class:BackendStat.StorageTreeKeyValue 146 public StorageTreeKeyValue(TreeName treeName) argument 148 this.treeName = treeName; 154 return treeName;
|
H A D | OnDiskMergeImporter.java | 927 Chunk newChunk(TreeName treeName) throws Exception; argument 961 abstract Callable<Void> newPhaseTwoTask(TreeName treeName, Chunk source, PhaseTwoProgressReporter progressReporter); argument 976 final Chunk newExternalSortChunk(TreeName treeName) throws Exception argument 978 return new ExternalSortChunk(tempDir, treeName.toString(), bufferPool, 979 newCollector(entryContainers.get(treeName.getBaseDN()), treeName), sorter); 982 final Callable<Void> newChunkCopierTask(TreeName treeName, final Chunk source, argument 985 return new ChunkCopierTask(progressReporter, source, treeName, importer); 988 final Callable<Void> newDN2IDImporterTask(TreeName treeName, final Chunk source, argument 991 final EntryContainer entryContainer = entryContainers.get(treeName 1041 newChunk(TreeName treeName) argument 1051 newPhaseTwoTask(TreeName treeName, final Chunk source, PhaseTwoProgressReporter progressReporter) argument 1090 newChunk(TreeName treeName) argument 1104 newPhaseTwoTask(TreeName treeName, final Chunk source, PhaseTwoProgressReporter progressReporter) argument 1144 read(TreeName treeName, ByteSequence key) argument 1150 openCursor(TreeName treeName) argument 1156 getRecordCount(TreeName treeName) argument 1192 newChunk(TreeName treeName) argument 1203 newPhaseTwoTask(TreeName treeName, Chunk source, PhaseTwoProgressReporter progressReporter) argument 1277 put(final TreeName treeName, ByteSequence key, ByteSequence value) argument 1289 getOrCreateChunk(final TreeName treeName) argument 1309 read(TreeName treeName, ByteSequence key) argument 1315 update(TreeName treeName, ByteSequence key, UpdateFunction f) argument 1321 openCursor(TreeName treeName) argument 1327 getRecordCount(TreeName treeName) argument 1345 delete(TreeName treeName, ByteSequence key) argument 2202 asChunk(TreeName treeName, Importer importer) argument 2211 private final TreeName treeName; field in class:OnDiskMergeImporter.ChunkCopierTask 2215 ChunkCopierTask(PhaseTwoProgressReporter reporter, Chunk source, TreeName treeName, Importer destination) argument 2385 private final TreeName treeName; field in class:OnDiskMergeImporter.ImporterToChunkAdapter 2389 ImporterToChunkAdapter(TreeName treeName, Importer importer) argument 2437 put(TreeName treeName, ByteSequence key, ByteSequence value) argument 2450 clearTree(TreeName treeName) argument 2456 read(TreeName treeName, ByteSequence key) argument 2462 openCursor(TreeName treeName) argument 3094 newCollector(final EntryContainer entryContainer, final TreeName treeName) argument 3115 isDN2ID(TreeName treeName) argument 3120 isDN2URI(TreeName treeName) argument 3125 isID2Entry(TreeName treeName) argument 3130 isID2ChildrenCount(TreeName treeName) argument 3135 isVLVIndex(EntryContainer entryContainer, TreeName treeName) argument 3140 getVLVIndex(EntryContainer entryContainer, TreeName treeName) argument 3152 getIndex(EntryContainer entryContainer, TreeName treeName) argument 3714 read(TreeName treeName, ByteSequence key) argument 3720 put(TreeName treeName, ByteSequence key, ByteSequence value) argument 3726 update(TreeName treeName, ByteSequence key, UpdateFunction f) argument 3740 openCursor(TreeName treeName) argument 3746 getRecordCount(TreeName treeName) argument 3772 delete(TreeName treeName, ByteSequence key) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/backends/pluggable/ |
H A D | DefaultIndexTest.java | 139 public ByteString read(TreeName treeName, ByteSequence key) argument 141 return getTree(treeName).get(key); 144 private TreeMap<ByteString, ByteString> getTree(TreeName treeName) { argument 145 final TreeMap<ByteString, ByteString> tree = storage.get(treeName); 147 throw new StorageRuntimeException("Tree " + treeName + " doesn't exists"); 153 public Cursor<ByteString, ByteString> openCursor(TreeName treeName) argument 155 final TreeMap<ByteString, ByteString> tree = getTree(treeName); 252 public long getRecordCount(TreeName treeName) argument 254 return getTree(treeName).size(); 270 public void put(TreeName treeName, ByteSequenc argument 276 update(TreeName treeName, ByteSequence key, UpdateFunction f) argument 287 delete(TreeName treeName, ByteSequence key) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/jeb/ |
H A D | JEStorage.java | 289 private Database getOrOpenTree(TreeName treeName) argument 291 return getOrOpenTree0(null, trees, treeName); 295 public void put(final TreeName treeName, final ByteSequence key, final ByteSequence value) argument 299 getOrOpenTree(treeName).put(null, db(key), db(value)); 308 public ByteString read(final TreeName treeName, final ByteSequence key) argument 313 boolean isDefined = getOrOpenTree(treeName).get(null, db(key), dbValue, null) == SUCCESS; 323 public SequentialCursor<ByteString, ByteString> openCursor(TreeName treeName) argument 327 return new CursorImpl(getOrOpenTree(treeName).openCursor(null, new CursorConfig())); 336 public void clearTree(TreeName treeName) argument 338 env.truncateDatabase(null, toDatabaseName(treeName), fals 373 getOrOpenTree(TreeName treeName) argument 386 put(final TreeName treeName, final ByteSequence key, final ByteSequence value) argument 402 putErrorMsg(TreeName treeName, ByteSequence key, ByteSequence value, String msg) argument 408 delete(final TreeName treeName, final ByteSequence key) argument 420 deleteErrorMsg(TreeName treeName, ByteSequence key, String msg) argument 426 getRecordCount(TreeName treeName) argument 439 openCursor(final TreeName treeName) argument 452 read(final TreeName treeName, final ByteSequence key) argument 467 update(final TreeName treeName, final ByteSequence key, final UpdateFunction f) argument 506 openTree(final TreeName treeName, boolean createOnDemand) argument 512 deleteTree(final TreeName treeName) argument 544 read(TreeName treeName, ByteSequence key) argument 550 openCursor(TreeName treeName) argument 556 getRecordCount(TreeName treeName) argument 562 openTree(TreeName treeName, boolean createOnDemand) argument 578 put(TreeName treeName, ByteSequence key, ByteSequence value) argument 584 update(TreeName treeName, ByteSequence key, UpdateFunction f) argument 590 delete(TreeName treeName, ByteSequence key) argument 638 getOrOpenTree0(Transaction txn, Map<TreeName, Database> trees, TreeName treeName) argument 789 toDatabaseName(final TreeName treeName) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pdb/ |
H A D | PDBStorage.java | 308 public void clearTree(final TreeName treeName) argument 311 deleteTree(txn, treeName); 312 createTree(txn, treeName); 315 private void createTree(final Transaction txn, final TreeName treeName) argument 321 ex = getNewExchange(treeName, true); 335 private void deleteTree(Transaction txn, final TreeName treeName) argument 341 ex = getNewExchange(treeName, true); 365 public void put(final TreeName treeName, final ByteSequence key, final ByteSequence value) argument 369 final Exchange ex = getExchangeFromCache(treeName); 381 public ByteString read(final TreeName treeName, fina argument 396 getExchangeFromCache(final TreeName treeName) argument 409 openCursor(TreeName treeName) argument 433 put(final TreeName treeName, final ByteSequence key, final ByteSequence value) argument 449 delete(final TreeName treeName, final ByteSequence key) argument 464 deleteTree(final TreeName treeName) argument 484 getRecordCount(TreeName treeName) argument 499 openCursor(final TreeName treeName) argument 517 openTree(final TreeName treeName, boolean createOnDemand) argument 537 read(final TreeName treeName, final ByteSequence key) argument 553 update(final TreeName treeName, final ByteSequence key, final UpdateFunction f) argument 583 openCreateTree(final TreeName treeName) argument 605 getExchangeFromCache(final TreeName treeName) argument 637 read(TreeName treeName, ByteSequence key) argument 643 openCursor(TreeName treeName) argument 649 getRecordCount(TreeName treeName) argument 655 openTree(TreeName treeName, boolean createOnDemand) argument 693 put(TreeName treeName, ByteSequence key, ByteSequence value) argument 699 update(TreeName treeName, ByteSequence key, UpdateFunction f) argument 705 delete(TreeName treeName, ByteSequence key) argument 711 getNewExchange(final TreeName treeName, final boolean create) argument [all...] |