Lines Matching refs:txn
164 Transaction txn = null;
167 txn = env.beginTransaction(null, null);
178 (txn, env, storePrefix, storePrefix + CATALOG_DB,
183 if (txn != null) {
185 txn.commit();
187 txn.abort();
330 Transaction txn = null;
334 txn = env.beginTransaction(null, null);
347 (env, txn, fileAndDbNames[0], fileAndDbNames[1],
367 openSecondaryIndexes(txn, entityMeta, priOpenState);
385 if (txn != null) {
386 txn.commit();
389 if (txn != null) {
390 txn.abort();
593 synchronized void openSecondaryIndexes(Transaction txn,
616 (txn, priIndex, entityClass, entityMeta,
631 openSecondaryIndex(Transaction txn,
684 (env, txn, fileAndDbNames[0], fileAndDbNames[1], priDb,
719 public synchronized void truncateClass(Transaction txn, Class entityClass)
735 boolean primaryExists = truncateIfExists(txn, storePrefix + clsName);
742 (txn,
758 private boolean truncateIfExists(Transaction txn, String dbName)
764 (env, txn, fileAndDbNames[0], fileAndDbNames[1],
869 (env, null/*txn*/, fileAndDbNames[0],
1239 Transaction txn = null;
1241 txn = env.beginTransaction(null, null);
1248 cursor = db.openCursor(txn, cursorConfig);
1264 if (txn != null && nWritten >= WRITES_PER_TXN) {
1267 txn.commit();
1268 txn = null;
1269 txn = env.beginTransaction(null, null);
1270 cursor = db.openCursor(txn, cursorConfig);
1285 if (txn != null) {
1287 txn.commit();
1289 txn.abort();