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
|
/**
* @file C++ Implementation: AppSideReg
*
* @brief Defines implementation of AppSideReg.
*
*/
#include "AppSideReg.h"
#include "AppOptions.h"
#include "monitorC.h"
#include "ArgPair.h"
#include "ace/Barrier.h"
#include <sstream>
#include <stdexcept>
#include <algorithm>
AppSideReg::AppSideReg(ACE_Barrier *ext_barrier, CORBA::ORB_ptr orb)
: HM_ior_ (AppOptions::instance ()->host_monitor_ior()),
orb_ (CORBA::ORB::_duplicate (orb)),
external_barrier_ (ext_barrier)
{
}
AppSideReg::~AppSideReg()
{
monitor_->stop ();
orb_->destroy ();
}
void AppSideReg::unregister_process (void)
{
hmvar_->unregister_process (AppOptions::instance()->process_id().c_str());
}
int AppSideReg::svc(void)
{
try
{
//ACE_DEBUG ((LM_DEBUG, "Entering svc ()\n"));
//ArgPair arg_pair = AppOptions::instance()->arg_pair ();
//std::copy (arg_pair.argv, arg_pair.argv + arg_pair.argc,
// std::ostream_iterator<std::string> (std::cout,"\n"));
//this->orb_ = CORBA::ORB_init (arg_pair.argc, arg_pair.argv, "ORB");
//std::copy (arg_pair.argv, arg_pair.argv + arg_pair.argc,
// std::ostream_iterator<std::string> (std::cout,"\n"));
CORBA::Object_var obj = orb_->string_to_object (HM_ior_.c_str());
//ACE_DEBUG ((LM_DEBUG, "Obtained HM IOR\n"));
if (CORBA::is_nil (obj))
{
ACE_DEBUG((LM_ERROR, "Nil Reference\n"));
return 1;
}
/// Downcast the object reference to a reference of type HostMonitor.
this->hmvar_ = HostMonitor::_narrow (obj);
if (CORBA::is_nil (hmvar_))
{
ACE_DEBUG((LM_ERROR, "Argument is not a HostMonitor reference.\n"));
return 1;
}
//ACE_DEBUG ((LM_DEBUG, "Creating the monitor\n"));
ACE_Barrier internal_thread_barrier (2);
monitor_ = std::auto_ptr <AppSideMonitor_Thread>
(new AppSideMonitor_Thread (&internal_thread_barrier));
monitor_->activate ();
//ACE_DEBUG ((LM_DEBUG, "Monitor activated\n"));
internal_thread_barrier.wait ();
/// Waiting for the AppSideMonitor_Thread to finish its socket stuff.
try {
hmvar_->dump ();
} catch (CORBA::Exception & ex) {
ACE_DEBUG((LM_DEBUG,"exception from dump.\n"));
throw;
}
//ACE_DEBUG ((LM_DEBUG, "Registering process\n"));
try {
if (hmvar_->register_process (
AppOptions::instance()->process_id().c_str(),
AppOptions::instance()->host_id().c_str(),
AppOptions::instance()->get_port()))
{
ACE_DEBUG((LM_DEBUG, "Registered successfully %s with host monitor.\n",
AppOptions::instance()->process_id().c_str()));
}
else
{
ACE_DEBUG((LM_ERROR, "Registeration with the monitor failed.\n"));
}
} catch (CORBA::Exception & ex) {
ACE_DEBUG((LM_DEBUG,"exception from register_process.\n"));
throw;
}
//ACE_DEBUG ((LM_DEBUG, "Registering process\n"));
}
catch (CORBA::Exception &ex)
{
ACE_PRINT_EXCEPTION (ex, "A CORBA exception was raised:");
return -1;
}
catch (...)
{
ACE_DEBUG((LM_ERROR, "Unknown exception raised!"));
return -1;
}
external_barrier_->wait ();
return 0;
}
|
