blob: bc4a9139dfce2f1c5d99e67aa6dfbe4a4143e641 (
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
|
// -*- C++ -*-
//=============================================================================
/**
* @file FTEC_Gateway.h
*
* $Id$
*
* @author Huang-Ming Huang <hh1@cse.wustl.edu>
*/
//=============================================================================
#ifndef FTEC_GATEWAY_H
#define FTEC_GATEWAY_H
#include /**/ "ace/pre.h"
#include "orbsvcs/orbsvcs/FtRtecEventChannelAdminC.h"
#include "orbsvcs/orbsvcs/RtecEventChannelAdminS.h"
namespace TAO_FTRTEC
{
struct FTEC_Gateway_Impl;
class TAO_FtRtEvent_Export FTEC_Gateway :
public POA_RtecEventChannelAdmin::EventChannel
{
public:
FTEC_Gateway(CORBA::ORB_ptr orb,
FtRtecEventChannelAdmin::EventChannel_ptr ftec);
~FTEC_Gateway();
RtecEventChannelAdmin::EventChannel_ptr activate
(PortableServer::POA_ptr poa
ACE_ENV_ARG_DECL);
RtecEventChannelAdmin::EventChannel_ptr
_this(ACE_ENV_SINGLE_ARG_DECL);
//= The RtecEventChannelAdmin::EventChannel methods
virtual RtecEventChannelAdmin::ConsumerAdmin_ptr
for_consumers (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC((CORBA::SystemException));
virtual RtecEventChannelAdmin::SupplierAdmin_ptr
for_suppliers (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC((CORBA::SystemException));
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));
void push(RtecEventChannelAdmin::ProxyPushConsumer_ptr proxy_consumer,
const RtecEventComm::EventSet & data
ACE_ENV_ARG_DECL);
private:
struct FTEC_Gateway_Impl *impl_;
};
}
#if defined(__ACE_INLINE__)
#include "FTEC_Gateway.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif
|
