1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2010, 2012 Oracle and/or its affiliates. All rights reserved.
*
*/
package repmgrtests;
import java.io.File;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.*;
import com.sleepycat.db.Database;
import com.sleepycat.db.DatabaseConfig;
import com.sleepycat.db.DatabaseEntry;
import com.sleepycat.db.DatabaseType;
import com.sleepycat.db.Environment;
import com.sleepycat.db.EnvironmentConfig;
import com.sleepycat.db.ReplicationConfig;
import com.sleepycat.db.ReplicationManagerSiteConfig;
import com.sleepycat.db.ReplicationManagerStartPolicy;
import com.sleepycat.db.ReplicationTimeoutType;
import com.sleepycat.db.VerboseConfig;
/**
* Regression test for #15927. If no clients running, master should
* not wait for acks. If acks are required according to the policy,
* master should return failure immediately.
*/
public class TestNoClient {
private static final String TEST_DIR_NAME = "TESTDIR";
private File testdir;
@Before public void setUp() throws Exception {
testdir = new File(TEST_DIR_NAME);
Util.rm_rf(testdir);
testdir.mkdir();
}
@Test public void timeTxns() throws Exception {
doIt(false);
}
@Test public void timePeer() throws Exception {
doIt(true);
}
private void doIt(boolean peer) throws Exception {
int[] testPorts = Util.findAvailablePorts(2);
int masterPort = testPorts[0];
int clientPort = testPorts[1];
EnvironmentConfig ec = makeBasicConfig();
EventHandler mon = new EventHandler();
ec.setEventHandler(mon);
ReplicationManagerSiteConfig local = new ReplicationManagerSiteConfig("localhost", masterPort);
local.setLocalSite(true);
local.setLegacy(true);
ec.addReplicationManagerSite(local);
ReplicationManagerSiteConfig clientConfig = new ReplicationManagerSiteConfig("localhost", clientPort);
clientConfig.setPeer(peer);
clientConfig.setLegacy(true);
ec.addReplicationManagerSite(clientConfig);
Environment master = new Environment(mkdir("master"), ec);
master.setReplicationConfig(ReplicationConfig.STRICT_2SITE, false);
master.replicationManagerStart(1, ReplicationManagerStartPolicy.REP_MASTER);
DatabaseConfig dc = new DatabaseConfig();
dc.setTransactional(true);
dc.setAllowCreate(true);
dc.setType(DatabaseType.BTREE);
Database db = master.openDatabase(null, "test.db", null, dc);
// Make the Ack timeout huge (10 seconds), to make it very
// easy to discern whether the master waited.
//
master.setReplicationTimeout(ReplicationTimeoutType.ACK_TIMEOUT,
10000000);
int initialFailureCount = mon.getPermFailCount();
long startTime = System.currentTimeMillis();
DatabaseEntry key = new DatabaseEntry();
DatabaseEntry value = new DatabaseEntry();
key.setData("msg".getBytes());
value.setData("hello, world!".getBytes());
db.put(null, key, value);
assertEquals(initialFailureCount + 1, mon.getPermFailCount());
// Note that Java measures time in milliseconds, although DB
// required us to specify microseconds (above).
//
long duration = System.currentTimeMillis() - startTime;
assertTrue(duration < 5000);
db.close();
master.close();
}
public static EnvironmentConfig makeBasicConfig() {
EnvironmentConfig ec = new EnvironmentConfig();
ec.setAllowCreate(true);
ec.setInitializeCache(true);
ec.setInitializeLocking(true);
ec.setInitializeLogging(true);
ec.setInitializeReplication(true);
ec.setTransactional(true);
ec.setThreaded(true);
if (Boolean.getBoolean("VERB_REPLICATION"))
ec.setVerbose(VerboseConfig.REPLICATION, true);
return (ec);
}
public File mkdir(String dname) {
File f = new File(testdir, dname);
f.mkdir();
return f;
}
}
|
