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
|
/* -*- C++ -*- */
// $Id$
#ifndef EC_WRAPPER_H
#define EC_WRAPPER_H
#include "orbsvcs/RtecEventChannelAdminS.h"
#include "orbsvcs/Event/EC_Lifetime_Utils_T.h"
#include "ECMcastTests_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_EC_Event_Channel;
TAO_END_VERSIONED_NAMESPACE_DECL
/**
* @class EC_Wrapper
*
* @brief This class decorates Rtec Event Channel implementation:
* - destroy () also shutdowns the ORB
* - automatic cleanup in destructor, if necessary
*/
class ECMcastTests_Export EC_Wrapper:
public virtual POA_RtecEventChannelAdmin::EventChannel,
public TAO_EC_Deactivated_Object
{
public:
/// Create a new EC_Wrapper object.
/// (Constructor access is restricted to insure that all
/// EC_Wrapper objects are heap-allocated.)
static TAO_EC_Servant_Var<EC_Wrapper> create (void);
/// Destructor. Destroys the Event Channel implementation.
virtual ~EC_Wrapper (void);
/// Create and initialize underlying EC servant.
int init (CORBA::ORB_ptr orb,
PortableServer::POA_ptr poa);
/// RtecEventChannelAdmin::Event_Channel methods.
//@{
virtual RtecEventChannelAdmin::ConsumerAdmin_ptr
for_consumers (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual RtecEventChannelAdmin::SupplierAdmin_ptr
for_suppliers (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Destroy the Event Channel, deactivate from POA, and shut down
/// the ORB.
virtual void destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual RtecEventChannelAdmin::Observer_Handle
append_observer (RtecEventChannelAdmin::Observer_ptr observer
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((
CORBA::SystemException,
RtecEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR,
RtecEventChannelAdmin::EventChannel::CANT_APPEND_OBSERVER));
virtual void remove_observer (RtecEventChannelAdmin::Observer_Handle
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((
CORBA::SystemException,
RtecEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR,
RtecEventChannelAdmin::EventChannel::CANT_REMOVE_OBSERVER));
//@}
protected:
/// Constructor (protected). Clients can create new
/// EC_Wrapper objects using the static create() method.
EC_Wrapper (void);
private:
/// Helper - destroys Event Channel and deactivate from POA, if
/// necessary.
void destroy_ec (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Event Channel implementation.
/*
* Once Event Channel implementation is made reference-counted, this
* pointer should turn into a Servant_Var.
*/
TAO_EC_Event_Channel *ec_impl_;
/// A reference to the ORB, so we can shut it down.
CORBA::ORB_var orb_;
};
#endif /* EC_WRAPPER_H */
|
