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
|
// -*- C++ -*-
//=============================================================================
/**
* @file RTConfig_Manager.h
*
* $Id$
*
* This file contains classes that manage name to configuration
* mapping info in a RTComponentServer.
*
* @author Nanbor Wang <nanbor@cs.wustl.edu>
*/
//=============================================================================
#ifndef CIAO_RTCONFIG_MANAGER_H
#define CIAO_RTCONFIG_MANAGER_H
#include /**/ "ace/pre.h"
#include "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/RTCORBA/RTCORBA.h"
#include "ciao/ServerResourcesC.h"
#include "ace/Null_Mutex.h"
#include "ace/SString.h"
#include "ace/Hash_Map_Manager_T.h"
namespace CIAO
{
/**
* @brief RTResource_Config_Manager maintains a collection of
* RTCORBA related resources.
*
* This class is responsible to create and manage a list of RTCORBA
* related resources that are global to an RT ComponentServer. The
* information required to create and configure these resources are
* passed in via the @a info argument in the @c init method. These
* resources are identified by names and can be used to associate
* these resources with related RTPolicies. These resources are
* destoryed along with this class.
*
* Currently, the only resources supported (and managed) by this
* class are Threadpool and Threadpool_with_Lanes.
*/
class RTResource_Config_Manager
{
public:
RTResource_Config_Manager (void);
~RTResource_Config_Manager (void);
void init (RTCORBA::RTORB_ptr rtorb);
/// Initializing the RTResource_Config_Manager
void init_resources (const CIAO::DAnCE::ServerResource &info
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Finalizing the RTResource_Config_Manager and the resources it
/// manages.
void fini (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Query a policy set by name
CORBA::PolicyList *find_policies_by_name (const char *name
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
protected:
void print_resources (const CIAO::DAnCE::ServerResource &info
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Query a thread pool by name.
RTCORBA::ThreadpoolId find_threadpool_by_name (const char *name
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Query a priority bands info by name.
RTCORBA::PriorityBands *find_priority_bands_by_name (const char *name
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
private:
/// Cached an ORB reference.
CORBA::ORB_var orb_;
// Cached an RTORB reference.
RTCORBA::RTORB_var rtorb_;
/// Hash_Map stuff.
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
RTCORBA::ThreadpoolId,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> TP_MAP;
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
RTCORBA::PriorityBands_var,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> PB_MAP;
/// Internal TP name to id map.
TP_MAP threadpool_map_;
/// Internal PB name to priority bands map.
PB_MAP priority_bands_map_;
/// create a single policy
CORBA::Policy_ptr create_single_policy
(const CIAO::DAnCE::PolicyDef &policy_def
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Hash_Map stuff.
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
CORBA::PolicyList_var,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> POLICY_MAP;
/// Internal TP names to id map.
POLICY_MAP policy_map_;
};
}
#if defined (__ACE_INLINE__)
# include "RTConfig_Manager.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* CIAO_RTCONFIG_MANAGER_H */
|
