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
|
/* -*- C++ -*- */
/**
* @file Event_Manager.h
*
* $Id$
*
* @author Pradeep Gore <pradeep@oomworks.com>
*
*
*/
#ifndef TAO_Notify_EVENT_MANAGER_H
#define TAO_Notify_EVENT_MANAGER_H
#include /**/ "ace/pre.h"
#include "notify_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/orbsvcs/ESF/ESF_Worker.h"
#include "tao/orbconf.h"
#include "ace/CORBA_macros.h"
class TAO_Notify_ProxySupplier;
class TAO_Notify_ProxyConsumer;
class TAO_Notify_EventTypeSeq;
template <class PROXY, class ACE_LOCK>
class TAO_Notify_Event_Map_T;
typedef TAO_Notify_Event_Map_T<TAO_Notify_ProxySupplier,
TAO_SYNCH_RW_MUTEX>
TAO_Notify_Consumer_Map;
typedef TAO_Notify_Event_Map_T<TAO_Notify_ProxyConsumer,
TAO_SYNCH_RW_MUTEX>
TAO_Notify_Supplier_Map;
/**
* @class TAO_Notify_Event_Manager
*
* @brief A class that manages the Consumer and Supplier maps.
*
*/
class TAO_Notify_Export TAO_Notify_Event_Manager
{
public:
/// Constuctor
TAO_Notify_Event_Manager (void);
/// Destructor
~TAO_Notify_Event_Manager ();
/// Init
void init (ACE_ENV_SINGLE_ARG_DECL);
/// Init
void shutdown (void);
/// Connect ProxySupplier
void connect (TAO_Notify_ProxySupplier* proxy_supplier ACE_ENV_ARG_DECL);
/// Disconnect ProxySupplier
void disconnect (TAO_Notify_ProxySupplier* proxy_supplier ACE_ENV_ARG_DECL);
/// Connect ProxyConsumer
void connect (TAO_Notify_ProxyConsumer* proxy_consumer ACE_ENV_ARG_DECL);
/// Disconnect ProxyConsumer
void disconnect (TAO_Notify_ProxyConsumer* proxy_consumer ACE_ENV_ARG_DECL);
/// Map accessors.
TAO_Notify_Consumer_Map* consumer_map (void);
TAO_Notify_Supplier_Map* supplier_map (void);
/// Offer change received on <proxy_consumer>.
void offer_change (TAO_Notify_ProxyConsumer* proxy_consumer, const TAO_Notify_EventTypeSeq& added, const TAO_Notify_EventTypeSeq& removed ACE_ENV_ARG_DECL);
/// Subscription change received on <proxy_supplier>.
void subscription_change (TAO_Notify_ProxySupplier* proxy_supplier, const TAO_Notify_EventTypeSeq& added, const TAO_Notify_EventTypeSeq& removed ACE_ENV_ARG_DECL);
/// What are the types being offered.
const TAO_Notify_EventTypeSeq& offered_types (void);
/// What are the types being subscribed.
const TAO_Notify_EventTypeSeq& subscription_types (void);
protected:
/// Subscribe <proxy_supplier> to the event type sequence list <seq>.
void subscribe (TAO_Notify_ProxySupplier* proxy_supplier, const TAO_Notify_EventTypeSeq& seq, TAO_Notify_EventTypeSeq& new_seq ACE_ENV_ARG_DECL);
/// Unsubscribe <proxy_supplier> to the event type sequence list <seq>.
void un_subscribe (TAO_Notify_ProxySupplier* proxy_supplier, const TAO_Notify_EventTypeSeq& seq, TAO_Notify_EventTypeSeq& last_seq ACE_ENV_ARG_DECL);
/// Subscribe <proxy_consumer> to the event type sequence list <seq>.
void publish (TAO_Notify_ProxyConsumer* proxy_consumer, const TAO_Notify_EventTypeSeq& seq, TAO_Notify_EventTypeSeq& new_seq ACE_ENV_ARG_DECL);
/// Subscribe <proxy_consumer> to the event type sequence list <seq>.
void un_publish (TAO_Notify_ProxyConsumer* proxy_consumer, const TAO_Notify_EventTypeSeq& seq, TAO_Notify_EventTypeSeq& last_seq ACE_ENV_ARG_DECL);
/// Consumer Map
TAO_Notify_Consumer_Map* consumer_map_;
/// Supplier Map
TAO_Notify_Supplier_Map* supplier_map_;
};
/********************************************************************************/
/**
* @class TAO_Notify_ProxyConsumer_Update_Worker
*
* @brief Inform ProxyConsumer of updates.
*
*/
class TAO_Notify_Export TAO_Notify_ProxyConsumer_Update_Worker : public TAO_ESF_Worker<TAO_Notify_ProxyConsumer>
{
public:
TAO_Notify_ProxyConsumer_Update_Worker (const TAO_Notify_EventTypeSeq& added, const TAO_Notify_EventTypeSeq& removed);
protected:
///= TAO_ESF_Worker method
void work (TAO_Notify_ProxyConsumer* proxy ACE_ENV_ARG_DECL);
const TAO_Notify_EventTypeSeq& added_;
const TAO_Notify_EventTypeSeq& removed_;
};
/********************************************************************************/
/**
* @class TAO_Notify_ProxySupplier_Update_Worker
*
* @brief Inform ProxySupplier of updates.
*
*/
class TAO_Notify_Export TAO_Notify_ProxySupplier_Update_Worker : public TAO_ESF_Worker<TAO_Notify_ProxySupplier>
{
public:
TAO_Notify_ProxySupplier_Update_Worker (const TAO_Notify_EventTypeSeq& added, const TAO_Notify_EventTypeSeq& removed);
protected:
///= TAO_ESF_Worker method
void work (TAO_Notify_ProxySupplier* proxy ACE_ENV_ARG_DECL);
const TAO_Notify_EventTypeSeq& added_;
const TAO_Notify_EventTypeSeq& removed_;
};
/********************************************************************************/
#if defined (__ACE_INLINE__)
#include "Event_Manager.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_Notify_EVENT_MANAGER_H */
|
