blob: 41750ef9d513d89c507511c917a9e2a719d1d626 (
plain)
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
|
// $Id$
// ==========================================================================
//
// = LIBRARY
// Orbsvcs
//
// = FILENAME
// Notify_EventChannelFactory_i
//
// = DESCRIPTION
// Implements the CosNotifyChannelAdmin::EventChannelFactory interface.
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ==========================================================================
#ifndef NOTIFY_EVENTCHANNELFACTORY_I_H
#define NOTIFY_EVENTCHANNELFACTORY_I_H
#include "ace/pre.h"
#include "Notify_ID_Pool_T.h"
#include "orbsvcs/CosNotifyChannelAdminS.h"
#include "notify_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class TAO_Notify_CO_Factory;
class TAO_Notify_POA_Factory;
// @@ Pradeep: here is a crazy idea: some people may want to create
// event channels as separate processes, for protection purposes. You
// may need to strategize this class to be able to do so... You could
// probably use the ImplRepo or something similar to make that work
// portably. I don't mean that you should do that right now, but
// consider it in your design.
class TAO_Notify_Export TAO_Notify_EventChannelFactory_i
: public virtual POA_CosNotifyChannelAdmin::EventChannelFactory
, public virtual PortableServer::RefCountServantBase
{
// = TITLE
// TAO_Notify_EventChannelFactory_i
//
// = DESCRIPTION
// The EventChannelFactory_i creates Event Channel objects and asigns
// IDs to it.
// It also has methods to get a previously created channel based on its
// ID.
//
public:
virtual ~TAO_Notify_EventChannelFactory_i (void);
// Destructor
static CosNotifyChannelAdmin::EventChannelFactory_ptr create (PortableServer::POA_ptr default_POA TAO_ENV_ARG_DECL);
// Create a factory servant and activates it with the default POA.
// Also creates a resource factory and assigns it this default_POA.
CosNotifyChannelAdmin::EventChannelFactory_ptr get_ref (TAO_ENV_SINGLE_ARG_DECL);
// Get the CORBA object.
void shutdown (TAO_ENV_SINGLE_ARG_DECL
#if !defined (TAO_HAS_EXCEPTIONS) || defined (TAO_LACKS_SUPPRESS_ENV)
, // This is ugly -- destroy_children should come BEFORE the env arg.
#endif
CORBA::Boolean destroy_children = 0);
// Destroy the factory
// By default, the factory's lifetime is not coupled with its creations
// Setting the <destroy_children> flag to 'true' will destory all event_channels that were created by this factory.
void event_channel_destroyed (CosNotifyChannelAdmin::ChannelID channel_id);
// Called by child EC's when they're about to go away.
// = Accesors
CosNotifyFilter::FilterFactory_ptr get_default_filter_factory (void);
// Accesor for the default filter factory shared by all EC's.
// = CosNotifyChannelAdmin::EventChannelFactory methods.
virtual CosNotifyChannelAdmin::EventChannel_ptr create_channel (
const CosNotification::QoSProperties & initial_qos,
const CosNotification::AdminProperties & initial_admin,
CosNotifyChannelAdmin::ChannelID_out id
TAO_ENV_ARG_DECL
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotification::UnsupportedQoS,
CosNotification::UnsupportedAdmin
));
virtual CosNotifyChannelAdmin::ChannelIDSeq * get_all_channels (
TAO_ENV_SINGLE_ARG_DECL
)
ACE_THROW_SPEC ((
CORBA::SystemException
));
virtual CosNotifyChannelAdmin::EventChannel_ptr get_event_channel (
CosNotifyChannelAdmin::ChannelID id
TAO_ENV_ARG_DECL
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyChannelAdmin::ChannelNotFound
));
protected:
TAO_Notify_EventChannelFactory_i (void);
// Constructor
void init_i (PortableServer::POA_ptr default_POA TAO_ENV_ARG_DECL);
// Initializes this object.
CosNotifyFilter::FilterFactory_ptr create_default_filter_factory_i (TAO_ENV_SINGLE_ARG_DECL);
// Create the default filter factory.
// = Data members
TAO_Notify_CO_Factory* channel_objects_factory_;
// The factory for channel objects.
TAO_Notify_POA_Factory* poa_factory_;
// The factory for POA based containers.
PortableServer::POA_var my_POA_;
// The POA in which we live.
// Filter objects and COS EC style proxys live here too.
PortableServer::POA_var ec_POA_;
// The POA in which we should activate EC's in.
// We create and own this.
TAO_Notify_ID_Pool_Ex<CosNotifyChannelAdmin::ChannelID,
CosNotifyChannelAdmin::ChannelIDSeq> ec_ids_;
// Id generator for event channels
ACE_Lock* lock_;
// The locking strategy.
CosNotifyFilter::FilterFactory_var default_filter_factory_;
// The default filter factory.
};
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#include "ace/post.h"
#endif /* NOTIFY_EVENTCHANNELFACTORY_I_H */
|
