blob: 6943c2783da8c3bd21df9cbc92a90302f10a561f (
plain)
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
|
/**
* @author William R. Otte <wotte@dre.vanderbilt.edu>
* @author Johnny Willemsen <jwillemsen@remedy.nl>
*
* $Id$
*
* Wrapper facade for NDDS.
*/
#ifndef DDS4CCM_PUBLISHER_H
#define DDS4CCM_PUBLISHER_H
#include "tao/LocalObject.h"
#include "dds4ccm/idl/dds_rtf2_dcpsEC.h"
#include "dds4ccm/idl/dds_rtf2_dcpsC.h"
#include "dds4ccm/impl/dds/dds4ccm_ndds_impl_export.h"
#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
# include "ndds/ndds_cpp.h"
#endif
#if defined (CIAO_DDS4CCM_OPENDDS) && (CIAO_DDS4CCM_OPENDDS==1)
typedef ::DDS::Publisher DDSPublisher;
#endif
#include "tao/LocalObject.h"
namespace CIAO
{
namespace DDS4CCM
{
class DDS4CCM_NDDS_IMPL_Export CCM_DDS_Publisher_i :
public virtual ::DDS::CCM_Publisher,
public virtual ::CORBA::LocalObject
{
public:
/// Constructor
CCM_DDS_Publisher_i (DDSPublisher * dw);
/// Destructor
virtual ~CCM_DDS_Publisher_i (void);
virtual
::DDS::DataWriter_ptr create_datawriter (::DDS::Topic_ptr a_topic,
const ::DDS::DataWriterQos & qos,
::DDS::DataWriterListener_ptr a_listener,
::DDS::StatusMask mask);
virtual
::DDS::DataWriter_ptr create_datawriter_with_profile (::DDS::Topic_ptr a_topic,
const char* library_name,
const char *profile_name,
::DDS::DataWriterListener_ptr a_listener,
::DDS::StatusMask mask);
virtual
::DDS::ReturnCode_t delete_datawriter (::DDS::DataWriter_ptr a_datawriter);
virtual
::DDS::DataWriter_ptr lookup_datawriter (const char * impl_name);
virtual
::DDS::ReturnCode_t delete_contained_entities (void);
virtual
::DDS::ReturnCode_t set_qos (const ::DDS::PublisherQos & qos);
virtual
::DDS::ReturnCode_t get_qos (::DDS::PublisherQos & qos);
virtual
::DDS::ReturnCode_t set_listener (::DDS::PublisherListener_ptr a_listener,
::DDS::StatusMask mask);
virtual
::DDS::PublisherListener_ptr get_listener (void);
virtual
::DDS::ReturnCode_t suspend_publications (void);
virtual
::DDS::ReturnCode_t resume_publications (void);
virtual
::DDS::ReturnCode_t begin_coherent_changes (void);
virtual
::DDS::ReturnCode_t end_coherent_changes (void);
virtual
::DDS::ReturnCode_t wait_for_acknowledgments (const ::DDS::Duration_t & max_wait);
virtual
::DDS::DomainParticipant_ptr get_participant (void);
virtual
::DDS::ReturnCode_t set_default_datawriter_qos (const ::DDS::DataWriterQos & qos);
virtual
::DDS::ReturnCode_t get_default_datawriter_qos (::DDS::DataWriterQos & qos);
virtual
::DDS::ReturnCode_t copy_from_topic_qos (::DDS::DataWriterQos & a_dataimpl_qos,
const ::DDS::TopicQos & a_impl_qos);
virtual
::DDS::ReturnCode_t enable (void);
virtual
::DDS::StatusCondition_ptr get_statuscondition (void);
virtual
::DDS::StatusMask get_status_changes (void);
virtual
::DDS::InstanceHandle_t get_instance_handle (void);
DDSPublisher * get_impl (void);
void set_impl (DDSPublisher *p);
private:
DDSPublisher *impl_;
DDSPublisher *impl (void);
};
}
}
#endif
|
