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
|
// $Id$
#include "dds4ccm/impl/ndds/DataWriter.h"
#include "dds4ccm/impl/ndds/Utils.h"
#include "dds4ccm/impl/ndds/Coherent_Changes_Guard.h"
#include "dds4ccm/impl/ndds/InstanceHandle_t.h"
#include "dds4ccm/impl/logger/Log_Macros.h"
template <typename DDS_TYPE, typename CCM_TYPE >
CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::Writer_T (void)
: InstanceHandleManager_T<DDS_TYPE, CCM_TYPE, typename CCM_TYPE::writer_type> (),
is_coherent_write_ (false)
{
DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::Writer_T");
}
template <typename DDS_TYPE, typename CCM_TYPE >
CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::~Writer_T (void)
{
DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::~Writer_T");
}
template <typename DDS_TYPE, typename CCM_TYPE >
void
CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_i (
const typename DDS_TYPE::value_type& datum,
const ::DDS::InstanceHandle_t& instance_handle,
::CCM_DDS::DataNumber_t index)
{
DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::write_i");
::DDS_InstanceHandle_t handle = ::DDS_HANDLE_NIL;
handle <<= instance_handle;
DDS_ReturnCode_t const retval = this->impl ()->write (datum, handle);
if (retval != DDS_RETCODE_OK)
{
DDS4CCM_ERROR (1, (LM_ERROR, CLINFO "CIAO::DDS4CCM::Writer_T::write_i - "
"Write unsuccessful, received error code %C\n",
translate_retcode (retval)));
throw CCM_DDS::InternalError (retval, index);
}
}
template <typename DDS_TYPE, typename CCM_TYPE >
void
CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_one (
const typename DDS_TYPE::value_type & an_instance,
const ::DDS::InstanceHandle_t & instance_handle)
{
DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::write_one");
this->write_i (an_instance, instance_handle, 0);
DDS4CCM_DEBUG (9, (LM_TRACE, CLINFO "CIAO::DDS4CCM::Writer_T::write_one - "
"Write successful\n"));
}
template <typename DDS_TYPE, typename CCM_TYPE >
void
CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_many (
const typename CCM_TYPE::seq_type& instances)
{
DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::write_many");
Coherent_Changes_Guard guard (this->impl ()->get_publisher(),
this->is_coherent_write_);
DDS4CCM_DEBUG (9, (LM_TRACE, CLINFO "CIAO::DDS4CCM::Writer_T::write_many - "
"Preparing to write to DDS\n"));
for (typename CCM_TYPE::seq_type::size_type index = 0;
index < instances.length();
index++)
{
this->write_i (instances[index], ::DDS::HANDLE_NIL, index);
}
DDS4CCM_DEBUG (9, (LM_TRACE, CLINFO "CIAO::DDS4CCM::Writer_T::write_many - "
"Write successful\n"));
}
template <typename DDS_TYPE, typename CCM_TYPE >
::CORBA::Boolean
CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::is_coherent_write (void)
{
return this->is_coherent_write_;
}
template <typename DDS_TYPE, typename CCM_TYPE >
void
CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::is_coherent_write (
::CORBA::Boolean value)
{
this->is_coherent_write_ = value;
}
|
