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
|
// $Id$
#include "Domain_Application_Impl.h"
#include "ace/Log_Msg.h"
#include "ace/streams.h"
#include "DAnCE/Logger/Log_Macros.h"
namespace DAnCE
{
DomainApplication_Impl::DomainApplication_Impl (
TNam2Nm & nams,
const Deployment::Properties & configProperty,
Deployment::Connections& conn)
: nams_ (nams)
{
DANCE_TRACE("DomainApplication_Impl::DomainApplication_Impl");
this->startLaunch (configProperty);
conn = this->connections_;
}
DomainApplication_Impl::~DomainApplication_Impl()
{
DANCE_TRACE ("DomainApplication_Impl::~DomainApplication_Impl()");
try
{
for (TApp2Mgr::iterator iter = this->node_applications_.begin();
iter != this->node_applications_.end();
++iter)
{
(*iter).int_id_->destroyApplication ( (*iter).ext_id_.in());
}
this->node_applications_.unbind_all();
}
catch (CORBA::Exception &e)
{
DANCE_ERROR((LM_ERROR, DLINFO
ACE_TEXT("DomainApplication_Impl::~DomainApplication_Impl - ")
ACE_TEXT("caught a CORBA exception %C(%C) \"%C\"\n"),
e._name(), e._rep_id(), e._info().c_str()));
}
catch(...)
{
DANCE_ERROR((LM_ERROR, DLINFO ACE_TEXT("DomainApplication_Impl::~DomainApplication_Impl - ")
ACE_TEXT("caught an unknown exception.\n")));
}
}
void
DomainApplication_Impl::finishLaunch (const Deployment::Connections & connections,
CORBA::Boolean start)
{
DANCE_TRACE ("DomainApplication_Impl::finishLaunch");
DANCE_DEBUG ((LM_DEBUG, DLINFO ACE_TEXT("DomainApplication_impl::finishLaunch - ")
ACE_TEXT("connections length is %d\n"), connections.length()));
for (TApp2Mgr::iterator iter = this->node_applications_.begin();
iter != this->node_applications_.end();
++iter)
{
(*iter).ext_id_->finishLaunch (connections, start);
}
}
void
DomainApplication_Impl::start ()
{
DANCE_TRACE ("DomainApplication_Impl::start");
for (TApp2Mgr::iterator iter = this->node_applications_.begin();
iter != this->node_applications_.end();
++iter)
{
(*iter).ext_id_->start ();
}
}
void
DomainApplication_Impl::startLaunch (
const Deployment::Properties & configProperty)
{
DANCE_TRACE ("DomainApplication_Impl::startLaunch");
for (TNam2Nm::iterator iter = this->nams_.begin();
iter != this->nams_.end();
++iter)
{
DANCE_DEBUG ((LM_TRACE, DLINFO ACE_TEXT("DomainApplication_Impl::startLaunch - ")
ACE_TEXT("Invoking startLaunch on an application\n")));
::Deployment::Connections_var conn;
Deployment::Application_ptr na = (*iter).ext_id_->startLaunch (configProperty, conn.out());
//Deployment::NodeApplication_ptr na = Deployment::NodeApplication::_narrow (a);
if (CORBA::is_nil (na))
{
DANCE_ERROR ((LM_ERROR, DLINFO
ACE_TEXT("DomainApplication_Impl::startLaunch -")
ACE_TEXT("Received nil object reference from startLaunch on node managers.\n")));
throw Deployment::StartError();
}
DANCE_DEBUG ((LM_TRACE, DLINFO
ACE_TEXT("DomainApplication_Impl::startLaunch - ")
ACE_TEXT("Application startLaunch succeeded, received %u connections\n"),
conn->length ()));
this->node_applications_.bind (na, (*iter).ext_id_);
size_t before = this->connections_.length();
this->connections_.length (before + conn->length());
for (size_t i = 0; i < conn->length(); ++i)
{
this->connections_[before+i] = (*conn) [i];
}
}
DANCE_DEBUG ((LM_DEBUG, DLINFO
ACE_TEXT("DomainApplication_Impl::startLaunch - ")
ACE_TEXT("Received %u connections from applications\n"),
this->connections_.length ()));
}
} // DAnCE
|
