Home
last modified time | relevance | path

Searched refs:replicaDb (Results 1 – 7 of 7) sorted by relevance

/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/txn/
H A DLockPreemptionTest.java49 private Database replicaDb; field in LockPreemptionTest
101 replicaDb = replicaEnv.openDatabase in open()
108 replicaDb.get(null, new DatabaseEntry(KEY1), in open()
114 replicaDb.get(null, new DatabaseEntry(KEY2), in open()
126 replicaDb.close(); in close()
138 replicaDb = null; in close()
154 replicaDb.get(replicaTxn, new DatabaseEntry(KEY1), in testPreempted()
164 replicaDb.get(replicaTxn, new DatabaseEntry(KEY1), in testPreempted()
258 final Cursor replicaCursor = replicaDb.openCursor(null, null); in testPreemptedWithNonTransactionalCursor()
380 replicaDb.get(replicaTxn, new DatabaseEntry(KEY1), in testPreemptedWithReadCommittedCursorThenDbRead()
[all …]
H A DRepAutoCommitTest.java93 Database replicaDb = null; in testAutoCommit() local
113 replicaDb = replica.openDatabase(null, "Foo", dbConfig); in testAutoCommit()
118 Cursor cursor = replicaDb.openCursor(null, null); in testAutoCommit()
138 OperationStatus status = replicaDb.put(null, key, data); in testAutoCommit()
146 replicaDb.close(); in testAutoCommit()
147 replicaDb = null; in testAutoCommit()
211 replicaDb = replica.openDatabase(txn, "Foo", dbConfig); in testAutoCommit()
216 OperationStatus status = replicaDb.get(null, key, data, in testAutoCommit()
229 replicaDb.openCursor(null, null); in testAutoCommit()
237 if (replicaDb != null) { in testAutoCommit()
[all …]
H A DPostLogCommitTest.java83 Database replicaDb = liveReplica.openDatabase(null, "foo", dbConfig); in testPostLogCommitException() local
114 verifyData(null, replicaDb); in testPostLogCommitException()
117 replicaDb.close(); in testPostLogCommitException()
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/
H A DCheckConfigTest.java498 Database replicaDb = null; in checkDbConfig() local
500 replicaDb = repEnvInfo[1].getEnv().openDatabase(null, "test", in checkDbConfig()
536 if (replicaDb != null) { in checkDbConfig()
537 replicaDb.close(); in checkDbConfig()
H A DDatabaseOperationTest.java218 Database replicaDb = null; in testMasterUpdateWhileReplicaReading() local
222 replicaDb = replica.openDatabase(null, "testDb", repConfig); in testMasterUpdateWhileReplicaReading()
234 replicaDb = replica.openDatabase(null, "testDb", dbConfig); in testMasterUpdateWhileReplicaReading()
238 new ReplicaReadingThread(start, end, replicaDb); in testMasterUpdateWhileReplicaReading()
263 replicaDb.close(); in testMasterUpdateWhileReplicaReading()
269 replicaDb = replica.openDatabase(null, "testDb", dbConfig); in testMasterUpdateWhileReplicaReading()
270 assertEquals(512, replicaDb.getConfig().getNodeMaxEntries()); in testMasterUpdateWhileReplicaReading()
271 replicaDb.close(); in testMasterUpdateWhileReplicaReading()
H A DHardRecoveryTest.java255 Database replicaDb = openDb(oldMaster); in doHardRecoveryWithConstructor() local
256 checkNotThere(oldMaster, replicaDb, 2, 3, 4, 5); in doHardRecoveryWithConstructor()
257 replicaDb.close(); in doHardRecoveryWithConstructor()
H A DReplicatedTransactionTest.java451 Database replicaDb = renv.openDatabase(rt, "testDB", dbconfig); in testReplicaCommitDurability() local
454 replicaDb.get(rt, key, val, LockMode.READ_COMMITTED); in testReplicaCommitDurability()
458 replicaDb.close(); in testReplicaCommitDurability()