summaryrefslogtreecommitdiff
path: root/modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp')
-rw-r--r--modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp79
1 files changed, 79 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp b/modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp
new file mode 100644
index 00000000000..7c66b260ab7
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp
@@ -0,0 +1,79 @@
+// $Id$
+
+#include "DataWriterListener.h"
+#include "DataWriter.h"
+#include "PublicationMatchedStatus.h"
+#include "LivelinessLostStatus.h"
+#include "OfferedIncompatibleQosStatus.h"
+#include "OfferedDeadlineMissedStatus.h"
+
+namespace CIAO
+{
+ namespace DDS4CCM
+ {
+ namespace RTI
+ {
+ // Implementation skeleton constructor
+ RTI_DataWriterListener_i::RTI_DataWriterListener_i (::DDS::DataWriterListener_ptr s)
+ : impl_ (::DDS::DataWriterListener::_duplicate (s))
+ {
+ }
+
+ // Implementation skeleton destructor
+ RTI_DataWriterListener_i::~RTI_DataWriterListener_i (void)
+ {
+ }
+
+ void
+ RTI_DataWriterListener_i::on_offered_deadline_missed (
+ ::DDSDataWriter *the_writer,
+ const ::DDS_OfferedDeadlineMissedStatus & status)
+ {
+ ::DDS::OfferedDeadlineMissedStatus ddsstatus;
+ ddsstatus <<= status;
+ ::DDS::DataWriter_var dds_writer = new RTI_DataWriter_i (the_writer);
+ this->impl_->on_offered_deadline_missed (dds_writer.in (), ddsstatus);
+ }
+
+ void
+ RTI_DataWriterListener_i::on_offered_incompatible_qos (
+ ::DDSDataWriter *the_writer,
+ const ::DDS_OfferedIncompatibleQosStatus & status)
+ {
+ ::DDS::OfferedIncompatibleQosStatus ddsstatus;
+ ddsstatus <<= status;
+ ::DDS::DataWriter_var dds_writer = new RTI_DataWriter_i (the_writer);
+ this->impl_->on_offered_incompatible_qos (dds_writer.in (), ddsstatus);
+ }
+
+ void
+ RTI_DataWriterListener_i::on_liveliness_lost (
+ ::DDSDataWriter *the_writer,
+ const ::DDS_LivelinessLostStatus & status)
+ {
+ ::DDS::LivelinessLostStatus ddsstatus;
+ ddsstatus <<= status;
+ ::DDS::DataWriter_var dds_writer = new RTI_DataWriter_i (the_writer);
+ this->impl_->on_liveliness_lost (dds_writer.in (), ddsstatus);
+ }
+
+ void
+ RTI_DataWriterListener_i::on_publication_matched (
+ ::DDSDataWriter *the_writer,
+ const ::DDS_PublicationMatchedStatus & status)
+ {
+ ::DDS::PublicationMatchedStatus ddsstatus;
+ ddsstatus <<= status;
+ ::DDS::DataWriter_var dds_writer = new RTI_DataWriter_i (the_writer);
+ this->impl_->on_publication_matched (dds_writer.in (), ddsstatus);
+ }
+
+ ::DDS::DataWriterListener_ptr
+ RTI_DataWriterListener_i::get_datawriterlistener (void)
+ {
+ return ::DDS::DataWriterListener::_duplicate (this->impl_.in ());
+ }
+ }
+ }
+}
+