Home
last modified time | relevance | path

Searched refs:repEnvInfo (Results 1 – 25 of 95) sorted by relevance

1234

/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/
H A DSecondaryNodeTest.java56 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 DJoinGroupTest.java46 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 DRepEnvMultiSubDirTest.java48 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 DUnknownStateReplicaTest.java36 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 DElectableGroupSizeOverrideTest.java32 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 DNodePriorityTest.java38 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 DDatabaseOperationTest.java63 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 DHardRecoveryTest.java104 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 DMasterChangeTest.java70 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 DLogRewriteWarningTest.java63 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 DUpdateJEVersionTest.java97 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 DLogFlusherTest.java48 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 DGroupShutdownTest.java37 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 DLDiffServiceTest.java37 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 DRollbackTest.java175 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 DEnvConvertTest.java55 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 DDbGroupAdminTest.java197 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 DRepEnvWrapper.java49 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 DDynamicGroupTest.java90 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 DGroupDbAckFailureTest.java46 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 DMonitorChangeListenerTest.java46 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 DOneNodeRestoreTest.java64 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 DNetworkRestoreInhibitTest.java74 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 DNetworkRestoreTest.java69 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 DRepTestUtils.java340 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 …]

1234