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
|
//$Id$:
/**
*
* @file NodeApplicationManager_Impl.h
*
* @auther Tao Lu <lu@dre.vanderbilt.edu>
*
**/
// @@ Tao: IMHO, its a good practice to have CIAO included to make
// things as clear as possible.
#ifndef NODEAPPLICATIONMANAGER_IMPL_H
#define NODEAPPLICATIONMANAGER_IMPL_H
// @@ Tao: Please include pre.h and post.h.
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Synch_Traits.h"
#include "DnC_DeploymentS.h"
// @@Tao: Since you are doing an implementation of the DnC, should
// this be in Deployment namespace. Wouldn't it be better put it in
// CIAO namespace?
namespace Deployment
{
/**
*
* @class NodeApplicationManager_Impl
*
* @brief This class implements the NodeApplicationManager interface.
* This interface is very simillar to the old DnC CIAO_Daemon.
*
**/
// @@ Tao: Don't you want to inherit from RefcountedServantBase.?
class NodeApplicationManager_Impl
: public virtual POA_Deployment::NodeApplicationManager
{
public:
// constructor.
NodeApplicationManager (NodeApplicationManagerManager_ptr nam_ptr,
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
// Default destructor.
virtual ~NodeApplicationManager (void);
/**
* @method startLaunch
*
* @brief
*
*/
virtual ::Deployment::Application_ptr
startLaunch (const Deployment::Properties & configProperty,
Deployment::Connections_out providedReference,
CORBA::Boolean start
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((
CORBA::SystemException,
Deployment::ResourceNotAvailable,
Deployment::StartError,
Deployment::InvalidProperty
));
/**
* @method start
*
* @brief
*
*/
irtual void destroyApplication (Deployment::Application_ptr app
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((
CORBA::SystemException,
Deployment::StopError
));
/**
* @name internal operations using the ACE_Map methods
*/
int obj_bind (const char *orb_id, CORBA::Object_ptr obj);
int obj_unbind (const char *orb_id);
int na_bind (const char *orb_id, ::Deployment::NodeApplication_ptr na);
int na_unbind (const char *orb_id);
protected:
// @@ Tao: DO you really two locks here? Can't you use just one
// and synchronize access to the map. Do you need so much
// concurrency out here?
typedef ACE_Hash_Map_Manager_Ex<const char *,
CORBA::Object_ptr,
ACE_Hash<const char *>,
ACE_Equal_To<const char *>,
TAO_SYNCH_MUTEX> OBJ_Table;
typedef OBJ_Table::iterator OBJ_Iterator;
// CIAO's Object_Set<> could be used here as well.
// It takes o(n) time to do find though.
// @@ Tao: Are you sure that Hash_Map is O(n)? :-). May be its
// good in algo class not for us.
typedef ACE_Hash_Map_Manager_Ex<const char *,
::Deployment::NodeApplication_ptr,
ACE_Hash<const char *>,
ACE_Equal_To<const char *>,
TAO_SYNCH_MUTEX> NodeApplication_Table;
typedef NodeApplication_Table::iterator NodeApplication_Iterator;
//Cached Plan
DeploymentPlan_var plan_;
//Launched Application(NodeApplication) but not terminated yet.
NodeApplication_Table nodeapplication_table;
// @@ Tao: Don't you want to use a _var here for proper memory
// management?
// Cached NodeManager
NodeManager_ptr node_manager_;
// Cached DomainApplication
DomainApplication_ptr domain_application_;
// Keep a pointer to the managing ORB serving this servant.
CORBA::ORB_var orb_;
// Keep a pointer to the managing POA.
PortableServer::POA_var poa_;
// My Canonical name.
CORBA::String_var name_;
// Internal object hash table.
OBJ_Table OBJ_table_;
}; /* class NodeApplicationManager_Impl */
}; /* namespace Deployment */
#endif /* NODEAPPLICATIONMANAGER_IMPL_H */
|
