blob: 1962d352465b4f5335e42159acbc654962657fb9 (
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
|
/* -*- C++ -*- */
/**
* @file Admin.h
*
* $Id$
*
* @author Pradeep Gore <pradeep@oomworks.com>
*
*
*/
#ifndef TAO_Notify_ADMIN_H
#define TAO_Notify_ADMIN_H
#include /**/ "ace/pre.h"
#include "orbsvcs/Notify/notify_serv_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/Notify/FilterAdmin.h"
#include "orbsvcs/Notify/EventTypeSeq.h"
#include "orbsvcs/Notify/Topology_Object.h"
#include "orbsvcs/Notify/EventChannel.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_Notify_Proxy;
template <class TYPE> class TAO_Notify_Container_T;
/**
* @class TAO_Notify_Admin
*
* @brief Base class for the ConsumerAdmin and SupplierAdmin.
*
*/
class TAO_Notify_Serv_Export TAO_Notify_Admin : public TAO_Notify::Topology_Parent
{
friend class TAO_Notify_Builder;
public:
typedef CosNotifyChannelAdmin::AdminIDSeq SEQ;
typedef CosNotifyChannelAdmin::AdminIDSeq_var SEQ_VAR;
/// Constructor
TAO_Notify_Admin ();
/// Destructor
virtual ~TAO_Notify_Admin ();
/// Init
void init (TAO_Notify::Topology_Parent * parent);
/// Insert the proxy in the <proxy_container_>.
void insert (TAO_Notify_Proxy* proxy);
/// Remove type from container_ and cleanup any EC resources.
void cleanup_proxy (TAO_Notify_Proxy *proxy,
bool is_supplier,
bool experienced_timeout);
/// Access Admin FilterAdmin.
TAO_Notify_FilterAdmin& filter_admin (void);
/// Set Filter operator
void filter_operator (
CosNotifyChannelAdmin::InterFilterGroupOperator filter_operator);
/// Access Filter operator
CosNotifyChannelAdmin::InterFilterGroupOperator filter_operator (void);
/// Obtain the Admin's subscribed types.
void subscribed_types (TAO_Notify_EventTypeSeq& subscribed_types);
TAO_Notify_EventChannel * event_channel () const;
/// Shutdown
virtual int shutdown (void);
virtual void save_persistent (TAO_Notify::Topology_Saver& saver);
virtual TAO_Notify::Topology_Object* load_child (const ACE_CString &type,
CORBA::Long id, const TAO_Notify::NVPList& attrs);
virtual void reconnect (void);
virtual void validate ();
void set_default (bool is_default);
bool is_default () const;
virtual void load_attrs(const TAO_Notify::NVPList& attrs);
protected:
void save_attrs (TAO_Notify::NVPList& attrs);
virtual const char * get_admin_type_name (void) const = 0;
typedef TAO_Notify_Container_T<TAO_Notify_Proxy> TAO_Notify_Proxy_Container;
TAO_Notify_Proxy_Container& proxy_container();
/// = Data Members
/// The EventChannel.
TAO_Notify_EventChannel::Ptr ec_;
/// The types that we've subscribed our proxy objects with the event manager.
TAO_Notify_EventTypeSeq subscribed_types_;
/// Filter Administration
TAO_Notify_FilterAdmin filter_admin_;
/// Filter operator
CosNotifyChannelAdmin::InterFilterGroupOperator filter_operator_;
bool is_default_;
private:
/// Remove type from container_
void remove (TAO_Notify_Proxy *proxy);
/// The Proxy Container.
ACE_Auto_Ptr< TAO_Notify_Proxy_Container > proxy_container_;
};
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "orbsvcs/Notify/Admin.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_Notify_ADMIN_H */
|
