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
|
// -*- 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 "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_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_WFMO,
TAO_REACTOR_MSGWFMO,
TAO_REACTOR_TP
};
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 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;
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_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.
};
#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)
#endif /* TAO_DEFAULT_CLIENT_H */
|
