blob: 36c72ef69f68f164c5851f7e6b7e46b25036e8aa (
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
|
// -*- 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 "orbsvcs/FtRtEvent/EventChannel/FTEC_Factory.h"
#include "orbsvcs/FtRtEvent/EventChannel/FTEC_Group_Manager.h"
#include "orbsvcs/FtRtEvent/EventChannel/IOGR_Maker.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
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);
// = The RtecEventChannelAdmin::EventChannel methods...
virtual RtecEventChannelAdmin::ConsumerAdmin_ptr
for_consumers (void);
virtual RtecEventChannelAdmin::SupplierAdmin_ptr
for_suppliers (void);
void get_state (FtRtecEventChannelAdmin::EventChannelState & s);
void set_state (const FTRT::State & stat);
void set_update (const FTRT::State & s);
/// EventChannelFacade Interface
virtual ::FtRtecEventChannelAdmin::ObjectId * connect_push_consumer (
RtecEventComm::PushConsumer_ptr push_consumer,
const RtecEventChannelAdmin::ConsumerQOS & qos
);
virtual ::FtRtecEventChannelAdmin::ObjectId * connect_push_supplier (
RtecEventComm::PushSupplier_ptr push_supplier,
const RtecEventChannelAdmin::SupplierQOS & qos
);
virtual void disconnect_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
);
virtual void disconnect_push_consumer (
const FtRtecEventChannelAdmin::ObjectId & oid
);
virtual void suspend_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
);
virtual void resume_push_supplier (
const FtRtecEventChannelAdmin::ObjectId & oid
);
virtual void push (
const FtRtecEventChannelAdmin::ObjectId & oid,
const RtecEventComm::EventSet & data
);
////////////////////////////////////////////
/// 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);
protected:
TAO_FTEC_Basic_Factory* factory();
private:
IOGR_Maker iogr_maker_;
};
TAO_END_VERSIONED_NAMESPACE_DECL
#endif
|
