/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/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();
|
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/ |
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);
|
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 | IndexBuffer.java | 143 * @param txn The database transaction to be used for the updates. 147 public void flush(Transaction txn) argument 173 index.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 188 vlvIndex.updateIndex(txn, bufferedVLVValues.addedValues, 207 id2children.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 233 id2subtree.updateKey(txn, key, bufferedKey.getValue().deletedIDs,
|
H A D | DN2URI.java | 136 * @param txn A database transaction used for the update, or null if none is 143 private boolean insert(Transaction txn, DN dn, String labeledURI) argument 154 status = put(txn, key, data); 166 * @param txn A database transaction used for the update, or null if none is 173 public boolean delete(Transaction txn, DN dn) argument 180 status = delete(txn, key); 185 containsReferrals = containsReferrals(txn); 191 * @param txn A database transaction used for the update, or null if none is 198 public boolean delete(Transaction txn, DN dn, String labeledURI) argument 208 Cursor cursor = openCursor(txn, cursorConfi 239 containsReferrals(Transaction txn) argument 286 modifyEntry(Transaction txn, Entry before, Entry after, List<Modification> mods) argument 354 replaceEntry(Transaction txn, Entry before, Entry after) argument 370 addEntry(Transaction txn, Entry entry) argument 397 deleteEntry(Transaction txn, Entry entry) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/ |
H A D | State.java | 85 * @param txn The database transaction or null if none. 90 public boolean removeIndexTrustState(Transaction txn, Index index) argument 96 OperationStatus status = delete(txn, key); 106 * @param txn The database transaction or null if none. 111 public boolean getIndexTrustState(Transaction txn, Index index) argument 121 status = read(txn, key, data, LockMode.DEFAULT); 134 * @param txn The database transaction or null if none. 139 public boolean getIndexTrustState(Transaction txn, VLVIndex vlvIndex) argument 149 status = read(txn, key, data, LockMode.DEFAULT); 162 * @param txn Th 168 putIndexTrustState(Transaction txn, Index index, boolean trusted) argument 200 putIndexTrustState(Transaction txn, VLVIndex vlvIndex, boolean trusted) 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...] |
H A D | IndexBuffer.java | 143 * @param txn The database transaction to be used for the updates. 147 public void flush(Transaction txn) argument 173 index.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 188 vlvIndex.updateIndex(txn, bufferedVLVValues.addedValues, 207 id2children.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 228 id2subtree.updateKey(txn, key, bufferedKey.getValue().deletedIDs,
|
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/ |
H A D | State.java | 102 * @param txn The database transaction or null if none. 107 public boolean removeIndexTrustState(Transaction txn, DatabaseContainer index) argument 112 OperationStatus status = delete(txn, key); 122 * @param txn The database transaction or null if none. 127 public boolean getIndexTrustState(Transaction txn, DatabaseContainer index) argument 134 status = read(txn, key, data, LockMode.DEFAULT); 147 * @param txn The database transaction or null if none. 153 public boolean putIndexTrustState(Transaction txn, DatabaseContainer index, argument 166 status = put(txn, key, data);
|
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...] |
H A D | IndexBuffer.java | 143 * @param txn The database transaction to be used for the updates. 147 public void flush(Transaction txn) argument 173 index.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 188 vlvIndex.updateIndex(txn, bufferedVLVValues.addedValues, 207 id2children.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 228 id2subtree.updateKey(txn, key, bufferedKey.getValue().deletedIDs,
|
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/ |
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);
|
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 | IndexBuffer.java | 143 * @param txn The database transaction to be used for the updates. 147 public void flush(Transaction txn) argument 173 index.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 188 vlvIndex.updateIndex(txn, bufferedVLVValues.addedValues, 207 id2children.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 233 id2subtree.updateKey(txn, key, bufferedKey.getValue().deletedIDs,
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/ |
H A D | State.java | 85 * @param txn The database transaction or null if none. 90 public boolean removeIndexTrustState(Transaction txn, Index index) argument 96 OperationStatus status = delete(txn, key); 106 * @param txn The database transaction or null if none. 111 public boolean getIndexTrustState(Transaction txn, Index index) argument 121 status = read(txn, key, data, LockMode.DEFAULT); 134 * @param txn The database transaction or null if none. 139 public boolean getIndexTrustState(Transaction txn, VLVIndex vlvIndex) argument 149 status = read(txn, key, data, LockMode.DEFAULT); 162 * @param txn Th 168 putIndexTrustState(Transaction txn, Index index, boolean trusted) argument 200 putIndexTrustState(Transaction txn, VLVIndex vlvIndex, boolean trusted) 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...] |
H A D | IndexBuffer.java | 143 * @param txn The database transaction to be used for the updates. 147 public void flush(Transaction txn) argument 173 index.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 188 vlvIndex.updateIndex(txn, bufferedVLVValues.addedValues, 207 id2children.updateKey(txn, key, bufferedKey.getValue().deletedIDs, 228 id2subtree.updateKey(txn, key, bufferedKey.getValue().deletedIDs,
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
H A D | ExportJob.java | 127 public Void run(ReadableTransaction txn) throws Exception 139 exportContainer(txn, exportContainer); 181 private void exportContainer(ReadableTransaction txn, EntryContainer entryContainer) argument 184 Cursor<ByteString, ByteString> cursor = txn.openCursor(entryContainer.getID2Entry().getName());
|
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 | 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
|
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 | 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...] |