blob: 2f021715f21c0f30a35f4bd8a26bb2f9ccf2726e (
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/orbsvcs/Event/EC_Event_Channel_Base.h"
#include "orbsvcs/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_object (
CORBA::ORB_var orb,
const FtRtecEventComm::ObjectId& supplier_admin_oid,
const FtRtecEventComm::ObjectId& consumer_admin_oid
ACE_ENV_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));
void get_state (FtRtecEventChannelAdmin::EventChannelState & s
ACE_ENV_ARG_DECL);
void set_state (const FTRT::State & stat ACE_ENV_ARG_DECL);
void set_update (const FTRT::State & s ACE_ENV_ARG_DECL)
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
);
virtual ::FtRtecEventChannelAdmin::ObjectId * connect_push_supplier (
RtecEventComm::PushSupplier_ptr push_supplier,
const RtecEventChannelAdmin::SupplierQOS & qos
ACE_ENV_ARG_DECL
);
virtual void disconnect_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL
);
virtual void disconnect_push_consumer (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL
);
virtual void suspend_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL
);
virtual void resume_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
ACE_ENV_ARG_DECL
);
virtual void push (
const FtRtecEventChannelAdmin::ObjectId & oid,
const RtecEventComm::EventSet & data
ACE_ENV_ARG_DECL
);
////////////////////////////////////////////
/// 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 FtRtecEventChannelAdmin::ObjectId& id);
TAO_FTEC_ProxyPushConsumer* find_proxy_push_consumer(const FtRtecEventChannelAdmin::ObjectId& id);
CORBA::Object_var make_iogr(CORBA::Object_ptr obj
ACE_ENV_ARG_DECL);
protected:
TAO_FTEC_Basic_Factory* factory();
private:
IOGR_Maker iogr_maker_;
};
#endif
|
