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
|
/**
* @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 defined (CIAO_DDS4CCM_OPENDDS) && (CIAO_DDS4CCM_OPENDDS==1)
typedef ::DDS::GuardCondition DDSGuardCondition;
typedef ::DDS::WaitSet DDSWaitSet;
typedef ::DDS::ReadCondition DDSReadCondition;
typedef ::DDS::ConditionSeq DDSConditionSeq;
#endif
namespace CIAO
{
namespace DDS4CCM
{
namespace RTI
{
/**
* @class Getter_Base_T<DDS_TYPE,CCM_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 DDS_TYPE, typename CCM_TYPE>
class Getter_Base_T :
public virtual CCM_TYPE::getter_type,
public virtual ::CORBA::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 (
typename CCM_TYPE::seq_type::_out_type instances,
::CCM_DDS::ReadInfoSeq_out infos);
virtual ::DDS::Duration_t time_out (void);
virtual void time_out (const ::DDS::Duration_t & time_out);
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_impl (::DDS::DataReader_ptr reader);
void passivate (void);
protected:
typename DDS_TYPE::data_reader *impl_;
DDSQueryCondition* condition_;
::DDS::Duration_t time_out_;
::CCM_DDS::DataNumber_t max_delivered_data_;
DDSWaitSet* ws_;
DDSReadCondition* rd_condition_;
bool wait (DDSConditionSeq& active_conditions);
typename DDS_TYPE::data_reader * impl (void);
};
template <typename DDS_TYPE, typename CCM_TYPE, bool FIXED>
class Getter_T;
/**
* @brief Implementation of the Getter port for variable sized data types.
*
*/
template <typename DDS_TYPE, typename CCM_TYPE>
class Getter_T <DDS_TYPE, CCM_TYPE, false> :
public Getter_Base_T <DDS_TYPE, CCM_TYPE>
{
public:
/**
*
* @brief get_one implementation for variable sized datatypes.
*
* Spec : get_one returns the next sample to be gotten.
*/
virtual bool get_one (
typename DDS_TYPE::value_type::_out_type an_instance,
::CCM_DDS::ReadInfo_out info);
};
/**
* @brief Implementation of the Getter port for fixed sized data types.
*
*/
template <typename DDS_TYPE, typename CCM_TYPE>
class Getter_T <DDS_TYPE, CCM_TYPE, true> :
public Getter_Base_T <DDS_TYPE, CCM_TYPE>
{
public:
/**
* @brief get_one implementation for fixed sized datatypes.
*
* Spec : get_one returns the next sample to be gotten.
*/
virtual bool get_one (
typename DDS_TYPE::value_type::_out_type an_instance,
::CCM_DDS::ReadInfo_out info);
};
}
}
}
#include "dds4ccm/impl/ndds/Getter_T.cpp"
#endif /* GETTER_T_H */
|
