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
151
152
153
154
155
156
157
158
159
160
161
162
163
164
|
// -*- C++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// default_resource.h
//
// = AUTHOR
// Chris Cleeland
// Carlos O'Ryan
//
// ============================================================================
#ifndef TAO_DEFAULT_RESOURCE_H
#define TAO_DEFAULT_RESOURCE_H
#include "ace/pre.h"
#include "tao/Resource_Factory.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Singleton.h"
#include "ace/Service_Config.h"
class TAO_Object_Adapter;
class TAO_Export TAO_Default_Resource_Factory : public TAO_Resource_Factory
{
// = TITLE
// TAO's default resource factory
//
// = DESCRIPTION
// Using a <{resource source specifier}> as a discriminator, the
// factory can return resource instances which are, e.g., global,
// stored in thread-specific storage, stored in shared memory,
// etc.
//
public:
// = Initialization and termination methods.
TAO_Default_Resource_Factory (void);
// Constructor.
virtual ~TAO_Default_Resource_Factory (void);
// Destructor.
// = Service Configurator hooks.
virtual int init (int argc, char* argv[]);
// Dynamic linking hook
int parse_args (int argc, char* argv[]);
// Parse svc.conf arguments
// = Member Accessors
enum
{
TAO_ALLOCATOR_NULL_LOCK,
TAO_ALLOCATOR_THREAD_LOCK
};
// = Type of Reactor
enum
{
TAO_REACTOR_SELECT_MT, // Use ACE_Token
TAO_REACTOR_SELECT_ST, // Use ACE_Noop_Token
TAO_REACTOR_FL,
TAO_REACTOR_TK,
TAO_REACTOR_WFMO,
TAO_REACTOR_MSGWFMO,
TAO_REACTOR_TP
};
// = Reactor mappings strategy
enum
{
TAO_SINGLE_REACTOR,
TAO_REACTOR_PER_PRIORITY
};
// = Priority mapping types
enum
{
TAO_PRIORITY_MAPPING_LINEAR,
TAO_PRIORITY_MAPPING_DIRECT
};
int cdr_allocator_source (void);
// Modify and get the source for the CDR allocators
// = Resource Retrieval
virtual int use_tss_resources (void) const;
virtual int use_locked_data_blocks (void) const;
virtual TAO_Reactor_Registry *get_reactor_registry (void);
virtual ACE_Reactor *get_reactor (void);
virtual TAO_Acceptor_Registry *get_acceptor_registry (void);
virtual TAO_Connector_Registry *get_connector_registry (void);
virtual ACE_Allocator* input_cdr_dblock_allocator (void);
virtual ACE_Allocator* input_cdr_buffer_allocator (void);
virtual ACE_Allocator* output_cdr_dblock_allocator (void);
virtual ACE_Allocator* output_cdr_buffer_allocator (void);
virtual TAO_ProtocolFactorySet *get_protocol_factories (void);
virtual int init_protocol_factories (void);
virtual TAO_Resource_Factory::Caching_Strategy connection_caching_strategy_type (void) const;
virtual double purge_percentage (void) const;
virtual TAO_Priority_Mapping *get_priority_mapping (void);
protected:
virtual ACE_Reactor_Impl *allocate_reactor_impl (void) const;
// Obtain the reactor implementation
protected:
int use_tss_resources_;
// Flag indicating whether resources should be global or
// thread-specific.
int use_locked_data_blocks_;
// The type of data blocks that the ORB should use
int reactor_registry_type_;
// The type of reactor registry.
int reactor_type_;
// Flag indicating which kind of reactor we should use.
int cdr_allocator_type_;
// The type of CDR allocators.
TAO_ProtocolFactorySet protocol_factories_;
// list of loaded protocol factories.
TAO_Resource_Factory::Caching_Strategy connection_caching_type_;
// Specifies the typeof caching strategy we should use for
// connection management.
double purge_percentage_;
// Specifies the percentage of entries which should get purged on
// demand.
int reactor_mask_signals_;
// If <0> then we create reactors with signal handling disabled.
int sched_policy_;
// The scheduling policy used to initialize the priority mapping
// strategy.
int priority_mapping_type_;
// The type of priority mapping class created by this factory.
};
#if defined (__ACE_INLINE__)
#include "tao/default_resource.i"
#endif /* __ACE_INLINE__ */
ACE_STATIC_SVC_DECLARE (TAO_Default_Resource_Factory)
ACE_FACTORY_DECLARE (TAO, TAO_Default_Resource_Factory)
#include "ace/post.h"
#endif /* TAO_DEFAULT_CLIENT_H */
|
