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
|
/**
*
* @file Containers_Info_Map.h
* @author Gan Deng <dengg@dre.vanderbilt.edu>
*
* Map of ContainerImplementationInfo sequences.
*
* $Id$
*/
#ifndef CIAO_CONTAINERS_INFO_MAP_H
#define CIAO_CONTAINERS_INFO_MAP_H
#include /**/ "ace/pre.h"
#include "ace/Null_Mutex.h"
#include "ace/Hash_Map_Manager.h"
//added for the HTTP support
#include "ace/Message_Block.h" //for ACE_Message_Block
#include "ciao/DeploymentC.h"
#include "ciao/Deployment_CoreC.h"
#include "ace/SString.h"
#include "CIAO_NAM_Export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
namespace CIAO
{
/**
* @class Container_Infos_Map
* @brief Implementation of a map of ContainerImplementationInfo sequences.
*
* This is a helper class to populate the NodeImplementationInfo struct from
* a deployment plan..
*/
class CIAO_NAM_Export Containers_Info_Map
{
public:
Containers_Info_Map (const Deployment::DeploymentPlan & plan,
const Deployment::ComponentPlans & shared_components);
Deployment::ContainerImplementationInfos *
containers_info (void);
private:
void initialize_map (void);
bool build_map (void);
bool insert_instance_into_map (
const Deployment::InstanceDeploymentDescription & instance);
bool insert_instance_into_container (
const Deployment::InstanceDeploymentDescription & instance,
Deployment::ComponentImplementationInfos & impl_infos);
/// Helper function to check wheather a component instance
/// is in the "shared components list".
bool is_shared_component (ACE_CString & name);
//Deployment::ContainerImplementationInfos_var containers_info_;
typedef
ACE_Hash_Map_Manager_Ex <ACE_CString,
Deployment::ContainerImplementationInfo *,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> MAP;
typedef MAP::iterator Iterator;
MAP map_;
const Deployment::DeploymentPlan & plan_;
/// shared components list, passed in from NodeImplementationInfoHandler
/// class.
Deployment::ComponentPlans shared_components_;
/**-------------------------------------------------------------------
* HTTP capability
* @author Stoyan Paunov
*
* Purpose: Adding the HTTP access code which will resove
* any references to HTTP URLs
*/
protected:
// @Stoyan - Please follow ACE coding guideines when naming your
//member variables. In particular, please use lower case and
//follow the name with a trailing underscore.
//directory in which to download the libraries obtained via HTTP
ACE_CString HTTP_DOWNLOAD_PATH;
/// This function checks if the HTTP_DOWNLOAD_PATH is
/// in the library load path
void
update_loader_path (void);
/// This function resolves any http location references
/// in the name of the implementation artifacts
/// It returns true on success and false on failure
bool
resolve_http_reference (const char* location,
ACE_CString &arti_name,
ACE_CString &name);
/// function to retvieve a file via HTTP
/// stores the file in the passed preallocated ACE_Message_Block
/// returns 1 on success
/// 0 on error
bool
retrieve_via_HTTP (const char* URL,
ACE_Message_Block &mb);
/// function that writes out a file to a specified location on the hand disk
/// returns 1 on success
/// 0 on already exists and replace == false
/// 0 on error
bool
write_to_disk (const char* full_path,
ACE_Message_Block& mb,
bool replace = true);
/// TODO: Fuction to remove the downloaded library to ensure
/// consisterncy in future runs
};
}
#include /**/ "ace/post.h"
#endif /*CIAO_CONTAINERS_INFO_MAP_H*/
|
