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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
/**
* @author Marcel Smit (msmit@remedy.nl)
*
* $Id$
*
* Wrapper facade for NDDS.
*/
#ifndef GETTER_T_H_
#define GETTER_T_H_
#include "dds4ccm/idl/dds_rtf2_dcpsC.h"
#include "ace/Copy_Disabled.h"
#if (CIAO_DDS4CCM_NDDS==1)
# include "dds4ccm/impl/ndds/Condition.h"
# include "dds4ccm/impl/ndds/ReadCondition.h"
# include "dds4ccm/impl/ndds/QueryCondition.h"
#endif
namespace CIAO
{
namespace DDS4CCM
{
/**
* @class Getter_Base_T<GETTER_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE>
*
* @brief Templated base class for the Getter port.
*
* Spec: Get operations are performed with the following parameters
* . SampleStateMask: NO_READ,
* . ViewStateMask: NEW or NOT_NEW,
* . InstanceStateMask: ALIVE or NOT_ALIVE,
* . Through the query (if any) of the Reader associated to the port,
* . Within the time limit specified in time_out.
*
* All methods return a boolean as result indicating whether actual data
* are provided (TRUE) or if the time-out occurred (FALSE).
*/
template <typename GETTER_TYPE, typename TYPED_DDS_READER, typename VALUE_TYPE, typename SEQ_VALUE_TYPE>
class Getter_Base_T :
public virtual GETTER_TYPE,
public virtual LocalObject,
private virtual ACE_Copy_Disabled
{
public:
/// Constructor
Getter_Base_T (void);
/// Destructor
virtual ~Getter_Base_T (void);
/**
* Spec : get_many returns all the available samples
* in the limits set by the attribute max_delivered_data.
* In case there are more available samples, the first
* max_delivered_data are returned. The default value for
* that attribute is UNLIMITED (0)
*/
virtual bool get_many (
SEQ_VALUE_TYPE& instances,
::CCM_DDS::ReadInfoSeq& infos);
/**
* @name time_out
* Accessors for time_out
*/
//@{
virtual ::DDS::Duration_t time_out (void);
virtual void time_out (const ::DDS::Duration_t & time_out);
//@}
/**
* @name max_delivered_data
* Accessors for max_delivered_data
*/
//@{
virtual ::CCM_DDS::DataNumber_t max_delivered_data (void);
virtual void max_delivered_data (
::CCM_DDS::DataNumber_t max_delivered_data);
//@}
/**
* Set the actual pointer to DDS Datareader
*/
void set_dds_reader (::DDS::DataReader_ptr reader,
::CIAO::DDS4CCM::ConditionManager * condition_manager);
::DDS::DataReader_ptr get_dds_reader (void);
protected:
typename TYPED_DDS_READER::_var_type dds_reader_;
::CIAO::DDS4CCM::ConditionManager * condition_manager_;
::DDS::Duration_t time_out_;
::CCM_DDS::DataNumber_t max_delivered_data_;
typename TYPED_DDS_READER::_ptr_type dds_reader (void);
/**
* @name get
*
* Generic helper methods which perform the actual
* DDS reading.
*/
//@{
::DDS::ReturnCode_t get (SEQ_VALUE_TYPE& data,
::DDS::SampleInfoSeq & sample_info,
const ::CORBA::Long & max_samples);
::DDS::ReturnCode_t get (
SEQ_VALUE_TYPE& data,
::DDS::SampleInfoSeq & sample_info,
const ::CORBA::Long & max_samples,
::DDS::QueryCondition_ptr qc);
::DDS::ReturnCode_t get (
SEQ_VALUE_TYPE & data,
::DDS::SampleInfoSeq & sample_info,
const ::CORBA::Long & max_samples,
::DDS::ReadCondition_ptr rd);
//@}
};
template <typename GETTER_TYPE, typename TYPED_DDS_READER, typename VALUE_TYPE, typename SEQ_VALUE_TYPE, bool FIXED>
class Getter_T;
/**
* @brief Implementation of the Getter port for variable sized data types.
*/
template <typename GETTER_TYPE, typename TYPED_DDS_READER, typename VALUE_TYPE, typename SEQ_VALUE_TYPE>
class Getter_T <GETTER_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE, false> :
public Getter_Base_T <GETTER_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE>
{
public:
/**
*
* @brief get_one implementation for variable sized datatypes.
*
* Spec : get_one returns the next sample to be gotten.
*
* @retval false When 'wait' times out or when no valid data could be read
* from DDS.
* @retval true When 'wait' is triggered.
*/
virtual bool get_one (
typename VALUE_TYPE::_out_type an_instance,
::CCM_DDS::ReadInfo_out info);
};
/**
* @brief Implementation of the Getter port for fixed sized data types.
*
*/
template <typename GETTER_TYPE, typename TYPED_DDS_READER, typename VALUE_TYPE, typename SEQ_VALUE_TYPE>
class Getter_T <GETTER_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE, true> :
public Getter_Base_T <GETTER_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE>
{
public:
/**
* @brief get_one implementation for fixed sized datatypes.
*
* Spec : get_one returns the next sample to be gotten.
*
* @retval false When 'wait' times out or when no valid data could be read
* from DDS.
* @retval true When 'wait' is triggered.
*/
virtual bool get_one (
typename VALUE_TYPE::_out_type an_instance,
::CCM_DDS::ReadInfo_out info);
};
}
}
#include "dds4ccm/impl/Getter_T.cpp"
#endif /* GETTER_T_H_ */
|
