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
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file FT_TestReplica_i.h
*
* $Id$
*
* This file declares an implementation of CORBA interface TestReplica.
*
* @author Dale Wilson <wilson_d@ociweb.com>
*/
//=============================================================================
//
#ifndef FT_TESTREPLICA_I_H_
#define FT_TESTREPLICA_I_H_
#include /**/ <ace/pre.h>
#include <ace/ACE.h>
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "FT_TestReplicaS.h"
////////////////////
// Forward Reference
class FT_ReplicaFactory_i;
/**
* Implement the TestReplica IDL interface.
*
* Persistent storage simulated by storing the counter
* in Persistent.dat.
*/
class FT_TestReplica_i : public virtual POA_FT_TEST::TestReplica
{
public:
FT_TestReplica_i (FT_ReplicaFactory_i * factory, const char * name, unsigned long factory_id);
virtual ~FT_TestReplica_i ();
/**
* parse command line arguments.
* remove any that are recognized, adjusting argc accordingly.
* @param argc classic C argc
* @param argv classic C argv
* @return 0 if ok, otherwise process exit code.
*/
int parse_args (int argc, char *argv[]);
/**
* provide information to appear in a "usage" display.
* caller will display:
* usage: [program] <usageMessage()> [other usage]
* @returns c-style string containing "bare" usage options.
*/
const char * usage_options();
/**
* Initialize this object.
* @param orbManager our ORB -- we keep var to it.
* @return zero for success; nonzero is process return code for failure.
*/
int init (CORBA::ORB_var & orb ACE_ENV_ARG_DECL);
/**
* Prepare to exit.
* @return zero for success; nonzero is process return code for failure.
*/
int fini (ACE_ENV_SINGLE_ARG_DECL);
/**
* 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);
void request_quit();
unsigned long factory_id()const;
static const char * repository_id();
::FT_TEST::TestReplica_ptr object_reference();
PortableServer::ObjectId object_id()const;
//////////////////////////////////////////
// Override CORBA servant virtual methods
virtual PortableServer::POA_ptr _default_POA (ACE_ENV_SINGLE_ARG_DECL);
virtual void _remove_ref (ACE_ENV_SINGLE_ARG_DECL);
private:
///////////////////////////
// override Replica methods
virtual void set (CORBA::Long value
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC (( CORBA::SystemException));
virtual CORBA::Long increment (CORBA::Long delta
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::Long get (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::Long counter (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void counter (CORBA::Long counter
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void die (FT_TEST::TestReplica::Bane when
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void shutdown (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
///////////////////////////
// override PullMonitorable
virtual CORBA::Boolean is_alive (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
///////////////////////////
// override Updatable
virtual ::FT::State * get_update (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, FT::NoUpdateAvailable));
virtual void set_update (const FT::State & s ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, FT::InvalidUpdate));
virtual ::FT::State * get_state (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, FT::NoStateAvailable));
virtual void set_state (const FT::State & s ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, FT::InvalidState));
////////////////
// Implement TAO_UpdateObjectGroup
virtual void tao_update_object_group (
const char * iogr,
PortableGroup::ObjectGroupRefVersion version,
CORBA::Boolean is_primary
ACE_ENV_ARG_DECL
)
ACE_THROW_SPEC ((CORBA::SystemException));
/////////////////
// implementation
private:
/**
* Load the persistent data.
* returns the data loaded.
*/
long load();
/**
* Store the persistent data.
* @param the data to be stored.
*/
void store(long value);
void suicide(const char *);
///////////////
// data members
private:
/**
* a bane code for when we should die.
*/
FT_TEST::TestReplica::Bane death_pending_;
/**
* verbosity level, settable by client.
*/
int verbose_;
/**
* who am I?
*/
ACE_CString name_;
/**
* The ID number assigned by the factory
*/
unsigned long factory_id_;
/**
* the factory that created thsi replica
*/
FT_ReplicaFactory_i * factory_;
/**
* 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_;
};
#include /**/ "ace/post.h"
#endif /* FT_TESTREPLICA_I_H_ */
|
