blob: e714e6e3a5cfb6c9bdd3a491010dfff884dfce3c (
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
|
/* -*- C++ -*- */
/**
* @file Proxy.h
*
* $Id$
*
* @author Pradeep Gore <pradeep@oomworks.com>
*
*
*/
#ifndef TAO_Notify_PROXY_H
#define TAO_Notify_PROXY_H
#include /**/ "ace/pre.h"
#include "notify_serv_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "Topology_Object.h"
#include "EventTypeSeq.h"
#include "FilterAdmin.h"
#include "Admin.h"
#include "Refcountable_Guard_T.h"
class TAO_Notify_Admin;
class TAO_Notify_Peer;
/**
* @class TAO_Notify_Proxy
*
* @brief Base class proxy for all proxys in NS.
*
*/
class TAO_Notify_Serv_Export TAO_Notify_Proxy
: public TAO_NOTIFY::Topology_Parent
{
friend class TAO_Notify_Peer;
public:
typedef CosNotifyChannelAdmin::ProxyIDSeq SEQ;
typedef CosNotifyChannelAdmin::ProxyIDSeq_var SEQ_VAR;
/// Constuctor
TAO_Notify_Proxy (void);
/// Destructor
~TAO_Notify_Proxy ();
/// Activate
virtual CORBA::Object_ptr activate (PortableServer::Servant servant
ACE_ENV_ARG_DECL);
/// Activate with a given ID
virtual CORBA::Object_ptr activate (
PortableServer::Servant servant,
CORBA::Long id
ACE_ENV_ARG_DECL);
/// Deactivate
void deactivate (ACE_ENV_SINGLE_ARG_DECL);
/// Obtain the Proxy's subscribed types.
void subscribed_types (TAO_Notify_EventTypeSeq& subscribed_types
ACE_ENV_ARG_DECL);
/// Check if this event passes the admin and proxy filters.
CORBA::Boolean check_filters (
const TAO_Notify_Event* event,
TAO_Notify_FilterAdmin& parent_filter_admin,
CosNotifyChannelAdmin::InterFilterGroupOperator filter_operator
ACE_ENV_ARG_DECL
);
/// Inform this proxy that the following types are being advertised.
void types_changed (const TAO_Notify_EventTypeSeq& added,
const TAO_Notify_EventTypeSeq& removed
ACE_ENV_ARG_DECL);
/// Have updates been turned off.
CORBA::Boolean updates_off (void);
/// Destroy this object.
virtual void destroy (ACE_ENV_SINGLE_ARG_DECL) = 0;
/// Access our Peer.
virtual TAO_Notify_Peer* peer (void) = 0;
/// Implement the Obtain Types.
virtual CosNotification::EventTypeSeq* obtain_types (
CosNotifyChannelAdmin::ObtainInfoMode mode,
const TAO_Notify_EventTypeSeq& types
ACE_ENV_ARG_DECL
)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Notification of subscriptions/offers set at the admin.
virtual void admin_types_changed (const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed
ACE_ENV_ARG_DECL) = 0;
/// Override, TAO_Notify_Object::qos_changed
virtual void qos_changed (const TAO_Notify_QoSProperties& qos_properties);
// TAO_NOTIFY::Topology_Object
virtual void save_persistent (TAO_NOTIFY::Topology_Saver& saver ACE_ENV_ARG_DECL);
virtual void save_attrs(TAO_NOTIFY::NVPList& attrs);
virtual const char * get_proxy_type_name (void) const = 0;
virtual TAO_NOTIFY::Topology_Object* load_child (const ACE_CString &type, CORBA::Long id,
const TAO_NOTIFY::NVPList& attrs ACE_ENV_ARG_DECL);
protected:
/// Filter Administration
TAO_Notify_FilterAdmin filter_admin_;
/// The types that we're subscribed with the event manager.
TAO_Notify_EventTypeSeq subscribed_types_;
/// True if updates have been turned off.
CORBA::Boolean updates_off_;
};
typedef TAO_Notify_Refcountable_Guard_T<TAO_Notify_Proxy> TAO_Notify_Proxy_Guard;
#if defined (__ACE_INLINE__)
#include "Proxy.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_Notify_PROXY_H */
|
