blob: b939dbdf74b070f8e37c7c98d5ccf8718e9cc9c3 (
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
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
|
// -*- C++ -*-
//
// $Id$
#ifndef STUBFAULTNOTIFIER_H_
#define STUBFAULTNOTIFIER_H_
#include <ace/ACE.h>
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include /**/ <ace/pre.h>
#include <orbsvcs/FT_NotifierS.h>
#include <orbsvcs/FT_FaultDetectorFactoryC.h>
#include <ace/Vector_T.h>
//////////////////////
// Forward references
/////////////////////
// Class declarations
/**
* A stub implementation of the FaultNotifier interface
*/
class StubFaultNotifier : public virtual POA_FT::FaultNotifier
{
//////////////////////
// non-CORBA interface
public:
/**
* Default constructor.
*/
StubFaultNotifier ();
/**
* Virtual destructor.
*/
virtual ~StubFaultNotifier ();
/**
* Parse command line arguments.
*/
int parse_args (int argc, char * argv[]);
/**
* Initialize.
*/
int init (CORBA::ORB_ptr orb ACE_ENV_ARG_DECL);
/**
* Prepare to exit.
*/
int fini (ACE_ENV_SINGLE_ARG_DECL);
/**
* Return a string to identify this object for logging/console message purposes.
*/
const char * identity () const;
/**
* idle time activity.
* @param result [out] status code to return from process
* @returns 0 to continue; nonzero to quit
*/
int idle(int &result ACE_ENV_ARG_DECL);
// override virtuals
::PortableServer::POA_ptr _default_POA (ACE_ENV_SINGLE_ARG_DECL);
PortableServer::ObjectId objectId()const;
/**
* Clean house for process shut down.
*/
void shutdown_i (ACE_ENV_SINGLE_ARG_DECL);
////////////////////////////////
// CORBA interface FaultNotifier
virtual void push_structured_fault (
const CosNotification::StructuredEvent & event
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void push_sequence_fault (
const CosNotification::EventBatch & events
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual ::CosNotifyFilter::Filter_ptr create_subscription_filter (
const char * constraint_grammar
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((CORBA::SystemException, CosNotifyFilter::InvalidGrammar));
virtual FT::FaultNotifier::ConsumerId connect_structured_fault_consumer (
CosNotifyComm::StructuredPushConsumer_ptr push_consumer,
CosNotifyFilter::Filter_ptr filter
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual FT::FaultNotifier::ConsumerId connect_sequence_fault_consumer (
CosNotifyComm::SequencePushConsumer_ptr push_consumer,
CosNotifyFilter::Filter_ptr filter
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void disconnect_consumer (
FT::FaultNotifier::ConsumerId connection
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((CORBA::SystemException, CosEventComm::Disconnected));
//////////////////////////////////////////
// CORBA interface PullMonitorable methods
virtual CORBA::Boolean is_alive (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/////////////////
// Implementation
private:
int write_ior_file();
///////////////
// Data Members
private:
/**
* The orb
*/
CORBA::ORB_var orb_;
/**
* The POA used to activate this object.
*/
PortableServer::POA_var poa_;
/**
* The CORBA object id assigned to this object.
*/
PortableServer::ObjectId_var object_id_;
/**
* IOR of this object as assigned by poa
*/
CORBA::String_var ior_;
/**
* A file to which the factory's IOR should be written.
*/
const char * ior_output_file_;
/**
* A file from which the detecor's IOR should be read.
*/
const char * detector_ior_;
::FT::FaultDetectorFactory_var factory_;
/**
* A collection of files containing replica IORs
*/
ACE_Vector < const char * > iorReplicaFiles_;
ACE_Vector < FT::PullMonitorable_var > replicas_;
/**
* A name to be used to register with the name service.
*/
const char * ns_name_;
/**
* A human-readable string to distinguish this from other Notifiers.
*/
ACE_CString identity_;
};
#include /**/ <ace/post.h>
#endif /* STUBFAULTNOTIFIER_H_ */
|
