| /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();
|