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
|
/**
* @author Marcel Smit <msmit@remedy.nl>
*
* $Id$
*
* Common dataReader class for the Getter, Reader,
* and, Listen port
*
*/
#ifndef DDS_DATAREADER_T_H
#define DDS_DATAREADER_T_H
#include "dds4ccm/impl/dds/DataReader.h"
#include "dds4ccm/impl/dds4ccm_conf.h"
#if (CIAO_DDS4CCM_OPENDDS==1)
typedef ::DDS::InstanceHandle_t DDS_InstanceHandle_t;
typedef ::DDS::SampleInfoSeq DDS_SampleInfoSeq;
#endif
namespace CIAO
{
namespace DDS4CCM
{
template <typename DDS_TYPE, typename CCM_TYPE>
class DataReader_T
: public virtual CCM_DDS_DataReader_i
{
public:
/// Constructor
DataReader_T (void);
/// Destructor
virtual ~DataReader_T (void);
void read_w_instance (
typename DDS_TYPE::dds_seq_type & data,
const ::DDS_InstanceHandle_t & lookup_hnd,
::DDS_SampleInfoSeq & sample_info);
void read_wo_instance (
typename DDS_TYPE::dds_seq_type & data,
::DDS_SampleInfoSeq & sample_info);
DDS_ReturnCode_t read_w_condition (
typename DDS_TYPE::dds_seq_type & data,
::DDS_SampleInfoSeq & sample_info,
::DDS_Long max_samples);
DDS_ReturnCode_t take (
typename DDS_TYPE::dds_seq_type & data,
::DDS_SampleInfoSeq & sample_info,
::DDS_Long max_samples);
DDS_InstanceHandle_t
lookup_instance (const typename DDS_TYPE::value_type& an_instance);
DDS_ReturnCode_t
return_loan (
typename DDS_TYPE::dds_seq_type & data,
::DDS_SampleInfoSeq & sample_info);
void delete_datareader (::DDS::Subscriber_ptr subscriber);
::CCM_DDS::QueryFilter *query (void);
void query (const ::CCM_DDS::QueryFilter & filter);
void
set_filter (const ::CCM_DDS::QueryFilter & filter,
DDSQueryCondition * qc);
// Getter related methods.
void remove_condition (DDSQueryCondition * qc, const char * type);
void remove_conditions (void);
DDSReadCondition *get_readcondition (void);
void create_readcondition (void);
DDSQueryCondition *get_querycondition (void);
void attach_querycondition (void);
bool
wait (DDSConditionSeq & active_conditions, DDS_Duration_t & time_out);
void set_proxy (DDSDataReader * dr);
void passivate (void);
void
create_datareader (::DDS::ContentFilteredTopic_ptr topic,
::DDS::Subscriber_ptr subscriber,
const char * library_name,
const char * profile_name);
void
create_datareader (::DDS::Topic_ptr topic,
::DDS::Subscriber_ptr subscriber,
const char * library_name,
const char * profile_name);
private:
typename DDS_TYPE::data_reader * impl_;
::DDSReadCondition * rd_condition_;
::DDSWaitSet * ws_;
// Different QueryConditions since the sample mask
// differs for all entities.
DDSQueryCondition * qc_reader_;
DDSQueryCondition * qc_getter_;
DDSQueryCondition * qc_listener_;
typename DDS_TYPE::data_reader * impl (void);
};
}
}
#include "dds4ccm/impl/dds/DataReader_T.cpp"
#endif /* DDS_DATAREADER_T_H */
|
