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
|
// $Id$
// ==========================================================================
//
// = LIBRARY
// Orbsvcs
//
// = FILENAME
// Notify_Resource_Manager.h
//
// = DESCRIPTION
// Resource Manager for the Notify Service implementation.
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ==========================================================================
#ifndef TAO_NOTIFY_RESOURCE_MANAGER
#define TAO_NOTIFY_RESOURCE_MANAGER
#include "ace/pre.h"
#include "Notify_ID_Pool_T.h"
#include "orbsvcs/CosNotifyChannelAdminS.h"
#include "tao/POA.h"
class TAO_Notify_EventChannelFactory_i;
class TAO_Notify_EventChannel_i;
class TAO_Notify_FilterFactory_i;
class TAO_Notify_ConsumerAdmin_i;
class TAO_Notify_SupplierAdmin_i;
class TAO_Notify_StructuredProxyPushSupplier_i;
class TAO_Notify_SequenceProxyPushSupplier_i;
class TAO_Notify_ProxyPushSupplier_i;
class TAO_Notify_StructuredProxyPushConsumer_i;
class TAO_Notify_SequenceProxyPushConsumer_i;
class TAO_Notify_ProxyPushConsumer_i;
class TAO_Notify_Event_Manager;
class TAO_Notify_Resource_Manager
{
// = TITLE
// Notify_Resource_Factory
//
// = DESCRIPTION
// This is class to control all the resources needed by all the other
// classes.
// Later:The class is also a Service Object that will configure the
// service on startup.
public:
TAO_Notify_Resource_Manager (PortableServer::POA_ptr default_POA);
// Constructor.
~TAO_Notify_Resource_Manager ();
// Destructor.
// = Factory method
static TAO_Notify_Resource_Manager* create (PortableServer::POA_ptr default_POA, CORBA::Environment &ACE_TRY_ENV);
// Factory method to create the Resource Factory Manager.
// This allows other specializations of the Resource Factory to be created
// via a common interface.
// = Accessors
PortableServer::POA_ptr get_default_POA (void);
// Returns the default POA.
// = Creation methods
TAO_Notify_EventChannel_i* create_event_channel (CosNotifyChannelAdmin::EventChannelFactory_ptr parent, CORBA::Environment &ACE_TRY_ENV);
// Create an Event Channel.
TAO_Notify_ConsumerAdmin_i* create_consumer_admin (TAO_Notify_EventChannel_i* channel, CORBA::Environment &ACE_TRY_ENV);
// Create a Consumer Admin.
TAO_Notify_SupplierAdmin_i* create_supplier_admin (TAO_Notify_EventChannel_i* channel, CORBA::Environment &ACE_TRY_ENV);
// Create a Supplier Admin.
TAO_Notify_FilterFactory_i* create_filter_factory (CORBA::Environment &ACE_TRY_ENV);
// Create the Filter Factory.
TAO_Notify_Event_Manager* create_event_manager (TAO_Notify_EventChannel_i* channel, CORBA::Environment &ACE_TRY_ENV);
// Create an event manager.
TAO_Notify_StructuredProxyPushSupplier_i* create_struct_proxy_pushsupplier (TAO_Notify_ConsumerAdmin_i* parent, CORBA::Environment &ACE_TRY_ENV);
// Create a Structured ProxyPushSupplier.
TAO_Notify_SequenceProxyPushSupplier_i* create_seq_proxy_pushsupplier (TAO_Notify_ConsumerAdmin_i* parent, CORBA::Environment &ACE_TRY_ENV);
// Create a Sequence ProxyPushSupplier.
TAO_Notify_ProxyPushSupplier_i* create_proxy_pushsupplier (TAO_Notify_ConsumerAdmin_i* parent, CORBA::Environment &ACE_TRY_ENV);
// Create a ProxyPushSupplier.
TAO_Notify_StructuredProxyPushConsumer_i* create_struct_proxy_pushconsumer (TAO_Notify_SupplierAdmin_i* parent, CORBA::Environment &ACE_TRY_ENV);
// Create a Structured ProxyPushConsumer.
TAO_Notify_SequenceProxyPushConsumer_i* create_seq_proxy_pushconsumer (TAO_Notify_SupplierAdmin_i* parent, CORBA::Environment &ACE_TRY_ENV);
// Create a Sequence ProxyPushConsumer.
TAO_Notify_ProxyPushConsumer_i* create_proxy_pushconsumer (TAO_Notify_SupplierAdmin_i* parent, CORBA::Environment &ACE_TRY_ENV);
// Create a ProxyPushConsumer.
PortableServer::POA_ptr create_event_channel_POA (PortableServer::POA_ptr parent_poa, CORBA::Environment &ACE_TRY_ENV);
// Create the POA to activate Event Channels in.
PortableServer::POA_ptr create_supplier_admin_POA (PortableServer::POA_ptr parent_poa, CORBA::Environment &ACE_TRY_ENV);
// Create the POA to activate SA's in.
PortableServer::POA_ptr create_consumer_admin_POA (PortableServer::POA_ptr parent_poa, CORBA::Environment &ACE_TRY_ENV);
// Create the POA to activate CA's in.
PortableServer::POA_ptr create_proxy_pushconsumer_POA (PortableServer::POA_ptr parent_poa, CORBA::Environment &ACE_TRY_ENV);
// Create the POA to activate proxy push consumers in.
PortableServer::POA_ptr create_proxy_pushsupplier_POA (PortableServer::POA_ptr parent_poa, CORBA::Environment &ACE_TRY_ENV);
// Create the POA to activate proxy push suppliers in.
// = Object activation and POA methods
CORBA::Object_ptr activate_object_with_id (CORBA::Long id, PortableServer::POA_ptr poa,PortableServer::Servant servant, CORBA::Environment &ACE_TRY_ENV);
// Converts <id> to an ObjectId and registers with the POA <poa>.
CORBA::Object_ptr activate_object (PortableServer::POA_ptr poa,PortableServer::Servant servant, CORBA::Environment &ACE_TRY_ENV);
// Registers with the POA <poa>.
CORBA::Object_ptr servant_to_reference (PortableServer::POA_ptr poa,PortableServer::Servant servant, CORBA::Environment &ACE_TRY_ENV);
// Registers with the POA <poa>.
CORBA::Object_ptr id_to_reference (CORBA::Long id, PortableServer::POA_ptr poa, CORBA::Environment &ACE_TRY_ENV);
// Look for the Object with id <id> in <poa>.
void destroy_POA (PortableServer::POA_ptr poa, CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ());
// Destroy the <poa>
void deactivate_object (CORBA::Object_ptr obj, PortableServer::POA_ptr poa, CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ());
// Deactivate the object.
void deactivate_object (PortableServer::Servant servant, PortableServer::POA_ptr, CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ());
// Deactivate the object.
// = Options
CORBA::Boolean default_subscription_enabled (void);
// True if new born event listeners should be subscribed for all the events.
protected:
// = Helper methods
PortableServer::ObjectId* long_to_ObjectId (const CORBA::Long id);
// Converts a CORBA::Long to an ObjectId
PortableServer::POA_ptr create_generic_childPOA_i (PortableServer::POA_ptr parent_poa, CORBA::Environment &ACE_TRY_ENV);
// Create the POA with the most generic policies.
protected:
PortableServer::POA_var default_POA_;
// The default POA to use.
TAO_Notify_ID_Pool<CORBA::Long> poa_ids_;
// Id generator for poa's.
};
#include "ace/post.h"
#endif /* TAO_NOTIFY_RESOURCE_MANAGER */
|
