Searched defs:txn (Results 1 - 25 of 129) sorted by relevance

123456

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/spi/
H A DReadOperation.java40 * @param txn
46 T run(ReadableTransaction txn) throws Exception; argument
H A DWriteOperation.java38 * @param txn
43 void run(WriteableTransaction txn) throws Exception; argument
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DJEUtils.java56 * @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 DJEUtils.java56 * @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 DState.java101 * @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 DDN2ID.java104 * @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 DIndexBuffer.java143 * @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 DDN2URI.java136 * @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 DState.java85 * @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 DDN2ID.java105 * @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 DIndexBuffer.java143 * @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 DState.java102 * @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 DDN2ID.java105 * @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 DIndexBuffer.java143 * @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 DState.java101 * @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 DDN2ID.java104 * @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 DIndexBuffer.java143 * @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 DState.java85 * @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 DDN2ID.java105 * @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 DIndexBuffer.java143 * @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 DExportJob.java127 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 DIndex.java42 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 DTree.java45 * @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 DAbstractTree.java50 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 DState.java96 * @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...]

Completed in 135 milliseconds

123456