blob: 8fcf3d4b7e8fdaf2685887bc9791c0743650148d (
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
|
#include "Notifier_Handler.h"
#include "tao/ORB_Core.h"
Notifier_Handler::Notifier_Handler (void)
{
// No-Op.
}
// Destroy a Notifier target object.
Notifier_Handler::~Notifier_Handler (void)
{
// No-Op.
}
int
Notifier_Handler::close (void)
{
if (this->notifier_ != 0)
{
ACE_DEBUG ((LM_DEBUG,
"closing down Notifier_Handler\n"));
CORBA::release (this->notifier_);
this->notifier_ = 0;
}
// shutdown the ORB.
this->orb_->shutdown ();
return 0;
}
void
Notifier_Handler::shutdown (void)
{
ACE_ASSERT (this->shutdowncallback != 0);
this->shutdowncallback->close ();
}
int
Notifier_Handler::run (void)
{
ACE_DEBUG ((LM_DEBUG,
"Running the Supplier...\n"));
// Run the ORB.
this->orb_->run ();
return 0;
}
ACE_Reactor*
Notifier_Handler::reactor(void)
{
// @@ Please see if there's a way to get to the Reactor without
// using the TAO_ORB_Core_instance().
return TAO_ORB_Core_instance ()->reactor ();
}
Event_Comm::Notifier *
Notifier_Handler::notifier (void)
{
return this->notifier_;
}
void
Notifier_Handler::notifier (Event_Comm::Notifier *notifier)
{
if (this->notifier_ != notifier)
{
CORBA::release (this->notifier_);
this->notifier_ = notifier;
}
}
// Init function.
int
Notifier_Handler::init (int argc,
ACE_TCHAR *argv[],
ShutdownCallback* _shutdowncallback)
{
// set the callback
shutdowncallback = _shutdowncallback;
try
{
// Retrieve the ORB.
this->orb_ = CORBA::ORB_init (argc, argv);
CORBA::Object_var poa_object =
this->orb_->resolve_initial_references ("RootPOA");
PortableServer::POA_var poa =
PortableServer::POA::_narrow (poa_object.in ());
PortableServer::POAManager_var poa_manager =
poa->the_POAManager ();
poa_manager->activate ();
// Initialization of the naming service.
if (this->naming_client_.init (orb_.in ()) != 0)
ACE_ERROR_RETURN ((LM_ERROR,
"(%P|%t) Unable to initialize "
"the TAO_Naming_Client.\n"),
-1);
CosNaming::Name notifier_ref_name (1);
notifier_ref_name.length (1);
notifier_ref_name[0].id =
CORBA::string_dup (NOTIFIER_BIND_NAME);
CORBA::Object_var notifier_obj =
this->naming_client_->resolve (notifier_ref_name);
// The CORBA::Object_var object is downcast to Notifier_var
// using the <_narrow> method.
this->notifier_ =
Event_Comm::Notifier::_narrow (notifier_obj.in ());
}
catch (const CORBA::Exception& ex)
{
ex._tao_print_exception ("Notifier_Handler::init\n");
return -1;
}
return 0;
}
|
