blob: 1dbf24c79d992059fd12d18bad6b511417cf3191 (
plain)
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
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2001-2009 Oracle. All rights reserved.
*
* $Id$
*/
package db.repquote_gsg;
import java.util.Vector;
import com.sleepycat.db.ReplicationHostAddress;
import com.sleepycat.db.ReplicationManagerStartPolicy;
public class RepConfig
{
// Constant values used in the RepQuote application.
public static final String progname = "RepQuoteExampleGSG";
public static final int CACHESIZE = 10 * 1024 * 1024;
public static final int SLEEPTIME = 5000;
// Member variables containing configuration information.
// String specifying the home directory for rep files.
public String home;
// Stores an optional set of "other" hosts.
public Vector<ReplicationHostAddress> otherHosts;
// Priority within the replication group.
public int priority;
public ReplicationManagerStartPolicy startPolicy;
// The host address to listen to.
public ReplicationHostAddress thisHost;
// Optional parameter specifying the # of sites in the
// replication group.
public int totalSites;
// Member variables used internally.
private int currOtherHost;
private boolean gotListenAddress;
public RepConfig()
{
startPolicy = ReplicationManagerStartPolicy.REP_ELECTION;
home = "";
gotListenAddress = false;
totalSites = 0;
priority = 100;
currOtherHost = 0;
thisHost = new ReplicationHostAddress();
otherHosts = new Vector<ReplicationHostAddress>();
}
public java.io.File getHome()
{
return new java.io.File(home);
}
public void setThisHost(String host, int port)
{
gotListenAddress = true;
thisHost.port = port;
thisHost.host = host;
}
public ReplicationHostAddress getThisHost()
{
if (!gotListenAddress)
System.err.println("Warning: no host specified, returning default.");
return thisHost;
}
public boolean gotListenAddress() {
return gotListenAddress;
}
public void addOtherHost(String host, int port)
{
ReplicationHostAddress newInfo = new ReplicationHostAddress(host, port);
otherHosts.add(newInfo);
}
public ReplicationHostAddress getFirstOtherHost()
{
currOtherHost = 0;
if (otherHosts.size() == 0)
return null;
return (ReplicationHostAddress)otherHosts.get(currOtherHost);
}
public ReplicationHostAddress getNextOtherHost()
{
currOtherHost++;
if (currOtherHost >= otherHosts.size())
return null;
return (ReplicationHostAddress)otherHosts.get(currOtherHost);
}
public ReplicationHostAddress getOtherHost(int i)
{
if (i >= otherHosts.size())
return null;
return (ReplicationHostAddress)otherHosts.get(i);
}
}
|
