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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Flows_T.h
*
* $Id$
*
* @author Nagarajan Surendran <naga@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_AV_FLOWS_T_H
#define TAO_AV_FLOWS_T_H
#include "ace/pre.h"
#include "AVStreams_i.h"
/**
* @class TAO_FDev
* @brief Implementation of the AV/Streams Flow Device.
* A FlowConnection is used to bind FDevs for flows,
* much like how a StreamCtrl is used to bind MMDevices for streams.
*/
template <class T_Producer, class T_Consumer>
class TAO_AV_Export TAO_FDev :
public virtual POA_AVStreams::FDev,
public virtual TAO_PropertySet,
public virtual PortableServer::RefCountServantBase
{
public:
/// default constructor
TAO_FDev (void);
/// constructor taking a flowname.
TAO_FDev (const char *flowname);
/// Destructor..
~TAO_FDev (void);
/// set/get the flowname.
/// create a flow producer object.
const char *flowname (void);
void flowname (const char *flowname);
AVStreams::FlowProducer_ptr create_producer (AVStreams::FlowConnection_ptr the_requester,
AVStreams::QoS & the_qos,
CORBA::Boolean_out met_qos,
char *& named_fdev,
CORBA::Environment &env = CORBA::Environment::default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException,
AVStreams::streamOpFailed,
AVStreams::streamOpDenied,
AVStreams::notSupported,
AVStreams::QoSRequestFailed));
/// bridge method for the application to override the producer object
/// creation. Default implementation creates a TAO_FlowProducer.
virtual AVStreams::FlowProducer_ptr make_producer (AVStreams::FlowConnection_ptr the_requester,
AVStreams::QoS & the_qos,
CORBA::Boolean_out met_qos,
char *& named_fdev,
CORBA::Environment &env = CORBA::Environment::default_environment ());
/// create a flow consumer object.
virtual AVStreams::FlowConsumer_ptr create_consumer (AVStreams::FlowConnection_ptr the_requester,
AVStreams::QoS & the_qos,
CORBA::Boolean_out met_qos,
char *& named_fdev,
CORBA::Environment &env = CORBA::Environment::default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException,
AVStreams::streamOpFailed,
AVStreams::streamOpDenied,
AVStreams::notSupported,
AVStreams::QoSRequestFailed));
/// bridge method for the application to override the consumer object
/// creation. Default implementation creates a TAO_FlowConsumer.
virtual AVStreams::FlowConsumer_ptr make_consumer (AVStreams::FlowConnection_ptr the_requester,
AVStreams::QoS & the_qos,
CORBA::Boolean_out met_qos,
char *& named_fdev,
CORBA::Environment &env = CORBA::Environment::default_environment ());
/// bind this FDev with another FDev.
virtual AVStreams::FlowConnection_ptr bind (AVStreams::FDev_ptr peer_device,
AVStreams::QoS & the_qos,
CORBA::Boolean_out is_met,
CORBA::Environment &env = CORBA::Environment::default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException,
AVStreams::streamOpFailed,
AVStreams::QoSRequestFailed));
/// multicast bind is not implemented yet.
virtual AVStreams::FlowConnection_ptr bind_mcast (AVStreams::FDev_ptr first_peer,
AVStreams::QoS & the_qos,
CORBA::Boolean_out is_met,
CORBA::Environment &env = CORBA::Environment::default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException,
AVStreams::streamOpFailed,
AVStreams::QoSRequestFailed));
/// destroys this FDev.
virtual void destroy (AVStreams::FlowEndPoint_ptr the_ep,
const char * fdev_name,
CORBA::Environment &env =
CORBA::Environment::default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException,
AVStreams::notSupported));
protected:
ACE_DLList <TAO_FlowProducer> producer_list_;
typedef ACE_DLList_Iterator <TAO_FlowProducer> PRODUCER_LIST_ITERATOR;
ACE_DLList <TAO_FlowConsumer> consumer_list_;
typedef ACE_DLList_Iterator <TAO_FlowConsumer> CONSUMER_LIST_ITERATOR;
CORBA::String_var flowname_;
};
#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
#include "Flows_T.cpp"
#endif /*ACE_TEMPLATES_REQUIRE_SOURCE */
#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
#pragma implementation ("Flows_T.cpp")
#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */
#include "ace/post.h"
#endif /* TAO_AV_FLOWS_T_H */
|
