/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/ |
H A D | SecondaryNodeTest.java | 56 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in testJoinLeaveJoin() 57 final RepEnvInfo secondaryInfo = repEnvInfo[repEnvInfo.length - 1]; in testJoinLeaveJoin() 68 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testJoinLeaveJoin() 86 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in testJoinLeaveAllJoinAll() 127 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in testSecondaryChangeMaster() 155 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in testQuorums() 230 restartNodes(repEnvInfo[1], repEnvInfo[2]); in testQuorums() 232 new RepEnvInfo[] { repEnvInfo[1], repEnvInfo[2] }, 2); in testQuorums() 286 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in testSecondaryLag() 415 secondary = repEnvInfo[repEnvInfo.length - 1]; in testCheckCompatible() [all …]
|
H A D | JoinGroupTest.java | 46 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in setUp() 47 repEnvInfo[repEnvInfo.length - 1].getRepConfig().setNodeType( in setUp() 62 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testAllJoinLeaveJoinGroup() 65 closeNodes(repEnvInfo); in testAllJoinLeaveJoinGroup() 90 (repEnvInfo[1].getEnvHome(), in testRepeatedOpen() 91 repEnvInfo[1].getRepConfig(), in testRepeatedOpen() 140 ri = repEnvInfo[i] = in testDefaultJoinGroupHelper() 165 repEnvInfo[1].openEnv in testTimeConsistencyJoinGroup() 223 repEnvInfo[0].closeEnv(); in testCopyEnvJoin() 240 repEnvInfo[0].openEnv(); in testCopyEnvJoin() [all …]
|
H A D | RepEnvMultiSubDirTest.java | 48 private RepEnvInfo[] repEnvInfo; field in RepEnvMultiSubDirTest 101 repEnvInfo = in testRepBasic() 115 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testRepBasic() 123 repEnvInfo[0].closeEnv(); in testRepBasic() 133 repEnvInfo[0].openEnv(); in testRepBasic() 249 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testHardRecovery() 253 repEnvInfo[i].closeEnv(); in testHardRecovery() 260 repEnvInfo[0].closeEnv(); in testHardRecovery() 266 master = RepTestUtils.restartGroup(repEnvInfo[1], repEnvInfo[2]); in testHardRecovery() 278 repEnvInfo[0].openEnv in testHardRecovery() [all …]
|
H A D | UnknownStateReplicaTest.java | 36 private RepEnvInfo[] repEnvInfo; field in UnknownStateReplicaTest 72 repEnvInfo[i].closeEnv(); in testBasic() 79 repEnvInfo[0].getRepConfig().setConfigParam in testBasic() 85 repEnvInfo[0].openEnv(); in testBasic() 122 repEnvInfo[1].openEnv(); in testBasic() 123 assertTrue(repEnvInfo[1].isMaster() || repEnvInfo[1].isReplica()); in testBasic() 127 assertTrue(repEnvInfo[0].isMaster() || repEnvInfo[0].isReplica()); in testBasic() 132 if (repEnvInfo[i].isMaster()) { in testBasic() 151 repEnvInfo[2].openEnv(); in testBasic() 152 assertTrue(repEnvInfo[2].isReplica()); in testBasic() [all …]
|
H A D | ElectableGroupSizeOverrideTest.java | 32 closeNodes(repEnvInfo); in testBasic() 35 RepEnvInfo ri0 = repEnvInfo[0]; in testBasic() 49 setElectableGroupSize(0, repEnvInfo); in testBasic() 50 RepEnvInfo mi = restartNodes(repEnvInfo); in testBasic() 52 closeNodes(repEnvInfo); in testBasic() 75 copyArray(repEnvInfo, simpleMajority, in testMasterDownOverride() 135 copyArray(repEnvInfo, simpleMajority - 1, in testMasterUpOverride() 172 setElectableGroupSize(override, repEnvInfo); in startGroupWithOverride() 186 repEnvInfo[i].openEnv(); in startGroupWithOverride() 191 closeNodes(repEnvInfo); in startGroupWithOverride() [all …]
|
H A D | NodePriorityTest.java | 38 closeNodes(repEnvInfo); in testNZObsoletLogfiles() 46 RepEnvInfo minfo = restartNodes(repEnvInfo); in testNZObsoletLogfiles() 48 assertEquals(repEnvInfo[repEnvInfo.length-1].getRepNode().getNodeId(), in testNZObsoletLogfiles() 52 final int secondLast = repEnvInfo.length - 2; in testNZObsoletLogfiles() 82 repEnvInfo[i].closeEnv(); in testNZObsoletLogfiles() 110 closeNodes(repEnvInfo); in testNZFailoverAndRestore() 112 final int last = repEnvInfo.length - 1; in testNZFailoverAndRestore() 120 RepEnvInfo minfo = restartNodes(repEnvInfo); in testNZFailoverAndRestore() 153 closeNodes(repEnvInfo); in testOnlyNZMasters() 163 RepEnvInfo minfo = restartNodes(repEnvInfo); in testOnlyNZMasters() [all …]
|
H A D | DatabaseOperationTest.java | 63 private RepEnvInfo[] repEnvInfo; field in DatabaseOperationTest 85 checkEquality(repEnvInfo); in testBasic() 252 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testMasterUpdateWhileReplicaReading() 327 repEnvInfo.length); in testCascade() 328 checkEquality(repEnvInfo); in testCascade() 391 repEnvInfo.length); in testDbNameOpReplicaWriteException() 392 checkEquality(repEnvInfo); in testDbNameOpReplicaWriteException() 523 checkEquality(repEnvInfo); in testLocalDatabases() 549 final int nEnvs = repEnvInfo.length; in createLocalDbs() 598 final int nEnvs = repEnvInfo.length; in checkLocalDbAbort() [all …]
|
H A D | HardRecoveryTest.java | 104 RepEnvInfo[] repEnvInfo = null; in doHardRecoveryWithConstructor() local 142 repEnvInfo[i].openEnv(cp); in doHardRecoveryWithConstructor() 146 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in doHardRecoveryWithConstructor() 155 repEnvInfo[i].closeEnv(); in doHardRecoveryWithConstructor() 189 repEnvInfo[0].abnormalCloseEnv(); in doHardRecoveryWithConstructor() 191 repEnvInfo[0].closeEnv(); in doHardRecoveryWithConstructor() 199 master = RepTestUtils.restartGroup(repEnvInfo[1], repEnvInfo[2]); in doHardRecoveryWithConstructor() 214 repEnvInfo[0].openEnv in doHardRecoveryWithConstructor() 249 repEnvInfo[0].openEnv in doHardRecoveryWithConstructor() 381 RepEnvInfo[] repEnvInfo = null; in testHardRecoveryDeadHandle() local [all …]
|
H A D | MasterChangeTest.java | 70 RepEnvInfo[] repEnvInfo = null; in testMasterBecomesReplica() local 92 repEnvInfo[i].openEnv(); in testMasterBecomesReplica() 106 makeReplicasConsistent(oldMasterTxn2, repEnvInfo[1], repEnvInfo[2]); in testMasterBecomesReplica() 167 scanData(repEnvInfo, 2, 4); in testMasterBecomesReplica() 204 scanData(repEnvInfo, 2, 4, 6); in testMasterBecomesReplica() 241 RepEnvInfo[] repEnvInfo = null; in testTransitions() local 259 repEnvInfo[i].openEnv(); in testTransitions() 291 repEnvInfo[currentIndex].getEnv(); in startTxnAndSwitch() 341 generator.scanData(repEnvInfo); in startTxnAndSwitch() 367 for (RepEnvInfo info: repEnvInfo) { in scanData() [all …]
|
H A D | LogRewriteWarningTest.java | 63 ReplicatedEnvironment env = repEnvInfo[0].getEnv(); in checkRollbacks() 84 closeNodes(repEnvInfo[0]); in checkRollbacks() 91 restartNodes(repEnvInfo[1], repEnvInfo[2]); in checkRollbacks() 98 final RepEnvInfo node2 = repEnvInfo[1]; in checkRollbacks() 99 final RepEnvInfo node3 = repEnvInfo[2]; in checkRollbacks() 112 repEnvInfo[0].getRepConfig().setLogFileRewriteListener in checkRollbacks() 118 restartNodes(repEnvInfo[0]); in checkRollbacks() 138 ReplicatedEnvironment env = repEnvInfo[0].getEnv(); in testException() 152 closeNodes(repEnvInfo[0]); in testException() 153 restartNodes(repEnvInfo[1], repEnvInfo[2]); in testException() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/impl/node/ |
H A D | UpdateJEVersionTest.java | 97 restartNodes(repEnvInfo[0], repEnvInfo[1]); in testUpdateJEVersion() 124 restartNodes(repEnvInfo[0], repEnvInfo[1], repEnvInfo[2]); in testUpdateJEVersion() 133 restartNodes(repEnvInfo[0], repEnvInfo[1]); in testUpdateJEVersion() 156 restartNodes(repEnvInfo[0], repEnvInfo[2]); in testUpdateJEVersion() 218 restartNodes(repEnvInfo[0], repEnvInfo[1], repEnvInfo[2]); in testUpdateJEVersionReplica() 255 restartNodes(repEnvInfo[0], repEnvInfo[1]); in testUpdateJEVersionDowngrade() 267 closeNodes(repEnvInfo[0], repEnvInfo[1]); in testUpdateJEVersionDowngrade() 269 restartNodes(repEnvInfo[0], repEnvInfo[1]); in testUpdateJEVersionDowngrade() 287 restartNodes(repEnvInfo[1], repEnvInfo[2]); in testUpdateJEVersionDowngrade() 324 setJEVersion(RG_V3PLUS, repEnvInfo[0], repEnvInfo[1], repEnvInfo[2]); in testUpgradeOldSecondaryNodeJoinRace() [all …]
|
H A D | LogFlusherTest.java | 48 private RepEnvInfo[] repEnvInfo; field in LogFlusherTest 67 repEnvInfo = in testBasicConfig() 69 RepTestUtils.joinGroup(repEnvInfo); in testBasicConfig() 70 assertTrue(repEnvInfo[0].isMaster()); in testBasicConfig() 73 for (int i = 0; i < repEnvInfo.length; i++) { in testBasicConfig() 111 RepTestUtils.shutdownRepEnvs(repEnvInfo); in testBasicConfig() 116 repEnvInfo = in testBasicConfig() 118 RepTestUtils.joinGroup(repEnvInfo); in testBasicConfig() 128 RepTestUtils.shutdownRepEnvs(repEnvInfo); in testBasicConfig() 176 repEnvInfo = in createRepEnvInfo() [all …]
|
H A D | GroupShutdownTest.java | 37 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in setUp() 38 repEnvInfo[repEnvInfo.length-1].getRepConfig().setNodeType( in setUp() 45 ReplicatedEnvironment mrep = repEnvInfo[0].getEnv(); in testShutdownExceptions() 55 new ReplicatedEnvironment(repEnvInfo[0].getEnvHome(), in testShutdownExceptions() 67 for (int i=1; i < repEnvInfo.length; i++) { in testShutdownExceptions() 68 repEnvInfo[i].closeEnv(); in testShutdownExceptions() 116 repEnvInfo[0].getRepNode().feederManager(). in shutdownBasic() 122 for (int i=1; i < repEnvInfo.length; i++) { in shutdownBasic() 123 RepEnvInfo repi = repEnvInfo[i]; in shutdownBasic() 151 for (int i=1; i < repEnvInfo.length; i++) { in restartReplicasNoWait() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/util/ldiff/ |
H A D | LDiffServiceTest.java | 37 private RepEnvInfo[] repEnvInfo; field in LDiffServiceTest 74 if (repEnvInfo != null) { in tearDown() 76 repEnvInfo[i].closeEnv(); in tearDown() 158 checkLDiff(repEnvInfo[0].getEnv(), in testExtraLocalData() 181 repEnvInfo[0].openEnv(); in makeTwoGroups() 183 repEnvInfo[1].openEnv(); in makeTwoGroups() 197 checkLDiff(repEnvInfo[0].getEnv(), in testExtraRemoteData() 213 checkLDiff(repEnvInfo[0].getEnv(), in testDifferentData() 248 checkLDiff(repEnvInfo[0].getEnv(), in testEmptyRemoteDb() 268 checkLDiff(repEnvInfo[0].getEnv(), in testSameEnvs() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/txn/ |
H A D | RollbackTest.java | 175 RepTestUtils.shutdownRepEnvs(repEnvInfo); in testRollingBackDbBackupAPI() 234 RepEnvInfo[] repEnvInfo = null; in masterDiesAndRejoins() local 274 for (RepEnvInfo info : repEnvInfo) { in masterDiesAndRejoins() 308 RepTestUtils.syncGroupToVLSN(repEnvInfo, repEnvInfo.length, in masterDiesAndRejoins() 343 for (RepEnvInfo repi : repEnvInfo) { in masterDiesAndRejoins() 358 for (RepEnvInfo repi : repEnvInfo) { in masterDiesAndRejoins() 379 RepEnvInfo[] repEnvInfo = null; in replicasDieAndRejoin() local 390 for (RepEnvInfo info : repEnvInfo) { in replicasDieAndRejoin() 432 for (RepEnvInfo repi : repEnvInfo) { in replicasDieAndRejoin() 471 RepTestUtils.syncGroupToVLSN(repEnvInfo, repEnvInfo.length, lastVLSN); in checkIfWholeGroupInSync() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/util/ |
H A D | EnvConvertTest.java | 55 private RepEnvInfo[] repEnvInfo; field in EnvConvertTest 116 repEnvInfo[0].openEnv(); in testOpenSequence() 126 repEnvInfo[0].openEnv(); in testOpenSequence() 142 repEnvInfo[0].openEnv(); in testOpenSequence() 212 checkEquality(repEnvInfo); in testCRUDOnDb() 255 checkEquality(repEnvInfo); in testDbOps() 284 checkEquality(repEnvInfo); in testReadOnReplica() 303 repEnvInfo[0].closeEnv(); in testTwoNodesFailover() 345 repEnvInfo = null; in testThreeNodesFailover() 356 repEnvInfo[0].closeEnv(); in testThreeNodesFailover() [all …]
|
H A D | DbGroupAdminTest.java | 197 repEnvInfo[2].closeEnv(); in testRemoveMember() 203 repEnvInfo[2].openEnv(); in testRemoveMember() 214 repEnvInfo[1].closeEnv(); in testRemoveMember() 244 repEnvInfo[1].openEnv(); in testRemoveMember() 281 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in openSecondaryNode() 282 final RepEnvInfo info = repEnvInfo[repEnvInfo.length - 1]; in openSecondaryNode() 372 MasterTransferTest.awaitSettle(repEnvInfo[0], repEnvInfo[1]); in testMastershipTransfer() 401 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testMastershipTransfer() 518 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testReplicationGroupAdmin() 680 MasterTransferTest.awaitSettle(repEnvInfo[0], repEnvInfo[1]); in tryDbGroupAdmin() [all …]
|
H A D | RepEnvWrapper.java | 49 if (repEnvInfo != null) { in create() 52 repEnvInfo = RepTestUtils.setupEnvInfos in create() 57 env = restartGroup(repEnvInfo); in create() 62 repEnvInfo = in create() 66 RepTestUtils.joinGroup(repEnvInfo); in create() 69 env = repEnvInfo[0].getEnv(); in create() 75 dirRepEnvInfoMap.put(envRootDir, repEnvInfo); in create() 107 return RepTestUtils.restartGroup(repEnvInfo); in restartGroup() 118 for (RepEnvInfo ri : repEnvInfo) { in closeInternal() 162 for (RepEnvInfo info : repEnvInfo) { in abnormalClose() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/impl/ |
H A D | DynamicGroupTest.java | 90 repEnvInfo[1].closeEnv(); in testRemoveMemberExceptions() 122 repEnvInfo[1].closeEnv(); in testDeleteMemberExceptions() 154 repEnvInfo[i].closeEnv(); in testRemoveMember() 160 repEnvInfo[i].openEnv(); in testRemoveMember() 171 final RepEnvInfo ri = repEnvInfo[i]; in testRemoveMember() 199 repEnvInfo[i].closeEnv(); in testDeleteMember() 209 repEnvInfo[i].openEnv(); in testDeleteMember() 259 repEnvInfo[1].closeEnv(); in testNoQuorum() 260 repEnvInfo[2].closeEnv(); in testNoQuorum() 264 repEnvInfo[3].openEnv(); in testNoQuorum() [all …]
|
H A D | GroupDbAckFailureTest.java | 46 repEnvInfo[3].openEnv(); in testRetriedCreation() 51 assertNull(repEnvInfo[3].getEnv()); in testRetriedCreation() 52 closeNodes(repEnvInfo[1], repEnvInfo[2]); in testRetriedCreation() 53 restartNodes(repEnvInfo[1], repEnvInfo[2]); in testRetriedCreation() 54 repEnvInfo[3].openEnv(); in testRetriedCreation() 67 RepEnvInfo master = repEnvInfo[0]; in testIgnoreUpdateFailure() 70 RepEnvInfo replica = repEnvInfo[1]; in testIgnoreUpdateFailure() 178 RepEnvInfo node1 = repEnvInfo[0]; in testZombie() 179 RepEnvInfo node2 = repEnvInfo[1]; in testZombie() 220 closeNodes(repEnvInfo); in testZombie() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/monitor/ |
H A D | MonitorChangeListenerTest.java | 46 repEnvInfo[0].closeEnv(); in testBasicBehaviors() 70 repEnvInfo[0].openEnv(); in checkGroupStart() 87 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in checkGroupStart() 114 repEnvInfo[i].openEnv(); in checkGroupStart() 235 RepTestUtils.syncGroupToLastCommit(repEnvInfo, repEnvInfo.length); in testActiveNodesWhenMonitorStarts() 265 repEnvInfo = Arrays.copyOf(repEnvInfo, pos + 1); in testAddSecondaryNode() 271 repEnvInfo[0]); in testAddSecondaryNode() 272 repEnvInfo[pos].openEnv(); in testAddSecondaryNode() 290 repEnvInfo[pos].closeEnv(); in testAddSecondaryNode() 336 repEnvInfo[1].closeEnv(); in testReplaceAsSecondaryNode() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/impl/networkRestore/ |
H A D | OneNodeRestoreTest.java | 64 final RepEnvInfo helper = repEnvInfo[0]; in testBasic() 65 closeNodes(repEnvInfo); in testBasic() 66 RepTestUtils.removeRepDirs(repEnvInfo[1], repEnvInfo[2]); in testBasic() 127 for (RepEnvInfo rei : repEnvInfo) { in testBasic() 150 closeNodes(repEnvInfo); in testWithElection() 151 RepTestUtils.removeRepDirs(repEnvInfo[1], repEnvInfo[2]); in testWithElection() 175 openWithNR(repEnvInfo[1])); in testWithElection() 184 repEnvInfo[2].openEnv(); in testWithElection() 191 closeNodes(repEnvInfo); in testIndirectHelper() 192 RepTestUtils.removeRepDirs(repEnvInfo[1], repEnvInfo[2]); in testIndirectHelper() [all …]
|
H A D | NetworkRestoreInhibitTest.java | 74 repEnvInfo[2].openEnv(); in testUnnecessaryILE() 97 repEnvInfo[2].openEnv(); in testNoILE() 100 RepTestUtils.syncGroup(repEnvInfo); in testNoILE() 110 ReplicatedEnvironment master = repEnvInfo[0].getEnv(); in setupTimedOutEnvironment() 113 populateDB(repEnvInfo[0].getEnv(), "testDB", 1000); in setupTimedOutEnvironment() 114 repEnvInfo[2].closeEnv(); in setupTimedOutEnvironment() 120 populateDB(repEnvInfo[0].getEnv(), "testDB", 10); in setupTimedOutEnvironment() 121 RepTestUtils.syncGroup(repEnvInfo); in setupTimedOutEnvironment() 122 closeNodes(repEnvInfo[0], repEnvInfo[1]); in setupTimedOutEnvironment() 134 restartNodes(repEnvInfo[0], repEnvInfo[1]); in setupTimedOutEnvironment()
|
H A D | NetworkRestoreTest.java | 69 final RepEnvInfo minfo = repEnvInfo[0]; in testLogProviders() 72 repEnvInfo = RepTestUtils.setupExtendEnvInfo(repEnvInfo, 1); in testLogProviders() 73 final RepEnvInfo sInfo = repEnvInfo[repEnvInfo.length - 1]; in testLogProviders() 80 RepEnvInfo nrInfo = repEnvInfo[1]; in testLogProviders() 104 final RepEnvInfo minfo = repEnvInfo[0]; in testConfigError() 108 RepEnvInfo nrInfo = repEnvInfo[1]; in testConfigError() 198 RepEnvInfo info2 = repEnvInfo[1]; in testBasic() 337 setExceptionListener(repEnvInfo[0]); in testLockout() 338 repEnvInfo[0].openEnv(); in testLockout() 406 setExceptionListener(repEnvInfo[0]); in testNBAbortOnSyncup() [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/utilint/ |
H A D | RepTestUtils.java | 340 return repEnvInfo; in setupEnvInfos() 366 return repEnvInfo; in setupEnvInfos() 571 shutdownRepEnvs(repEnvInfo, true); in shutdownRepEnvs() 591 if (repEnvInfo == null) { in shutdownRepEnvs() 596 for (RepEnvInfo ri : repEnvInfo) { in shutdownRepEnvs() 912 syncGroup(repEnvInfo, vlsn); in syncGroup() 987 assert repEnvInfo.length > 0; in checkNodeEquality() 1802 final RepEnvInfo repEnvInfo; field in RepTestUtils.JoinThread 1819 this.repEnvInfo = repEnvInfo; in JoinThread() 1915 final RepEnvInfo repEnvInfo; field in RepTestUtils.SyncThread [all …]
|