blob: 630bad0d6e903b9ef0174d4898b57aae14b23191 (
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
|
// -*- C++ -*-
//
// $Id$
#ifndef STUBFAULTCONSUMER_H
#define STUBFAULTCONSUMER_H
#include /**/ <ace/pre.h>
#include <ace/ACE.h>
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/orbsvcs/CosNotifyChannelAdminS.h"
#include <orbsvcs/orbsvcs/FT_NotifierC.h>
//////////////////////
// Forward references
/////////////////////
// Class declarations
/**
* A stub fault consumer for use in unit testing Fault Notifier.
*/
class StubFaultConsumer
: public virtual POA_CosNotifyComm::StructuredPushConsumer
{
public:
/**
* Default constructor.
*/
StubFaultConsumer ();
/**
* virtual destructor.
*/
virtual ~StubFaultConsumer ();
::PortableServer::POA_ptr _default_POA (ACE_ENV_SINGLE_ARG_DECL);
::PortableServer::ObjectId objectId()const;
/**
* Parse command line arguments.
*/
int parse_args (int argc, char * argv[]);
/**
* Publish this objects IOR.
*/
int init (CORBA::ORB_ptr orb, ::FT::FaultNotifier_var & notifier
ACE_ENV_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);
/**
* Clean house for process shut down.
*/
int fini (ACE_ENV_SINGLE_ARG_DECL);
size_t notifications() const;
public:
////////////////
// CORBA methods
virtual void push_structured_event(
const CosNotification::StructuredEvent ¬ification
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
throw (CORBA::SystemException, CosEventComm::Disconnected);
virtual void offer_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
throw (CORBA::SystemException, CosNotifyComm::InvalidEventType);
virtual void disconnect_structured_push_consumer(ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
throw (CORBA::SystemException);
////////////////////
// Forbidden methods
private:
StubFaultConsumer (const StubFaultConsumer & rhs);
StubFaultConsumer & operator = (const StubFaultConsumer & rhs);
/////////////////////////
// Implementation methods
private:
///////////////
// 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_;
/**
* A human-readable string to distinguish this from other FaultConsumers.
*/
ACE_CString identity_;
/**
* boolean: request quit
*/
int quit_;
/**
* the notifier
*/
::FT::FaultNotifier_var notifier_;
/**
* consumer id assigned by the notifier
*/
::FT::FaultNotifier::ConsumerId consumer_id_;
size_t notifications_;
};
#include /**/ <ace/post.h>
#endif /* STUBFAULTCONSUMER_H */
|
