-
Notifications
You must be signed in to change notification settings - Fork 465
/
ValueDispatcher.h
91 lines (70 loc) · 3.01 KB
/
ValueDispatcher.h
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
/*
* Distributed under the OpenDDS License.
* See: http://www.opendds.org/license.html
*/
#ifndef OPENDDS_DCPS_VALUE_DISPATCHER_H
#define OPENDDS_DCPS_VALUE_DISPATCHER_H
#include "TypeSupportImpl.h"
#include "ValueReader.h"
#include "ValueWriter.h"
OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
namespace OpenDDS {
namespace DCPS {
struct OpenDDS_Dcps_Export ValueDispatcher {
virtual ~ValueDispatcher() {}
virtual void* new_value() const = 0;
virtual void delete_value(void* data) const = 0;
virtual bool read(ValueReader& value_reader, void* data) const = 0;
virtual void write(ValueWriter& value_writer, const void* data) const = 0;
virtual DDS::InstanceHandle_t register_instance_helper(DDS::DataWriter* dw, const void* data) const = 0;
virtual DDS::ReturnCode_t write_helper(DDS::DataWriter* dw, const void* data, DDS::InstanceHandle_t inst) const = 0;
virtual DDS::ReturnCode_t unregister_instance_helper(DDS::DataWriter* dw, const void* data, DDS::InstanceHandle_t inst) const = 0;
virtual DDS::ReturnCode_t dispose_helper(DDS::DataWriter* dw, const void* data, DDS::InstanceHandle_t inst) const = 0;
};
template <typename T>
struct ValueDispatcher_T : public virtual ValueDispatcher {
virtual ~ValueDispatcher_T() {}
virtual void* new_value() const
{
return new T();
}
virtual void delete_value(void* data) const
{
T* tbd = static_cast<T*>(data);
delete tbd;
}
virtual bool read(ValueReader& value_reader, void* data) const
{
return vread(value_reader, *static_cast<T*>(data));
}
virtual void write(ValueWriter& value_writer, const void* data) const
{
vwrite(value_writer, *static_cast<const T*>(data));
}
typedef typename OpenDDS::DCPS::DDSTraits<T> TraitsType;
typedef typename TraitsType::DataWriterType DataWriterType;
virtual DDS::InstanceHandle_t register_instance_helper(DDS::DataWriter* dw, const void* data) const
{
DataWriterType* dw_t = dynamic_cast<DataWriterType*>(dw);
return dw_t ? dw_t->register_instance(*static_cast<const T*>(data)) : DDS::HANDLE_NIL;
}
virtual DDS::ReturnCode_t write_helper(DDS::DataWriter* dw, const void* data, DDS::InstanceHandle_t inst) const
{
DataWriterType* dw_t = dynamic_cast<DataWriterType*>(dw);
return dw_t ? dw_t->write(*static_cast<const T*>(data), inst) : DDS::RETCODE_BAD_PARAMETER;
}
virtual DDS::ReturnCode_t unregister_instance_helper(DDS::DataWriter* dw, const void* data, DDS::InstanceHandle_t inst) const
{
DataWriterType* dw_t = dynamic_cast<DataWriterType*>(dw);
return dw_t ? dw_t->unregister_instance(*static_cast<const T*>(data), inst) : DDS::RETCODE_BAD_PARAMETER;
}
virtual DDS::ReturnCode_t dispose_helper(DDS::DataWriter* dw, const void* data, DDS::InstanceHandle_t inst) const
{
DataWriterType* dw_t = dynamic_cast<DataWriterType*>(dw);
return dw_t ? dw_t->dispose(*static_cast<const T*>(data), inst) : DDS::RETCODE_BAD_PARAMETER;
}
};
} // namespace DCPS
} // namespace OpenDDS
OPENDDS_END_VERSIONED_NAMESPACE_DECL
#endif /* OPENDDS_DCPS_VALUE_DISPATCHER_H */