blob: 70ccfbf26f6397863802855ff641526c12adb5a1 (
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
|
// -*- C++ -*-
//
// $Id$
#include "StubBatchConsumer.h"
#include "ace/Get_Opt.h"
#include "orbsvcs/PortableGroup/PG_Properties_Encoder.h"
StubBatchConsumer::StubBatchConsumer ()
: quit_(0)
{
}
StubBatchConsumer::~StubBatchConsumer ()
{
}
int StubBatchConsumer::parse_args (int argc, ACE_TCHAR * argv[])
{
ACE_UNUSED_ARG (argc);
ACE_UNUSED_ARG (argv);
int optionError = 0;
// No options for now
return optionError;
}
::PortableServer::POA_ptr StubBatchConsumer::_default_POA (void)
{
return ::PortableServer::POA::_duplicate(this->poa_.in ());
}
PortableServer::ObjectId StubBatchConsumer::objectId()const
{
return this->object_id_.in();
}
/**
* register this object
*/
int StubBatchConsumer::init (CORBA::ORB_ptr orb, ::FT::FaultNotifier_var & notifier)
{
int result = 0;
this->orb_ = CORBA::ORB::_duplicate (orb);
this->notifier_ = notifier;
this->identity_ = "StubBatchConsumer";
// Use the ROOT POA for now
CORBA::Object_var poa_object =
this->orb_->resolve_initial_references (TAO_OBJID_ROOTPOA);
if (CORBA::is_nil (poa_object.in ()))
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT (" (%P|%t) Unable to initialize the POA.\n")),
-1);
// Get the POA .
this->poa_ = PortableServer::POA::_narrow (poa_object.in ());
if (CORBA::is_nil(this->poa_.in ()))
{
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT (" (%P|%t) Unable to narrow the POA.\n")),
-1);
}
PortableServer::POAManager_var poa_manager =
this->poa_->the_POAManager ();
poa_manager->activate ();
// Register with the POA.
this->object_id_ = this->poa_->activate_object (this);
// find my identity as an object
CORBA::Object_var this_obj =
this->poa_->id_to_reference (object_id_.in ());
CosNotifyFilter::Filter_var filter = CosNotifyFilter::Filter::_nil();
this->consumer_id_ = notifier->connect_sequence_fault_consumer(
CosNotifyComm::SequencePushConsumer::_narrow(this_obj.in ()),
filter.in ());
return result;
}
/**
* Return a string to identify this object for logging/console message purposes.
*/
const char * StubBatchConsumer::identity () const
{
return this->identity_.c_str();
}
/**
* Clean house for process shut down.
*/
void StubBatchConsumer::fini (void)
{
this->notifier_->disconnect_consumer(this->consumer_id_);
}
int StubBatchConsumer::idle(int & result)
{
ACE_UNUSED_ARG(result);
return this->quit_;
}
////////////////
// CORBA methods
//virtual
void StubBatchConsumer::push_structured_events (
const CosNotification::EventBatch & notifications
)
{
ACE_UNUSED_ARG (notifications);
//@@ sequence of structured event handling not written yet
}
void StubBatchConsumer::offer_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed
)
{
ACE_UNUSED_ARG (added);
ACE_UNUSED_ARG (removed);
ACE_ERROR ((LM_ERROR,
"StubBatchConsumer: offer_change call ignored.\n"
));
// @@ not implemented (not likely to be needed)
}
//virtual
void StubBatchConsumer::disconnect_sequence_push_consumer (
)
{
ACE_ERROR ((LM_ERROR,
"StubBatchConsumer:disconnect_sequence_push_consumer interpreted as quit request.\n"
));
this->quit_ = 1;
}
|
