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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2009, 2015 Oracle and/or its affiliates. All rights reserved.
*
*/
using System;
using System.Collections.Generic;
using System.Text;
using BerkeleyDB.Internal;
namespace BerkeleyDB {
/// <summary>
/// A class representing the return value of
/// <see cref="DatabaseEnvironment.RepProcessMessage"/>.
/// </summary>
public class RepProcMsgResult {
/// <summary>
/// The result of processing an incoming replication message.
/// </summary>
public enum ProcMsgResult {
/// <summary>
/// The replication group has more than one master.
/// </summary>
/// <remarks>
/// The application should reconfigure itself as a client by calling
/// <see cref="DatabaseEnvironment.RepStartClient"/>,
/// and then call for an election using
/// <see cref="DatabaseEnvironment.RepHoldElection"/>.
/// </remarks>
DUPLICATE_MASTER,
/// <summary>
/// An unspecified error occurred.
/// </summary>
ERROR,
/// <summary>
/// An election is needed.
/// </summary>
/// <remarks>
/// The application should call for an election using
/// <see cref="DatabaseEnvironment.RepHoldElection"/>.
/// </remarks>
HOLD_ELECTION,
/// <summary>
/// A message cannot be processed.
/// </summary>
/// <remarks>
/// This is an indication that a message is irrelevant to the
/// current replication state (for example, an old message from a
/// previous generation arrives and is processed late).
/// </remarks>
IGNORED,
/// <summary>
/// Processing a message resulted in the processing of records that
/// are permanent.
/// </summary>
/// <remarks>
/// <see cref="RetLsn"/> is the maximum LSN of the permanent
/// records stored.
/// </remarks>
IS_PERMANENT,
/// <summary>
/// A new master has been chosen but the client is unable to
/// synchronize with the new master.
/// </summary>
/// <remarks>
/// Possibly because the client has turned off automatic
/// internal initialization (the
/// <see cref="ReplicationConfig.AutoInit"/> setting).
/// </remarks>
JOIN_FAILURE,
/// <summary>
/// The system received contact information from a new environment.
/// </summary>
/// <remarks>
/// The rec parameter to
/// <see cref="DatabaseEnvironment.RepProcessMessage"/> contains the
/// opaque data specified in the cdata parameter to
/// <see cref="DatabaseEnvironment.RepStartClient"/>. The
/// application should take whatever action is needed to establish a
/// communication channel with this new environment.
/// </remarks>
NEW_SITE,
/// <summary>
/// A message carrying a DB_REP_PERMANENT flag was processed
/// successfully, but was not written to disk.
/// </summary>
/// <remarks>
/// <see cref="RetLsn"/> is the LSN of this record. The application
/// should take whatever action is deemed necessary to retain its
/// recoverability characteristics.
/// </remarks>
NOT_PERMANENT,
/// <summary>
/// Processing a message succeded.
/// </summary>
SUCCESS
};
/// <summary>
/// The result of processing an incoming replication message.
/// </summary>
public ProcMsgResult Result;
/// <summary>
/// The log sequence number of the permanent log message that could not
/// be written to disk if <see cref="Result"/> is
/// <see cref="ProcMsgResult.NOT_PERMANENT"/>. The largest log
/// sequence number of the permanent records that are now written to
/// disk as a result of processing the message, if
/// <see cref="Result"/> is
/// <see cref="ProcMsgResult.IS_PERMANENT"/>. In all other cases the
/// value is undefined.
/// </summary>
public LSN RetLsn;
internal RepProcMsgResult(int ret, LSN dblsn) {
RetLsn = null;
switch (ret) {
case DbConstants.DB_REP_DUPMASTER:
Result = ProcMsgResult.DUPLICATE_MASTER;
break;
case DbConstants.DB_REP_HOLDELECTION:
Result = ProcMsgResult.HOLD_ELECTION;
break;
case DbConstants.DB_REP_IGNORE:
Result = ProcMsgResult.IGNORED;
break;
case DbConstants.DB_REP_ISPERM:
Result = ProcMsgResult.IS_PERMANENT;
break;
case DbConstants.DB_REP_JOIN_FAILURE:
Result = ProcMsgResult.JOIN_FAILURE;
break;
case DbConstants.DB_REP_NEWSITE:
Result = ProcMsgResult.NEW_SITE;
break;
case DbConstants.DB_REP_NOTPERM:
Result = ProcMsgResult.NOT_PERMANENT;
break;
case 0:
Result = ProcMsgResult.SUCCESS;
break;
default:
Result = ProcMsgResult.ERROR;
break;
}
}
}
}
|
