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
|
/**
* @author Johnny Willemsen (jwillemsen@remedy.nl)
*
* $Id$
*
* Wrapper facade for NDDS.
*/
#ifndef DATAWRITER_T_H_
#define DATAWRITER_T_H_
#include "dds4ccm/idl/ndds/ndds_dcpsC.h"
#include "dds4ccm/impl/dds4ccm_conf.h"
#include "dds4ccm/impl/ndds/DataWriter.h"
namespace CIAO
{
namespace NDDS
{
template <typename TYPED_DDS_WRITER, typename TYPED_WRITER_TYPE, typename VALUE_TYPE>
class DataWriter_T
: public virtual DDS_DataWriter_Base,
public virtual TYPED_WRITER_TYPE
{
public:
explicit DataWriter_T (::DDSDataWriter * dw,
::DDS::DomainParticipant_ptr dp,
::DDS::Publisher_ptr pub);
virtual ::DDS::ReturnCode_t set_qos (const ::DDS::DataWriterQos & qos);
virtual ::DDS::ReturnCode_t get_qos (::DDS::DataWriterQos & qos);
virtual ::DDS::ReturnCode_t set_listener (
::DDS::DataWriterListener_ptr a_listener,
::DDS::StatusMask mask);
virtual ::DDS::DataWriterListener_ptr get_listener (void);
virtual ::DDS::Topic_ptr get_topic (void);
virtual ::DDS::Publisher_ptr get_publisher (void);
virtual ::DDS::ReturnCode_t wait_for_acknowledgments (
const ::DDS::Duration_t & max_wait);
virtual ::DDS::ReturnCode_t get_liveliness_lost_status (
::DDS::LivelinessLostStatus & status);
virtual ::DDS::ReturnCode_t get_offered_deadline_missed_status (
::DDS::OfferedDeadlineMissedStatus & status);
virtual ::DDS::ReturnCode_t get_offered_incompatible_qos_status (
::DDS::OfferedIncompatibleQosStatus & status);
virtual ::DDS::ReturnCode_t get_publication_matched_status (
::DDS::PublicationMatchedStatus & status);
virtual ::DDS::ReturnCode_t assert_liveliness (void);
virtual ::DDS::ReturnCode_t get_matched_subscriptions (
::DDS::InstanceHandleSeq & subscription_handles);
virtual ::DDS::ReturnCode_t get_matched_subscription_data (
::DDS::SubscriptionBuiltinTopicData & subscription_data,
DDS_INSTANCE_HANDLE_T_IN subscription_handle);
virtual ::DDS::ReturnCode_t enable (void);
virtual ::DDS::StatusCondition_ptr get_statuscondition (void);
virtual ::DDS::StatusMask get_status_changes (void);
virtual DDS_INSTANCE_HANDLE_T_RETN get_instance_handle (void);
virtual ::DDS::InstanceHandle_t register_instance (
const VALUE_TYPE & instance_data);
virtual ::DDS::InstanceHandle_t register_instance_w_timestamp (
const VALUE_TYPE & instance_data,
const ::DDS::Time_t & source_timestamp);
virtual ::DDS::ReturnCode_t unregister_instance (
const VALUE_TYPE & instance_data,
const ::DDS::InstanceHandle_t & handle);
virtual ::DDS::ReturnCode_t unregister_instance_w_timestamp (
const VALUE_TYPE & instance_data,
const ::DDS::InstanceHandle_t & handle,
const ::DDS::Time_t & source_timestamp);
virtual ::DDS::ReturnCode_t write (
const VALUE_TYPE & instance_data,
const ::DDS::InstanceHandle_t & handle);
virtual ::DDS::ReturnCode_t write_w_timestamp (
const VALUE_TYPE & instance_data,
const ::DDS::InstanceHandle_t & handle,
const ::DDS::Time_t & source_timestamp);
virtual ::DDS::ReturnCode_t dispose (
const VALUE_TYPE & instance_data,
const ::DDS::InstanceHandle_t & instance_handle);
virtual ::DDS::ReturnCode_t dispose_w_timestamp (
const VALUE_TYPE & instance_data,
const ::DDS::InstanceHandle_t & instance_handle,
const ::DDS::Time_t & source_timestamp);
virtual ::DDS::ReturnCode_t get_key_value (
VALUE_TYPE & key_holder,
const ::DDS::InstanceHandle_t & handle);
virtual ::DDS::InstanceHandle_t lookup_instance (
const VALUE_TYPE & instance_data);
virtual ::DDSDataWriter * get_rti_entity (void);
virtual void set_rti_entity (::DDSDataWriter * dw);
private:
TYPED_DDS_WRITER * rti_entity_;
::DDS::DomainParticipant_var dp_;
::DDS::Publisher_var pub_;
TYPED_DDS_WRITER * rti_entity (void);
};
}
}
#include "dds4ccm/impl/ndds/DataWriter_T.cpp"
#endif /* DATAWRITER_T_H_ */
|
