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
|
/**
* $Id$
* @file Plan_Generator_Impl.cpp
* @author Shanshan Jiang <shanshan.jiang@vanderbilt.edu>
*/
#include "Plan_Generator_Impl.h"
#include "orbsvcs/CosNamingC.h"
#include "PCVisitor.h"
#include "PCVisitorBase.h"
namespace CIAO
{
namespace Plan_Generator
{
// @todo make this a private method
static CORBA::Object_ptr
fetch_reference_naming (CORBA::ORB_ptr orb,
const char *repoman_name = 0)
{
CORBA::Object_var tmp = orb->resolve_initial_references ("NameService");
CosNaming::NamingContext_var pns =
CosNaming::NamingContext::_narrow (tmp.in ());
if (CORBA::is_nil (pns.in ()))
{
return CORBA::Object::_nil ();
}
CosNaming::Name name (1);
name.length (1);
name[0].id = CORBA::string_dup (repoman_name);
return pns->resolve (name);
}
Plan_Generator_i::Plan_Generator_i ()
: rm_ ()
{
}
bool
Plan_Generator_i::init (CORBA::ORB_ptr orb,
bool rm_use_naming,
const char *rm_name)
{
CORBA::Object_var obj;
if (rm_use_naming)
{
obj = fetch_reference_naming (orb, rm_name);
}
else
{
obj = orb->string_to_object (rm_name);
}
this->rm_ = Deployment::RepositoryManager::_narrow (obj.in ());
if (CORBA::is_nil (this->rm_.in ()))
{
ACE_ERROR ((LM_ERROR,
"(%P|%t) CIAO_PlanGenerator: nil Repository "
"Manager reference, narrow failed\n"));
return false;
}
return true;
}
bool
Plan_Generator_i::generate_plan (Deployment::DeploymentPlan &plan,
const char *package_uri,
bool use_package_name)
{
if (CORBA::is_nil (rm_.in ()))
{
ACE_ERROR ((LM_ERROR,
"(%P|%t) CIAO_Repoman: nil Execution\n"));
return false;
}
::Deployment::PackageConfiguration_var pc;
ACE_TCHAR package[PACKAGE_NAME_LEN];
size_t length = ACE_OS::strlen (package_uri);
size_t pos1 = 0;
size_t pos2 = ACE_OS::strcspn (package_uri + pos1, "+");
while (pos1 < length)
{
ACE_OS::strsncpy (package, package_uri + pos1, pos2 + 1);
if (use_package_name)
{
pc = this->rm_->findPackageByName (package);
PCVisitor pcv (plan, *pc, true);
pcv.Visit ();
}
else
{
CORBA::StringSeq_var seq = this->rm_->findNamesByType (package);
for (CORBA::ULong i = 0; i < seq->length (); ++i)
{
pc = this->rm_->findPackageByName (seq[i]);
PCVisitor pcv (plan, *pc, true);
pcv.Visit ();
}
}
pos1 += pos2 + 1;
pos2 = ACE_OS::strcspn (package_uri + pos1, "+");
}
return true;
}
bool
Plan_Generator_i::generate_plan (Deployment::DeploymentPlan &plan,
const char *specific_type,
int &index)
{
if (CORBA::is_nil (rm_.in ()))
{
ACE_ERROR ((LM_ERROR,
"(%P|%t) CIAO_Repoman: nil Execution\n"));
return false;
}
::Deployment::PackageConfiguration_var pc;
CORBA::StringSeq_var seq = rm_->findNamesByType (specific_type);
for (CORBA::ULong i = 0; i < seq->length (); ++i)
{
pc = rm_->findPackageByName (seq[i]);
PCVisitor pcv (plan, *pc, false);
index = pcv.Visit ();
}
return true;
}
}
}
|
