blob: b34a8b6d4f5f4434a8ef011e5f697d7186a06fc7 (
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2002, 2015 Oracle and/or its affiliates. All rights reserved.
*
* $Id$
*/
package com.sleepycat.db;
import com.sleepycat.db.internal.DbConstants;
/**
A class that provides definitions for the types of network ack policy to use
when transmitting messages between replication sites using the Replication
Manager.
<p>
Set using the {@link com.sleepycat.db.EnvironmentConfig#setReplicationManagerAckPolicy EnvironmentConfig.setReplicationManagerAckPolicy} API.
*/
public final class ReplicationManagerAckPolicy {
/**
The master should wait until all replication clients have acknowledged
each permanent replication message.
*/
public static final ReplicationManagerAckPolicy ALL =
new ReplicationManagerAckPolicy("ALL", DbConstants.DB_REPMGR_ACKS_ALL);
/**
The master should wait until all currently connected
replication clients have acknowledged each permanent replication message.
*/
public static final ReplicationManagerAckPolicy ALL_AVAILABLE =
new ReplicationManagerAckPolicy(
"ALL_AVAILABLE", DbConstants.DB_REPMGR_ACKS_ALL_AVAILABLE);
/**
The master should wait until all electable peers have acknowledged
each permanent replication message (where "electable peer" means a
client capable of being subsequently elected master of the
replication group).
*/
public static final ReplicationManagerAckPolicy ALL_PEERS =
new ReplicationManagerAckPolicy(
"ALL_PEERS", DbConstants.DB_REPMGR_ACKS_ALL_PEERS);
/**
The master should not wait for any client replication message
acknowledgments.
*/
public static final ReplicationManagerAckPolicy NONE =
new ReplicationManagerAckPolicy(
"NONE", DbConstants.DB_REPMGR_ACKS_NONE);
/**
The master should wait until at least one client site has acknowledged
each permanent replication message.
*/
public static final ReplicationManagerAckPolicy ONE =
new ReplicationManagerAckPolicy("ONE", DbConstants.DB_REPMGR_ACKS_ONE);
/**
The master should wait until at least one electable peer has acknowledged
each permanent replication message (where "electable peer" means a client
capable of being subsequently elected master of the replication group).
*/
public static final ReplicationManagerAckPolicy ONE_PEER =
new ReplicationManagerAckPolicy(
"ONE_PEER", DbConstants.DB_REPMGR_ACKS_ONE_PEER);
/**
The master should wait until it has received acknowledgements from the
minimum number of electable peers sufficient to ensure that the effect
of the permanent record remains durable if an election is held (where
"electable peer" means a client capable of being subsequently elected
master of the replication group). This is the default acknowledgement
policy.
*/
public static final ReplicationManagerAckPolicy QUORUM =
new ReplicationManagerAckPolicy(
"QUORUM", DbConstants.DB_REPMGR_ACKS_QUORUM);
/* package */
static ReplicationManagerAckPolicy fromInt(int type) {
switch(type) {
case DbConstants.DB_REPMGR_ACKS_ALL:
return ALL;
case DbConstants.DB_REPMGR_ACKS_ALL_AVAILABLE:
return ALL_AVAILABLE;
case DbConstants.DB_REPMGR_ACKS_ALL_PEERS:
return ALL_PEERS;
case DbConstants.DB_REPMGR_ACKS_NONE:
return NONE;
case DbConstants.DB_REPMGR_ACKS_ONE:
return ONE;
case DbConstants.DB_REPMGR_ACKS_ONE_PEER:
return ONE_PEER;
case DbConstants.DB_REPMGR_ACKS_QUORUM:
return QUORUM;
default:
throw new IllegalArgumentException(
"Unknown ACK policy: " + type);
}
}
private String statusName;
private int id;
private ReplicationManagerAckPolicy(final String statusName, final int id) {
this.statusName = statusName;
this.id = id;
}
/* package */
int getId() {
return id;
}
/** {@inheritDoc} */
public String toString() {
return "ReplicationManagerAckPolicy." + statusName;
}
}
|
