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
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file FT_ReplicationManagerFaultAnalyzer.h
*
* $Id$
*
* This file is part of TAO's implementation of Fault Tolerant CORBA.
* This is the Replication Manager's implementation of a fault analyzer.
*
* @author Steve Totten <totten_s@ociweb.com>
*/
//=============================================================================
#ifndef FT_REPLICATION_MANAGER_FAULT_ANALYZER_H_
#define FT_REPLICATION_MANAGER_FAULT_ANALYZER_H_
#include /**/ "ace/pre.h"
#include <ace/ACE.h>
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/FT_ReplicationManager/FT_DefaultFaultAnalyzer.h"
#include "orbsvcs/FT_CORBAC.h"
// Forward declarations.
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
template <class T> class ACE_Unbounded_Set;
template <class T> class ACE_Unbounded_Set_Iterator;
ACE_END_VERSIONED_NAMESPACE_DECL
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
namespace TAO
{
///////////////////////
// Forward declarations
class FT_ReplicationManager;
struct FT_FaultEventDescriptor;
typedef ACE_Unbounded_Set<PortableGroup::Location> FT_Location_Set;
/**
* Replication Manager's fault analyzer.
*
*/
class FT_ReplicationManagerFaultAnalyzer
: public ::TAO::FT_DefaultFaultAnalyzer
{
public:
/**
* Constructor.
* @param replication_manager Pointer to TAO::FT_ReplicationManager.
*/
FT_ReplicationManagerFaultAnalyzer (
const TAO::FT_ReplicationManager * replication_manager);
/**
* Destructor.
*/
virtual ~FT_ReplicationManagerFaultAnalyzer ();
public:
/**
* Validate event type to make sure it is one we can handle.
* @param event The structured fault event, as from the Fault Notifier.
* @return 0 if it is a valid event type, -1 otherwise.
*/
virtual int validate_event_type (
const CosNotification::StructuredEvent & event);
/**
* Analyze a fault event.
* @param event The structured fault event, as from the Fault Notifier.
* @return 0 on success, -1 on failure.
*/
virtual int analyze_fault_event (
const CosNotification::StructuredEvent & event);
////////////////////
// Forbidden methods
private:
/// Default constructor.
FT_ReplicationManagerFaultAnalyzer ();
/// Copy constructor.
FT_ReplicationManagerFaultAnalyzer (
const FT_ReplicationManagerFaultAnalyzer & rhs);
/// Assignment operator.
FT_ReplicationManagerFaultAnalyzer & operator = (
const FT_ReplicationManagerFaultAnalyzer & rhs);
/////////////////////////
// Implementation methods
protected:
/// Helper functions for fault analysis.
// Extract the type id from a CORBA any.
int get_type_id (const CORBA::Any& val, PortableGroup::TypeId_out type_id);
// Extract the ObjectGroupId from a CORBA any.
int get_object_group_id (const CORBA::Any& val, PortableGroup::ObjectGroupId& id);
// Extract the PortableGroup::Location from a CORBA any.
int get_location (const CORBA::Any& val, PortableGroup::Location_out location);
// Get the MembershipStyle property.
int get_membership_style (
const PortableGroup::Properties & properties,
PortableGroup::MembershipStyleValue & membership_style);
// Get the ReplicationStyle property.
int get_replication_style (
const PortableGroup::Properties & properties,
FT::ReplicationStyleValue & replication_style);
// Get the MinimumNumberMembers property.
int get_minimum_number_members (
const PortableGroup::Properties & properties,
PortableGroup::MinimumNumberMembersValue & minimum_number_members);
// Get the InitialNumberMembers property.
int get_initial_number_members (
const PortableGroup::Properties & properties,
PortableGroup::InitialNumberMembersValue & initial_number_members);
// Get the Factories property.
int get_factories (
const PortableGroup::Properties & properties,
PortableGroup::FactoryInfos_out factories);
// Handle a single replica failure.
int single_replica_failure (
TAO::FT_FaultEventDescriptor & fault_event_desc);
// Handle a location failure.
int location_failure (
TAO::FT_FaultEventDescriptor & fault_event_desc);
// Handle a type at location failure.
int type_failure (
TAO::FT_FaultEventDescriptor & fault_event_desc);
// Is the replica at location the primary member of its ObjectGroup?
// Sets <object_is_primary> and returns 0 on success.
// Returns -1 on failure.
int is_primary_member (
const PortableGroup::ObjectGroup_ptr iogr,
const PortableGroup::Location & location,
int & object_is_primary);
/// remove a failed member from a group
int remove_failed_member (
PortableGroup::ObjectGroup_ptr iogr,
TAO::FT_FaultEventDescriptor & fault_event_desc,
PortableGroup::ObjectGroup_out new_iogr);
// Choose a new primary member for the ObjectGroup.
// Sets <new_iogr> and returns 0 on success.
// Returns -1 on failure.
int set_new_primary (
PortableGroup::ObjectGroup_ptr iogr,
TAO::FT_FaultEventDescriptor & fault_event_desc,
PortableGroup::ObjectGroup_out new_iogr);
#if 0 // this is handled by the remove_member method
// While the number of members in the object group is less than
// the MinimumNumberMembers property, add new members.
// Sets <new_iogr> and returns 0 on success.
// Returns -1 on failure.
int add_members (
PortableGroup::ObjectGroup_ptr iogr,
TAO::FT_FaultEventDescriptor & fault_event_desc,
PortableGroup::ObjectGroup_out new_iogr);
#endif
///////////////
// Data Members
private:
FT_ReplicationManager * replication_manager_;
};
} // namespace TAO
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif /* FT_REPLICATION_MANAGER_FAULT_ANALYZER_H_ */
|
