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
|
/* -*- 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 "ace/Auto_Ptr.h"
#include "orbsvcs/Notify/Refcountable.h"
#include "orbsvcs/Notify/notify_serv_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/orbconf.h"
#include "ace/CORBA_macros.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
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;
namespace CORBA
{
class Environment;
}
/**
* @class TAO_Notify_Event_Manager
*
* @brief A class that manages the Consumer and Supplier maps.
*
*/
class TAO_Notify_Serv_Export TAO_Notify_Event_Manager : public TAO_Notify_Refcountable
{
public:
typedef TAO_Notify_Refcountable_Guard_T< TAO_Notify_Event_Manager > Ptr;
/// Constuctor
TAO_Notify_Event_Manager (void);
/// Destructor
virtual ~TAO_Notify_Event_Manager ();
void release();
/// 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) const;
/// What are the types being subscribed.
const TAO_Notify_EventTypeSeq& subscription_types (void) const;
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);
private:
// Disallow copying and assignment; we don't need them
// and if we let the compiler generate them it needs the
// full declaration of the template arguments for ACE_Auto_Ptr<>
// below.
TAO_Notify_Event_Manager (TAO_Notify_Event_Manager&);
TAO_Notify_Event_Manager& operator= (TAO_Notify_Event_Manager&);
/// Consumer Map
ACE_Auto_Ptr< TAO_Notify_Consumer_Map > consumer_map_;
/// Supplier Map
ACE_Auto_Ptr< TAO_Notify_Supplier_Map > supplier_map_;
};
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif /* TAO_Notify_EVENT_MANAGER_H */
|
