blob: d7fa4abf2b4ef4eabed3f0706675b8d89e5ad0f7 (
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
158
159
160
161
162
163
164
165
166
167
168
169
170
171
|
/* -*- C++ -*- */
// $Id$
//
// ============================================================================
//
// = LIBRARY
// TAO services
//
// = FILENAME
// Module_Factory
//
// = AUTHOR
// Carlos O'Ryan
//
// = DESCRIPTION
// The has strategies to handle several phases of the Event
// processing, for instance dispatching can be implemented using
// queues and different threads or just FIFO.
// The choice of the strategies is controlled by a Factory class
// that builds the right modules for the EC.
//
// = TODO
// Some of the strategies are still hard-coded.
//
// ============================================================================
#ifndef TAO_MODULE_FACTORY_H
#define TAO_MODULE_FACTORY_H
#include "orbsvcs/orbsvcs_export.h"
class ACE_EventChannel;
class ACE_ES_Dispatching_Base;
class ACE_ES_Consumer_Module;
class ACE_ES_Correlation_Module;
class ACE_ES_Subscription_Module;
class ACE_ES_Supplier_Module;
class ACE_ES_Priority_Timer;
class TAO_EC_Timer_Module;
class TAO_ORBSVCS_Export TAO_Module_Factory
{
// = TITLE
// Factory class for the Event Channel "modules".
//
// = DESCRIPTION
// The Event Channel "modules" represent the different phases and
// strategies in event processing. Event Channel configuration is
// achieved by constructing modules with different dynamic
// types. This class encapsulates all the strategies creation in
// a single point.
//
public:
virtual ~TAO_Module_Factory (void);
virtual ACE_ES_Dispatching_Base*
create_dispatching_module (ACE_EventChannel*) = 0;
virtual void destroy_dispatching_module (ACE_ES_Dispatching_Base*) = 0;
virtual ACE_ES_Consumer_Module*
create_consumer_module (ACE_EventChannel*) = 0;
virtual void destroy_consumer_module (ACE_ES_Consumer_Module*) = 0;
virtual ACE_ES_Correlation_Module*
create_correlation_module (ACE_EventChannel*) = 0;
virtual void destroy_correlation_module (ACE_ES_Correlation_Module*) = 0;
virtual ACE_ES_Subscription_Module*
create_subscription_module (ACE_EventChannel*) = 0;
virtual void destroy_subscription_module (ACE_ES_Subscription_Module*) = 0;
virtual ACE_ES_Supplier_Module*
create_supplier_module (ACE_EventChannel*) = 0;
virtual void destroy_supplier_module (ACE_ES_Supplier_Module*) = 0;
virtual TAO_EC_Timer_Module*
create_timer_module (ACE_EventChannel*) = 0;
virtual void destroy_timer_module (TAO_EC_Timer_Module*) = 0;
};
// ****************************************************************
class TAO_ORBSVCS_Export TAO_Default_Module_Factory : public TAO_Module_Factory
{
// = TITLE
// Default factory class for the Event Channel.
//
// = DESCRIPTION
// The Event Channel "modules" represent the different phases and
// strategies in event processing. Event Channel configuration is
// achieved by constructing modules with different dynamic
// types. This class encapsulates all the strategies creation in
// a single point.
//
public:
TAO_Default_Module_Factory (void);
virtual ~TAO_Default_Module_Factory (void);
virtual ACE_ES_Dispatching_Base*
create_dispatching_module (ACE_EventChannel*);
virtual void destroy_dispatching_module (ACE_ES_Dispatching_Base*);
virtual ACE_ES_Consumer_Module*
create_consumer_module (ACE_EventChannel*);
virtual void destroy_consumer_module (ACE_ES_Consumer_Module*);
virtual ACE_ES_Correlation_Module*
create_correlation_module (ACE_EventChannel*);
virtual void destroy_correlation_module (ACE_ES_Correlation_Module*);
virtual ACE_ES_Subscription_Module*
create_subscription_module (ACE_EventChannel*);
virtual void destroy_subscription_module (ACE_ES_Subscription_Module*);
virtual ACE_ES_Supplier_Module*
create_supplier_module (ACE_EventChannel*);
virtual void destroy_supplier_module (ACE_ES_Supplier_Module*);
virtual TAO_EC_Timer_Module*
create_timer_module (ACE_EventChannel*);
virtual void destroy_timer_module (TAO_EC_Timer_Module*);
};
// ****************************************************************
class TAO_ORBSVCS_Export TAO_Reactive_Module_Factory : public TAO_Module_Factory
{
// = TITLE
// Factory class for the Event Channel "modules".
//
// = DESCRIPTION
// This class factors out modules that require no extra threads
// for event or timer dispatching.
// An Event Channel configured with this factory can exhibit high
// priority inversion, but it should provide high-performance due
// to the elimination of context switching.
//
public:
TAO_Reactive_Module_Factory (void);
virtual ~TAO_Reactive_Module_Factory (void);
virtual ACE_ES_Dispatching_Base*
create_dispatching_module (ACE_EventChannel*);
virtual void destroy_dispatching_module (ACE_ES_Dispatching_Base*);
virtual ACE_ES_Consumer_Module*
create_consumer_module (ACE_EventChannel*);
virtual void destroy_consumer_module (ACE_ES_Consumer_Module*);
virtual ACE_ES_Correlation_Module*
create_correlation_module (ACE_EventChannel*);
virtual void destroy_correlation_module (ACE_ES_Correlation_Module*);
virtual ACE_ES_Subscription_Module*
create_subscription_module (ACE_EventChannel*);
virtual void destroy_subscription_module (ACE_ES_Subscription_Module*);
virtual ACE_ES_Supplier_Module*
create_supplier_module (ACE_EventChannel*);
virtual void destroy_supplier_module (ACE_ES_Supplier_Module*);
virtual TAO_EC_Timer_Module*
create_timer_module (ACE_EventChannel*);
virtual void destroy_timer_module (TAO_EC_Timer_Module*);
};
#endif /* ACE_EVENT_CHANNEL_H */
|
