blob: 7f23a208cad30fafd66f7b62731b86fc6a1fea30 (
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 FTEC_Event_Channel_Impl.h
*
* $Id$
*
* @author Huang-Ming Huang <hh1@cse.wustl.edu>
*/
//=============================================================================
#ifndef TAO_FTEC_EVENT_CHANNEL_H
#define TAO_FTEC_EVENT_CHANNEL_H
#include "ace/Synch_T.h"
#include "orbsvcs/Event/EC_Event_Channel_Base.h"
#include "orbsvcs/FtRtecEventChannelAdminC.h"
#include "FTEC_Factory.h"
#include "FTEC_Group_Manager.h"
#include "IOGR_Maker.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class TAO_FTEC_ProxyPushSupplier;
class TAO_FTEC_ProxyPushConsumer;
class TAO_FTEC_SupplierAdmin;
class TAO_FTEC_ConsumerAdmin;
class FT_ProxyAdmin_Base;
class TAO_FTEC_Event_Channel_Impl : public TAO_EC_Event_Channel_Base
, public TAO_FTEC_Group_Manager
{
public:
TAO_FTEC_Event_Channel_Impl(const TAO_EC_Event_Channel_Attributes& attributes);
~TAO_FTEC_Event_Channel_Impl();
/// Start the internal threads (if any), etc.
/// After this call the EC can be used.
virtual void activate (
CORBA::ORB_var orb,
const PortableServer::ObjectId& supplier_admin_oid,
const PortableServer::ObjectId& consumer_admin_oid
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
// = 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));
void get_state (FtRtecEventChannelAdmin::EventChannelState & s
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
void set_state (const FTRT::State & stat ACE_ENV_ARG_DECL_WITH_DEFAULTS);
void set_update (const FTRT::State & s ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException, FTRT::InvalidUpdate));
/// EventChannelFacade Interface
virtual ::FtRtecEventChannelAdmin::ObjectId * connect_push_consumer (
RtecEventComm::PushConsumer_ptr push_consumer,
const RtecEventChannelAdmin::ConsumerQOS & qos
ACE_ENV_ARG_DECL_WITH_DEFAULTS
);
virtual ::FtRtecEventChannelAdmin::ObjectId * connect_push_supplier (
RtecEventComm::PushSupplier_ptr push_supplier,
const RtecEventChannelAdmin::SupplierQOS & qos
ACE_ENV_ARG_DECL_WITH_DEFAULTS
);
virtual void disconnect_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL_WITH_DEFAULTS
);
virtual void disconnect_push_consumer (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL_WITH_DEFAULTS
);
virtual void suspend_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL_WITH_DEFAULTS
);
virtual void resume_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL_WITH_DEFAULTS
);
virtual void push (
const FtRtecEventChannelAdmin::ObjectId & oid,
const RtecEventComm::EventSet & data
ACE_ENV_ARG_DECL_WITH_DEFAULTS
);
////////////////////////////////////////////
/// Access the consumer admin implementation, useful for controlling
/// the activation...
TAO_FTEC_ConsumerAdmin* consumer_admin (void) const;
/// Access the supplier admin implementation, useful for controlling
/// the activation...
TAO_FTEC_SupplierAdmin* supplier_admin (void) const;
TAO_FTEC_ProxyPushSupplier* find_proxy_push_supplier(const PortableServer::ObjectId& id);
TAO_FTEC_ProxyPushConsumer* find_proxy_push_consumer(const PortableServer::ObjectId& id);
CORBA::Object_var make_iogr(CORBA::Object_ptr obj
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
protected:
TAO_FTEC_Basic_Factory* factory();
private:
IOGR_Maker iogr_maker_;
};
#endif
|
