GSDFPacketDcps_impl.h
Go to the documentation of this file.
1 #ifndef GSDFPACKETDCPS_IMPL_H_
2 #define GSDFPACKETDCPS_IMPL_H_
3 
4 #include "ccpp.h"
5 #include "ccpp_GSDFPacket.h"
6 #include "ccpp_TypeSupport_impl.h"
7 #include "ccpp_DataWriter_impl.h"
8 #include "ccpp_DataReader_impl.h"
9 #include "ccpp_DataReaderView_impl.h"
10 
11 
12 namespace opensplice_dds_comm {
13 
14  class GSDFPacketTypeSupportFactory : public ::DDS::TypeSupportFactory_impl
15  {
16  public:
17  GSDFPacketTypeSupportFactory() {}
18  virtual ~GSDFPacketTypeSupportFactory() {}
19  private:
20  ::DDS::DataWriter_ptr
21  create_datawriter (gapi_dataWriter handle);
22 
23  ::DDS::DataReader_ptr
24  create_datareader (gapi_dataReader handle);
25 
26  ::DDS::DataReaderView_ptr
27  create_view (gapi_dataReaderView handle);
28  };
29 
30  class GSDFPacketTypeSupport : public virtual GSDFPacketTypeSupportInterface,
31  public ::DDS::TypeSupport_impl
32  {
33  public:
34  virtual ::DDS::ReturnCode_t register_type(
35  ::DDS::DomainParticipant_ptr participant,
36  const char * type_name) THROW_ORB_EXCEPTIONS;
37 
38  virtual char * get_type_name() THROW_ORB_EXCEPTIONS;
39 
40  GSDFPacketTypeSupport (void);
41  virtual ~GSDFPacketTypeSupport (void);
42 
43  private:
44  GSDFPacketTypeSupport (const GSDFPacketTypeSupport &);
45  void operator= (const GSDFPacketTypeSupport &);
46 
47  static const char *metaDescriptor[];
48  static const ::DDS::ULong metaDescriptorArrLength;
49  };
50 
51  typedef GSDFPacketTypeSupportInterface_var GSDFPacketTypeSupport_var;
52  typedef GSDFPacketTypeSupportInterface_ptr GSDFPacketTypeSupport_ptr;
53 
54  class GSDFPacketDataWriter_impl : public virtual GSDFPacketDataWriter,
55  public ::DDS::DataWriter_impl
56  {
57  public:
58 
59  virtual ::DDS::InstanceHandle_t register_instance(
60  const GSDFPacket & instance_data) THROW_ORB_EXCEPTIONS;
61 
62  virtual ::DDS::InstanceHandle_t register_instance_w_timestamp(
63  const GSDFPacket & instance_data,
64  const ::DDS::Time_t & source_timestamp) THROW_ORB_EXCEPTIONS;
65 
66  virtual ::DDS::ReturnCode_t unregister_instance(
67  const GSDFPacket & instance_data,
68  ::DDS::InstanceHandle_t handle) THROW_ORB_EXCEPTIONS;
69 
70  virtual ::DDS::ReturnCode_t unregister_instance_w_timestamp(
71  const GSDFPacket & instance_data,
72  ::DDS::InstanceHandle_t handle,
73  const ::DDS::Time_t & source_timestamp) THROW_ORB_EXCEPTIONS;
74 
75  virtual ::DDS::ReturnCode_t write(
76  const GSDFPacket & instance_data,
77  ::DDS::InstanceHandle_t handle) THROW_ORB_EXCEPTIONS;
78 
79  virtual ::DDS::ReturnCode_t write_w_timestamp(
80  const GSDFPacket & instance_data,
81  ::DDS::InstanceHandle_t handle,
82  const ::DDS::Time_t & source_timestamp) THROW_ORB_EXCEPTIONS;
83 
84  virtual ::DDS::ReturnCode_t dispose(
85  const GSDFPacket & instance_data,
86  ::DDS::InstanceHandle_t handle) THROW_ORB_EXCEPTIONS;
87 
88  virtual ::DDS::ReturnCode_t dispose_w_timestamp(
89  const GSDFPacket & instance_data,
90  ::DDS::InstanceHandle_t handle,
91  const ::DDS::Time_t & source_timestamp) THROW_ORB_EXCEPTIONS;
92 
93  virtual ::DDS::ReturnCode_t writedispose(
94  const GSDFPacket & instance_data,
95  ::DDS::InstanceHandle_t handle) THROW_ORB_EXCEPTIONS;
96 
97  virtual ::DDS::ReturnCode_t writedispose_w_timestamp(
98  const GSDFPacket & instance_data,
99  ::DDS::InstanceHandle_t handle,
100  const ::DDS::Time_t & source_timestamp) THROW_ORB_EXCEPTIONS;
101 
102  virtual ::DDS::ReturnCode_t get_key_value(
103  GSDFPacket & key_holder,
104  ::DDS::InstanceHandle_t handle) THROW_ORB_EXCEPTIONS;
105 
106  virtual ::DDS::InstanceHandle_t lookup_instance(
107  const GSDFPacket & instance_data) THROW_ORB_EXCEPTIONS;
108 
109 
110  GSDFPacketDataWriter_impl (
111  gapi_dataWriter handle
112  );
113 
114  virtual ~GSDFPacketDataWriter_impl (void);
115 
116  private:
117  GSDFPacketDataWriter_impl(const GSDFPacketDataWriter_impl &);
118  void operator= (const GSDFPacketDataWriter &);
119  };
120 
121  class GSDFPacketDataReader_impl : public virtual GSDFPacketDataReader,
122  public ::DDS::DataReader_impl
123  {
124  friend class GSDFPacketDataReaderView_impl;
125  public:
126  virtual ::DDS::ReturnCode_t read(
127  GSDFPacketSeq & received_data,
128  ::DDS::SampleInfoSeq & info_seq,
129  ::DDS::Long max_samples,
130  ::DDS::SampleStateMask sample_states,
131  ::DDS::ViewStateMask view_states,
132  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
133 
134  virtual ::DDS::ReturnCode_t take(
135  GSDFPacketSeq & received_data,
136  ::DDS::SampleInfoSeq & info_seq,
137  ::DDS::Long max_samples,
138  ::DDS::SampleStateMask sample_states,
139  ::DDS::ViewStateMask view_states,
140  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
141 
142  virtual ::DDS::ReturnCode_t read_w_condition(
143  GSDFPacketSeq & received_data,
144  ::DDS::SampleInfoSeq & info_seq,
145  ::DDS::Long max_samples,
146  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
147 
148  virtual ::DDS::ReturnCode_t take_w_condition(
149  GSDFPacketSeq & received_data,
150  ::DDS::SampleInfoSeq & info_seq,
151  ::DDS::Long max_samples,
152  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
153 
154  virtual ::DDS::ReturnCode_t read_next_sample(
155  GSDFPacket & received_data,
156  ::DDS::SampleInfo & sample_info) THROW_ORB_EXCEPTIONS;
157 
158  virtual ::DDS::ReturnCode_t take_next_sample(
159  GSDFPacket & received_data,
160  ::DDS::SampleInfo & sample_info) THROW_ORB_EXCEPTIONS;
161 
162  virtual ::DDS::ReturnCode_t read_instance(
163  GSDFPacketSeq & received_data,
164  ::DDS::SampleInfoSeq & info_seq,
165  ::DDS::Long max_samples,
166  ::DDS::InstanceHandle_t a_handle,
167  ::DDS::SampleStateMask sample_states,
168  ::DDS::ViewStateMask view_states,
169  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
170 
171  virtual ::DDS::ReturnCode_t take_instance(
172  GSDFPacketSeq & received_data,
173  ::DDS::SampleInfoSeq & info_seq,
174  ::DDS::Long max_samples,
175  ::DDS::InstanceHandle_t a_handle,
176  ::DDS::SampleStateMask sample_states,
177  ::DDS::ViewStateMask view_states,
178  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
179 
180  virtual ::DDS::ReturnCode_t read_next_instance(
181  GSDFPacketSeq & received_data,
182  ::DDS::SampleInfoSeq & info_seq,
183  ::DDS::Long max_samples,
184  ::DDS::InstanceHandle_t a_handle,
185  ::DDS::SampleStateMask sample_states,
186  ::DDS::ViewStateMask view_states,
187  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
188 
189  virtual ::DDS::ReturnCode_t take_next_instance(
190  GSDFPacketSeq & received_data,
191  ::DDS::SampleInfoSeq & info_seq,
192  ::DDS::Long max_samples,
193  ::DDS::InstanceHandle_t a_handle,
194  ::DDS::SampleStateMask sample_states,
195  ::DDS::ViewStateMask view_states,
196  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
197 
198  virtual ::DDS::ReturnCode_t read_next_instance_w_condition(
199  GSDFPacketSeq & received_data,
200  ::DDS::SampleInfoSeq & info_seq,
201  ::DDS::Long max_samples,
202  ::DDS::InstanceHandle_t a_handle,
203  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
204 
205  virtual ::DDS::ReturnCode_t take_next_instance_w_condition(
206  GSDFPacketSeq & received_data,
207  ::DDS::SampleInfoSeq & info_seq,
208  ::DDS::Long max_samples,
209  ::DDS::InstanceHandle_t a_handle,
210  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
211 
212  virtual ::DDS::ReturnCode_t return_loan(
213  GSDFPacketSeq & received_data,
214  ::DDS::SampleInfoSeq & info_seq) THROW_ORB_EXCEPTIONS;
215 
216  virtual ::DDS::ReturnCode_t get_key_value(
217  GSDFPacket & key_holder,
218  ::DDS::InstanceHandle_t handle) THROW_ORB_EXCEPTIONS;
219 
220  virtual ::DDS::InstanceHandle_t lookup_instance(
221  const GSDFPacket & instance) THROW_ORB_EXCEPTIONS;
222 
223  GSDFPacketDataReader_impl (
224  gapi_dataReader handle
225  );
226 
227  virtual ~GSDFPacketDataReader_impl(void);
228 
229  private:
230  GSDFPacketDataReader_impl(const GSDFPacketDataReader &);
231  void operator= (const GSDFPacketDataReader &);
232 
233  static ::DDS::ReturnCode_t check_preconditions(
234  GSDFPacketSeq & received_data,
235  ::DDS::SampleInfoSeq & info_seq,
236  ::DDS::Long max_samples
237  );
238  };
239 
240  class GSDFPacketDataReaderView_impl : public virtual GSDFPacketDataReaderView,
241  public ::DDS::DataReaderView_impl
242  {
243  public:
244  virtual ::DDS::ReturnCode_t read(
245  GSDFPacketSeq & received_data,
246  ::DDS::SampleInfoSeq & info_seq,
247  ::DDS::Long max_samples,
248  ::DDS::SampleStateMask sample_states,
249  ::DDS::ViewStateMask view_states,
250  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
251 
252  virtual ::DDS::ReturnCode_t take(
253  GSDFPacketSeq & received_data,
254  ::DDS::SampleInfoSeq & info_seq,
255  ::DDS::Long max_samples,
256  ::DDS::SampleStateMask sample_states,
257  ::DDS::ViewStateMask view_states,
258  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
259 
260  virtual ::DDS::ReturnCode_t read_w_condition(
261  GSDFPacketSeq & received_data,
262  ::DDS::SampleInfoSeq & info_seq,
263  ::DDS::Long max_samples,
264  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
265 
266  virtual ::DDS::ReturnCode_t take_w_condition(
267  GSDFPacketSeq & received_data,
268  ::DDS::SampleInfoSeq & info_seq,
269  ::DDS::Long max_samples,
270  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
271 
272  virtual ::DDS::ReturnCode_t read_next_sample(
273  GSDFPacket & received_data,
274  ::DDS::SampleInfo & sample_info) THROW_ORB_EXCEPTIONS;
275 
276  virtual ::DDS::ReturnCode_t take_next_sample(
277  GSDFPacket & received_data,
278  ::DDS::SampleInfo & sample_info) THROW_ORB_EXCEPTIONS;
279 
280  virtual ::DDS::ReturnCode_t read_instance(
281  GSDFPacketSeq & received_data,
282  ::DDS::SampleInfoSeq & info_seq,
283  ::DDS::Long max_samples,
284  ::DDS::InstanceHandle_t a_handle,
285  ::DDS::SampleStateMask sample_states,
286  ::DDS::ViewStateMask view_states,
287  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
288 
289  virtual ::DDS::ReturnCode_t take_instance(
290  GSDFPacketSeq & received_data,
291  ::DDS::SampleInfoSeq & info_seq,
292  ::DDS::Long max_samples,
293  ::DDS::InstanceHandle_t a_handle,
294  ::DDS::SampleStateMask sample_states,
295  ::DDS::ViewStateMask view_states,
296  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
297 
298  virtual ::DDS::ReturnCode_t read_next_instance(
299  GSDFPacketSeq & received_data,
300  ::DDS::SampleInfoSeq & info_seq,
301  ::DDS::Long max_samples,
302  ::DDS::InstanceHandle_t a_handle,
303  ::DDS::SampleStateMask sample_states,
304  ::DDS::ViewStateMask view_states,
305  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
306 
307  virtual ::DDS::ReturnCode_t take_next_instance(
308  GSDFPacketSeq & received_data,
309  ::DDS::SampleInfoSeq & info_seq,
310  ::DDS::Long max_samples,
311  ::DDS::InstanceHandle_t a_handle,
312  ::DDS::SampleStateMask sample_states,
313  ::DDS::ViewStateMask view_states,
314  ::DDS::InstanceStateMask instance_states) THROW_ORB_EXCEPTIONS;
315 
316  virtual ::DDS::ReturnCode_t read_next_instance_w_condition(
317  GSDFPacketSeq & received_data,
318  ::DDS::SampleInfoSeq & info_seq,
319  ::DDS::Long max_samples,
320  ::DDS::InstanceHandle_t a_handle,
321  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
322 
323  virtual ::DDS::ReturnCode_t take_next_instance_w_condition(
324  GSDFPacketSeq & received_data,
325  ::DDS::SampleInfoSeq & info_seq,
326  ::DDS::Long max_samples,
327  ::DDS::InstanceHandle_t a_handle,
328  ::DDS::ReadCondition_ptr a_condition) THROW_ORB_EXCEPTIONS;
329 
330  virtual ::DDS::ReturnCode_t return_loan(
331  GSDFPacketSeq & received_data,
332  ::DDS::SampleInfoSeq & info_seq) THROW_ORB_EXCEPTIONS;
333 
334  virtual ::DDS::ReturnCode_t get_key_value(
335  GSDFPacket & key_holder,
336  ::DDS::InstanceHandle_t handle) THROW_ORB_EXCEPTIONS;
337 
338  virtual ::DDS::InstanceHandle_t lookup_instance(
339  const GSDFPacket & instance) THROW_ORB_EXCEPTIONS;
340 
341  GSDFPacketDataReaderView_impl (
342  gapi_dataReader handle
343  );
344 
345  virtual ~GSDFPacketDataReaderView_impl(void);
346 
347  private:
348  GSDFPacketDataReaderView_impl(const GSDFPacketDataReaderView &);
349  void operator= (const GSDFPacketDataReaderView &);
350  };
351 
352 }
353 
354 #endif
opensplice_dds_comm::GSDFPacketDataReader
Definition: GSDFPacketDcps.h:118
opensplice_dds_comm::GSDFPacket
Definition: GSDFPacket.h:22
opensplice_dds_comm
Definition: GSDFPacket.h:18
opensplice_dds_comm::GSDFPacketTypeSupport_ptr
GSDFPacketTypeSupportInterface_ptr GSDFPacketTypeSupport_ptr
Definition: GSDFPacketDcps_impl.h:52
opensplice_dds_comm::GSDFPacketDataReaderView
Definition: GSDFPacketDcps.h:159
opensplice_dds_comm::GSDFPacketDataReaderView_impl
Definition: GSDFPacketDcps_impl.h:240
opensplice_dds_comm::GSDFPacketDataWriter_impl
Definition: GSDFPacketDcps_impl.h:54
opensplice_dds_comm::GSDFPacketTypeSupportFactory::~GSDFPacketTypeSupportFactory
virtual ~GSDFPacketTypeSupportFactory()
Definition: GSDFPacketDcps_impl.h:18
opensplice_dds_comm::GSDFPacketTypeSupport::metaDescriptorArrLength
static const ::DDS::ULong metaDescriptorArrLength
Definition: GSDFPacketDcps_impl.h:48
opensplice_dds_comm::GSDFPacketTypeSupportFactory::GSDFPacketTypeSupportFactory
GSDFPacketTypeSupportFactory()
Definition: GSDFPacketDcps_impl.h:17
opensplice_dds_comm::GSDFPacketTypeSupportFactory
Definition: GSDFPacketDcps_impl.h:14
opensplice_dds_comm::GSDFPacketTypeSupportInterface
Definition: GSDFPacketDcps.h:54
ccpp_GSDFPacket.h
opensplice_dds_comm::GSDFPacketTypeSupport
Definition: GSDFPacketDcps_impl.h:30
opensplice_dds_comm::GSDFPacketDataWriter
Definition: GSDFPacketDcps.h:80
opensplice_dds_comm::GSDFPacketTypeSupportInterface_var
DDS_DCPSInterface_var< GSDFPacketTypeSupportInterface > GSDFPacketTypeSupportInterface_var
Definition: GSDFPacketDcps.h:26
opensplice_dds_comm::GSDFPacketDataReader_impl
Definition: GSDFPacketDcps_impl.h:121
opensplice_dds_comm::GSDFPacketTypeSupportFactory::create_datawriter
::DDS::DataWriter_ptr create_datawriter(gapi_dataWriter handle)
Definition: GSDFPacketDcps_impl.cpp:23
opensplice_dds_comm::GSDFPacketTypeSupportFactory::create_datareader
::DDS::DataReader_ptr create_datareader(gapi_dataReader handle)
Definition: GSDFPacketDcps_impl.cpp:29
opensplice_dds_comm::GSDFPacketSeq
DDS_DCPSUVLSeq< GSDFPacket, struct GSDFPacketSeq_uniq_ > GSDFPacketSeq
Definition: GSDFPacketDcps.h:51
opensplice_dds_comm::GSDFPacketTypeSupportFactory::create_view
::DDS::DataReaderView_ptr create_view(gapi_dataReaderView handle)
Definition: GSDFPacketDcps_impl.cpp:36
opensplice_dds_comm::GSDFPacketTypeSupport_var
GSDFPacketTypeSupportInterface_var GSDFPacketTypeSupport_var
Definition: GSDFPacketDcps_impl.h:51

opensplice_dds_comm
Author(s):
autogenerated on Thu Jun 1 2017 02:43:49