/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
H A D | AbstractTree.java | 50 public final void open(WriteableTransaction txn, boolean createOnDemand) throws StorageRuntimeException argument 52 txn.openTree(name, createOnDemand); 53 afterOpen(txn, createOnDemand); 57 void afterOpen(WriteableTransaction txn, boolean createOnDemand) throws StorageRuntimeException argument 63 public final void delete(WriteableTransaction txn) throws StorageRuntimeException argument 65 beforeDelete(txn); 66 txn.deleteTree(name); 70 void beforeDelete(WriteableTransaction txn) throws StorageRuntimeException argument 76 public final long getRecordCount(ReadableTransaction txn) throws StorageRuntimeException argument 78 return txn [all...] |
H A D | Index.java | 42 EntryIDSet get(ReadableTransaction txn, ByteSequence key); argument 48 Cursor<ByteString, EntryIDSet> openCursor(ReadableTransaction txn); argument 52 void setTrusted(WriteableTransaction txn, boolean trusted); argument 54 void update(WriteableTransaction txn, ByteString key, EntryIDSet deletedIDs, EntryIDSet addedIDs); argument
|
H A D | ID2ChildrenCount.java | 68 SequentialCursor<EntryID, Void> openCursor(ReadableTransaction txn) argument 70 return transformKeysAndValues(counter.openCursor(txn), 81 * @param txn storage transaction 86 void updateCount(final WriteableTransaction txn, final EntryID entryID, final long delta) { argument 89 addToCounter(txn, entryID, delta); 95 * @param txn storage transaction 98 void updateTotalCount(final WriteableTransaction txn, final long delta) { argument 99 addToCounter(txn, TOTAL_COUNT_ENTRY_ID, delta); 102 private void addToCounter(WriteableTransaction txn, EntryID entryID, final long delta) argument 104 counter.addCount(txn, toKe 150 getCount(ReadableTransaction txn, EntryID entryID) argument 160 getTotalCount(ReadableTransaction txn) argument 171 removeCount(final WriteableTransaction txn, final EntryID entryID) argument [all...] |
H A D | State.java | 96 * @param txn The transaction or null if none. 102 EnumSet<IndexFlag> getIndexFlags(ReadableTransaction txn, TreeName indexTreeName) throws StorageRuntimeException { argument 103 checkNotNull(txn, "txn must not be null"); 106 final ByteString value = txn.read(getName(), keyForIndex(indexTreeName)); 112 * @param txn a non null transaction 116 * @throws NullPointerException if txn, index or flags is null 119 boolean addFlagsToIndex(WriteableTransaction txn, TreeName indexTreeName, final IndexFlag... flags) argument 121 checkNotNull(txn, "txn mus 169 removeFlagsFromIndex(WriteableTransaction txn, TreeName indexTreeName, final IndexFlag... flags) argument 201 deleteRecord(WriteableTransaction txn, TreeName indexTreeName) argument [all...] |
H A D | Tree.java | 45 * @param txn 51 void open(WriteableTransaction txn, boolean createOnDemand) throws StorageRuntimeException; argument 56 * @param txn 61 void delete(WriteableTransaction txn) throws StorageRuntimeException; argument 66 * @param txn 72 long getRecordCount(ReadableTransaction txn) throws StorageRuntimeException; argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/spi/ |
H A D | ReadOperation.java | 40 * @param txn 46 T run(ReadableTransaction txn) throws Exception; argument
|
H A D | WriteOperation.java | 38 * @param txn 43 void run(WriteableTransaction txn) throws Exception; argument
|
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/ |
H A D | DatabaseContainer.java | 102 Transaction txn = 106 database = env.openDatabase(txn, name, dbConfig); 111 txn.getId()); 113 EntryContainer.transactionCommit(txn); 117 EntryContainer.transactionAbort(txn); 165 * @param txn The JE transaction handle, or null if none. 171 protected OperationStatus put(Transaction txn, DatabaseEntry key, argument 175 OperationStatus status = database.put(txn, key, data); 179 txn, key, data); 187 * @param txn Th 195 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 218 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 239 delete(Transaction txn, DatabaseEntry key) argument 262 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | NullIndex.java | 88 public boolean insertID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 133 void updateKey(Transaction txn, DatabaseEntry key, EntryIDSet deletedIDs, argument 154 public void removeID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 165 public void delete(Transaction txn, Set<byte[]> keySet, EntryID entryID) argument 186 public ConditionResult containsID(Transaction txn, DatabaseEntry key, argument 197 public EntryIDSet readKey(DatabaseEntry key, Transaction txn, argument 208 public void writeKey(Transaction txn, DatabaseEntry key, argument 261 public boolean addEntry(Transaction txn, EntryID entryID, Entry entry) argument 283 public void removeEntry(Transaction txn, EntryID entryID, Entry entry) argument 294 public void modifyEntry(Transaction txn, EntryI argument 336 setTrusted(Transaction txn, boolean trusted) argument 407 put(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 418 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 429 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 440 delete(Transaction txn, DatabaseEntry key) argument 451 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | DN2ID.java | 104 * @param txn A JE database transaction to be used for the database operation, 113 public boolean insert(Transaction txn, DN dn, EntryID id) argument 122 status = insert(txn, key, data); 134 * @param txn A JE database transaction to be used for the database operation, 142 public boolean put(Transaction txn, DN dn, EntryID id) argument 150 status = put(txn, key, data); 161 * @param txn A JE database transaction to be used for the database operation, 169 public OperationStatus put(Transaction txn, DatabaseEntry key, argument 173 return super.put(txn, key, data); 178 * @param txn 185 remove(Transaction txn, DN dn) argument 204 delete(Transaction txn, DatabaseEntry key) argument 219 get(Transaction txn, DN dn, LockMode lockMode) argument 240 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument [all...] |
H A D | State.java | 101 * @param txn The database transaction or null if none. 106 public boolean removeIndexTrustState(Transaction txn, DatabaseContainer index) argument 111 OperationStatus status = delete(txn, key); 121 * @param txn The database transaction or null if none. 126 public boolean getIndexTrustState(Transaction txn, DatabaseContainer index) argument 133 status = read(txn, key, data, LockMode.DEFAULT); 146 * @param txn The database transaction or null if none. 152 public boolean putIndexTrustState(Transaction txn, DatabaseContainer index, argument 165 status = put(txn, key, data);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/ |
H A D | DatabaseContainer.java | 103 Transaction txn = 107 database = env.openDatabase(txn, name, dbConfig); 112 txn.getId()); 114 EntryContainer.transactionCommit(txn); 118 EntryContainer.transactionAbort(txn); 166 * @param txn The JE transaction handle, or null if none. 172 protected OperationStatus put(Transaction txn, DatabaseEntry key, argument 176 OperationStatus status = database.put(txn, key, data); 180 txn, key, data); 188 * @param txn Th 196 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 219 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 240 delete(Transaction txn, DatabaseEntry key) argument 263 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | NullIndex.java | 89 public boolean insertID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 134 void updateKey(Transaction txn, DatabaseEntry key, EntryIDSet deletedIDs, argument 155 public void removeID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 166 public void delete(Transaction txn, Set<byte[]> keySet, EntryID entryID) argument 187 public ConditionResult containsID(Transaction txn, DatabaseEntry key, argument 198 public EntryIDSet readKey(DatabaseEntry key, Transaction txn, argument 209 public void writeKey(Transaction txn, DatabaseEntry key, argument 262 public boolean addEntry(Transaction txn, EntryID entryID, Entry entry) argument 284 public void removeEntry(Transaction txn, EntryID entryID, Entry entry) argument 295 public void modifyEntry(Transaction txn, EntryI argument 337 setTrusted(Transaction txn, boolean trusted) argument 408 put(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 419 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 430 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 441 delete(Transaction txn, DatabaseEntry key) argument 452 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | DN2ID.java | 105 * @param txn A JE database transaction to be used for the database operation, 114 public boolean insert(Transaction txn, DN dn, EntryID id) argument 123 status = insert(txn, key, data); 135 * @param txn A JE database transaction to be used for the database operation, 143 public boolean put(Transaction txn, DN dn, EntryID id) argument 151 status = put(txn, key, data); 162 * @param txn A JE database transaction to be used for the database operation, 170 public OperationStatus put(Transaction txn, DatabaseEntry key, argument 174 return super.put(txn, key, data); 179 * @param txn 186 remove(Transaction txn, DN dn) argument 205 delete(Transaction txn, DatabaseEntry key) argument 220 get(Transaction txn, DN dn, LockMode lockMode) argument 241 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/ |
H A D | DatabaseContainer.java | 103 Transaction txn = 107 database = env.openDatabase(txn, name, dbConfig); 112 txn.getId()); 114 EntryContainer.transactionCommit(txn); 118 EntryContainer.transactionAbort(txn); 166 * @param txn The JE transaction handle, or null if none. 172 protected OperationStatus put(Transaction txn, DatabaseEntry key, argument 176 OperationStatus status = database.put(txn, key, data); 180 txn, key, data); 188 * @param txn Th 196 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 219 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 240 delete(Transaction txn, DatabaseEntry key) argument 263 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | NullIndex.java | 89 public boolean insertID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 134 void updateKey(Transaction txn, DatabaseEntry key, EntryIDSet deletedIDs, argument 155 public void removeID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 166 public void delete(Transaction txn, Set<byte[]> keySet, EntryID entryID) argument 187 public ConditionResult containsID(Transaction txn, DatabaseEntry key, argument 198 public EntryIDSet readKey(DatabaseEntry key, Transaction txn, argument 209 public void writeKey(Transaction txn, DatabaseEntry key, argument 262 public boolean addEntry(Transaction txn, EntryID entryID, Entry entry) argument 284 public void removeEntry(Transaction txn, EntryID entryID, Entry entry) argument 295 public void modifyEntry(Transaction txn, EntryI argument 337 setTrusted(Transaction txn, boolean trusted) argument 408 put(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 419 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 430 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 441 delete(Transaction txn, DatabaseEntry key) argument 452 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | DN2ID.java | 105 * @param txn A JE database transaction to be used for the database operation, 114 public boolean insert(Transaction txn, DN dn, EntryID id) argument 123 status = insert(txn, key, data); 135 * @param txn A JE database transaction to be used for the database operation, 143 public boolean put(Transaction txn, DN dn, EntryID id) argument 151 status = put(txn, key, data); 162 * @param txn A JE database transaction to be used for the database operation, 170 public OperationStatus put(Transaction txn, DatabaseEntry key, argument 174 return super.put(txn, key, data); 179 * @param txn 186 remove(Transaction txn, DN dn) argument 205 delete(Transaction txn, DatabaseEntry key) argument 220 get(Transaction txn, DN dn, LockMode lockMode) argument 241 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/ |
H A D | DatabaseContainer.java | 102 Transaction txn = 106 database = env.openDatabase(txn, name, dbConfig); 111 txn.getId()); 113 EntryContainer.transactionCommit(txn); 117 EntryContainer.transactionAbort(txn); 165 * @param txn The JE transaction handle, or null if none. 171 protected OperationStatus put(Transaction txn, DatabaseEntry key, argument 175 OperationStatus status = database.put(txn, key, data); 179 txn, key, data); 187 * @param txn Th 195 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 218 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 239 delete(Transaction txn, DatabaseEntry key) argument 262 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | NullIndex.java | 88 public boolean insertID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 133 void updateKey(Transaction txn, DatabaseEntry key, EntryIDSet deletedIDs, argument 154 public void removeID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 165 public void delete(Transaction txn, Set<byte[]> keySet, EntryID entryID) argument 186 public ConditionResult containsID(Transaction txn, DatabaseEntry key, argument 197 public EntryIDSet readKey(DatabaseEntry key, Transaction txn, argument 208 public void writeKey(Transaction txn, DatabaseEntry key, argument 261 public boolean addEntry(Transaction txn, EntryID entryID, Entry entry) argument 283 public void removeEntry(Transaction txn, EntryID entryID, Entry entry) argument 294 public void modifyEntry(Transaction txn, EntryI argument 336 setTrusted(Transaction txn, boolean trusted) argument 407 put(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 418 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 429 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 440 delete(Transaction txn, DatabaseEntry key) argument 451 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | DN2ID.java | 104 * @param txn A JE database transaction to be used for the database operation, 113 public boolean insert(Transaction txn, DN dn, EntryID id) argument 122 status = insert(txn, key, data); 134 * @param txn A JE database transaction to be used for the database operation, 142 public boolean put(Transaction txn, DN dn, EntryID id) argument 150 status = put(txn, key, data); 161 * @param txn A JE database transaction to be used for the database operation, 169 public OperationStatus put(Transaction txn, DatabaseEntry key, argument 173 return super.put(txn, key, data); 178 * @param txn 185 remove(Transaction txn, DN dn) argument 204 delete(Transaction txn, DatabaseEntry key) argument 219 get(Transaction txn, DN dn, LockMode lockMode) argument 240 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/ |
H A D | DatabaseContainer.java | 103 Transaction txn = 107 database = env.openDatabase(txn, name, dbConfig); 112 txn.getId()); 114 EntryContainer.transactionCommit(txn); 118 EntryContainer.transactionAbort(txn); 166 * @param txn The JE transaction handle, or null if none. 172 protected OperationStatus put(Transaction txn, DatabaseEntry key, argument 176 OperationStatus status = database.put(txn, key, data); 180 txn, key, data); 188 * @param txn Th 196 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 219 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 240 delete(Transaction txn, DatabaseEntry key) argument 263 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | NullIndex.java | 89 public boolean insertID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 134 void updateKey(Transaction txn, DatabaseEntry key, EntryIDSet deletedIDs, argument 155 public void removeID(Transaction txn, DatabaseEntry key, EntryID entryID) argument 166 public void delete(Transaction txn, Set<byte[]> keySet, EntryID entryID) argument 187 public ConditionResult containsID(Transaction txn, DatabaseEntry key, argument 198 public EntryIDSet readKey(DatabaseEntry key, Transaction txn, argument 209 public void writeKey(Transaction txn, DatabaseEntry key, argument 262 public boolean addEntry(Transaction txn, EntryID entryID, Entry entry) argument 284 public void removeEntry(Transaction txn, EntryID entryID, Entry entry) argument 295 public void modifyEntry(Transaction txn, EntryI argument 337 setTrusted(Transaction txn, boolean trusted) argument 408 put(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 419 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument 430 insert(Transaction txn, DatabaseEntry key, DatabaseEntry data) argument 441 delete(Transaction txn, DatabaseEntry key) argument 452 openCursor(Transaction txn, CursorConfig cursorConfig) argument [all...] |
H A D | DN2ID.java | 105 * @param txn A JE database transaction to be used for the database operation, 114 public boolean insert(Transaction txn, DN dn, EntryID id) argument 123 status = insert(txn, key, data); 135 * @param txn A JE database transaction to be used for the database operation, 143 public boolean put(Transaction txn, DN dn, EntryID id) argument 151 status = put(txn, key, data); 162 * @param txn A JE database transaction to be used for the database operation, 170 public OperationStatus put(Transaction txn, DatabaseEntry key, argument 174 return super.put(txn, key, data); 179 * @param txn 186 remove(Transaction txn, DN dn) argument 205 delete(Transaction txn, DatabaseEntry key) argument 220 get(Transaction txn, DN dn, LockMode lockMode) argument 241 read(Transaction txn, DatabaseEntry key, DatabaseEntry data, LockMode lockMode) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | JEUtils.java | 56 * @param txn 59 public static void abort(Transaction txn) argument 61 if (txn != null) 65 txn.abort();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | JEUtils.java | 56 * @param txn 59 public static void abort(Transaction txn) argument 61 if (txn != null) 65 txn.abort();
|