diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener.cpp')
| -rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener.cpp | 225 |
1 files changed, 111 insertions, 114 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener.cpp b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener.cpp index cf307eb4251..a36630d250e 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener.cpp +++ b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener.cpp @@ -17,151 +17,148 @@ namespace CIAO { namespace DDS4CCM { - namespace RTI + CCM_DDS_DataReaderListener_i::CCM_DDS_DataReaderListener_i (::DDS::DataReaderListener_ptr p) + : impl_ (::DDS::DataReaderListener::_duplicate (p)) { - RTI_DataReaderListener_i::RTI_DataReaderListener_i (::DDS::DataReaderListener_ptr p) - : impl_ (::DDS::DataReaderListener::_duplicate (p)) - { - } + } - RTI_DataReaderListener_i::~RTI_DataReaderListener_i (void) - { - } + CCM_DDS_DataReaderListener_i::~CCM_DDS_DataReaderListener_i (void) + { + } - void - RTI_DataReaderListener_i::on_requested_deadline_missed ( - ::DDSDataReader* the_reader, - const ::DDS_RequestedDeadlineMissedStatus & status) - { - DDS4CCM_TRACE ("RTI_DataReaderListener_i::on_requested_deadline_missed"); + void + CCM_DDS_DataReaderListener_i::on_requested_deadline_missed ( + ::DDSDataReader* the_reader, + const ::DDS_RequestedDeadlineMissedStatus & status) + { + DDS4CCM_TRACE ("CCM_DDS_DataReaderListener_i::on_requested_deadline_missed"); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - ::DDS::RequestedDeadlineMissedStatus ddsstatus; - ddsstatus <<= status; - ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); - ACE_NEW (dds_reader, RTI_DataReader_i ()); - RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(dds_reader.in ()); - rti_dr->set_impl (the_reader); - this->impl_->on_requested_deadline_missed (dds_reader.in (), ddsstatus); + ::DDS::RequestedDeadlineMissedStatus ddsstatus; + ddsstatus <<= status; + ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); + ACE_NEW (dds_reader, CCM_DDS_DataReader_i ()); + CCM_DDS_DataReader_i *rti_dr = dynamic_cast < CCM_DDS_DataReader_i *>(dds_reader.in ()); + rti_dr->set_impl (the_reader); + this->impl_->on_requested_deadline_missed (dds_reader.in (), ddsstatus); #else - this->impl_->on_requested_deadline_missed (the_reader, status); + this->impl_->on_requested_deadline_missed (the_reader, status); #endif - } + } - void - RTI_DataReaderListener_i::on_requested_incompatible_qos ( - ::DDSDataReader* the_reader, - const ::DDS_RequestedIncompatibleQosStatus & status) - { - DDS4CCM_TRACE ("RTI_DataReaderListener_i::on_requested_incompatible_qos"); + void + CCM_DDS_DataReaderListener_i::on_requested_incompatible_qos ( + ::DDSDataReader* the_reader, + const ::DDS_RequestedIncompatibleQosStatus & status) + { + DDS4CCM_TRACE ("CCM_DDS_DataReaderListener_i::on_requested_incompatible_qos"); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - ::DDS::RequestedIncompatibleQosStatus ddsstatus; - ddsstatus <<= status; - ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); - ACE_NEW (dds_reader, RTI_DataReader_i ()); - RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(dds_reader.in ()); - rti_dr->set_impl (the_reader); - this->impl_->on_requested_incompatible_qos (dds_reader.in (), ddsstatus); + ::DDS::RequestedIncompatibleQosStatus ddsstatus; + ddsstatus <<= status; + ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); + ACE_NEW (dds_reader, CCM_DDS_DataReader_i ()); + CCM_DDS_DataReader_i *rti_dr = dynamic_cast < CCM_DDS_DataReader_i *>(dds_reader.in ()); + rti_dr->set_impl (the_reader); + this->impl_->on_requested_incompatible_qos (dds_reader.in (), ddsstatus); #else - this->impl_->on_requested_incompatible_qos (the_reader, status); + this->impl_->on_requested_incompatible_qos (the_reader, status); #endif - } + } - void - RTI_DataReaderListener_i::on_sample_rejected ( - ::DDSDataReader* the_reader, - const ::DDS_SampleRejectedStatus & status) - { - DDS4CCM_TRACE ("RTI_DataReaderListener_i::on_sample_rejected"); + void + CCM_DDS_DataReaderListener_i::on_sample_rejected ( + ::DDSDataReader* the_reader, + const ::DDS_SampleRejectedStatus & status) + { + DDS4CCM_TRACE ("CCM_DDS_DataReaderListener_i::on_sample_rejected"); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - ::DDS::SampleRejectedStatus ddsstatus; - ddsstatus <<= status; - ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); - ACE_NEW (dds_reader, RTI_DataReader_i ()); - RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(dds_reader.in ()); - rti_dr->set_impl (the_reader); - this->impl_->on_sample_rejected (dds_reader.in (), ddsstatus); + ::DDS::SampleRejectedStatus ddsstatus; + ddsstatus <<= status; + ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); + ACE_NEW (dds_reader, CCM_DDS_DataReader_i ()); + CCM_DDS_DataReader_i *rti_dr = dynamic_cast < CCM_DDS_DataReader_i *>(dds_reader.in ()); + rti_dr->set_impl (the_reader); + this->impl_->on_sample_rejected (dds_reader.in (), ddsstatus); #else - this->impl_->on_sample_rejected (the_reader, status); + this->impl_->on_sample_rejected (the_reader, status); #endif - } + } - void - RTI_DataReaderListener_i::on_liveliness_changed ( - ::DDSDataReader* the_reader, - const ::DDS_LivelinessChangedStatus & status) - { - DDS4CCM_TRACE ("RTI_DataReaderListener_i::on_liveliness_changed"); + void + CCM_DDS_DataReaderListener_i::on_liveliness_changed ( + ::DDSDataReader* the_reader, + const ::DDS_LivelinessChangedStatus & status) + { + DDS4CCM_TRACE ("CCM_DDS_DataReaderListener_i::on_liveliness_changed"); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - ::DDS::LivelinessChangedStatus ddsstatus; - ddsstatus <<= status; - ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); - ACE_NEW (dds_reader, RTI_DataReader_i ()); - RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(dds_reader.in ()); - rti_dr->set_impl (the_reader); - this->impl_->on_liveliness_changed (dds_reader.in (), ddsstatus); + ::DDS::LivelinessChangedStatus ddsstatus; + ddsstatus <<= status; + ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); + ACE_NEW (dds_reader, CCM_DDS_DataReader_i ()); + CCM_DDS_DataReader_i *rti_dr = dynamic_cast < CCM_DDS_DataReader_i *>(dds_reader.in ()); + rti_dr->set_impl (the_reader); + this->impl_->on_liveliness_changed (dds_reader.in (), ddsstatus); #else - this->impl_->on_liveliness_changed (the_reader, status); + this->impl_->on_liveliness_changed (the_reader, status); #endif - } + } - void - RTI_DataReaderListener_i::on_data_available(::DDSDataReader *the_reader) - { - DDS4CCM_TRACE ("RTI_DataReaderListener_i::on_data_available"); + void + CCM_DDS_DataReaderListener_i::on_data_available(::DDSDataReader *the_reader) + { + DDS4CCM_TRACE ("CCM_DDS_DataReaderListener_i::on_data_available"); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); - ACE_NEW (dds_reader, RTI_DataReader_i ()); - RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(dds_reader.in ()); - rti_dr->set_impl (the_reader); - this->impl_->on_data_available (dds_reader.in ()); + ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); + ACE_NEW (dds_reader, CCM_DDS_DataReader_i ()); + CCM_DDS_DataReader_i *rti_dr = dynamic_cast < CCM_DDS_DataReader_i *>(dds_reader.in ()); + rti_dr->set_impl (the_reader); + this->impl_->on_data_available (dds_reader.in ()); #else - this->impl_->on_data_available (the_reader); + this->impl_->on_data_available (the_reader); #endif - } + } - void - RTI_DataReaderListener_i::on_subscription_matched ( - ::DDSDataReader* the_reader, - const ::DDS_SubscriptionMatchedStatus & status) - { - DDS4CCM_TRACE ("RTI_DataReaderListener_i::on_subscription_matched"); + void + CCM_DDS_DataReaderListener_i::on_subscription_matched ( + ::DDSDataReader* the_reader, + const ::DDS_SubscriptionMatchedStatus & status) + { + DDS4CCM_TRACE ("CCM_DDS_DataReaderListener_i::on_subscription_matched"); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - ::DDS::SubscriptionMatchedStatus ddsstatus; - ddsstatus <<= status; - ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); - ACE_NEW (dds_reader, RTI_DataReader_i ()); - RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(dds_reader.in ()); - rti_dr->set_impl (the_reader); - this->impl_->on_subscription_matched (dds_reader.in (), ddsstatus); + ::DDS::SubscriptionMatchedStatus ddsstatus; + ddsstatus <<= status; + ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); + ACE_NEW (dds_reader, CCM_DDS_DataReader_i ()); + CCM_DDS_DataReader_i *rti_dr = dynamic_cast < CCM_DDS_DataReader_i *>(dds_reader.in ()); + rti_dr->set_impl (the_reader); + this->impl_->on_subscription_matched (dds_reader.in (), ddsstatus); #else - this->impl_->on_subscription_matched (the_reader, status); + this->impl_->on_subscription_matched (the_reader, status); #endif - } + } - void - RTI_DataReaderListener_i::on_sample_lost ( - ::DDSDataReader* the_reader, - const ::DDS_SampleLostStatus & status) - { - DDS4CCM_TRACE ("RTI_DataReaderListener_i::on_sample_lost"); + void + CCM_DDS_DataReaderListener_i::on_sample_lost ( + ::DDSDataReader* the_reader, + const ::DDS_SampleLostStatus & status) + { + DDS4CCM_TRACE ("CCM_DDS_DataReaderListener_i::on_sample_lost"); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - ::DDS::SampleLostStatus ddsstatus; - ddsstatus <<= status; - ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); - ACE_NEW (dds_reader, RTI_DataReader_i ()); - RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(dds_reader.in ()); - rti_dr->set_impl (the_reader); - this->impl_->on_sample_lost (dds_reader.in (), ddsstatus); + ::DDS::SampleLostStatus ddsstatus; + ddsstatus <<= status; + ::DDS::DataReader_var dds_reader = ::DDS::DataReader::_nil (); + ACE_NEW (dds_reader, CCM_DDS_DataReader_i ()); + CCM_DDS_DataReader_i *rti_dr = dynamic_cast < CCM_DDS_DataReader_i *>(dds_reader.in ()); + rti_dr->set_impl (the_reader); + this->impl_->on_sample_lost (dds_reader.in (), ddsstatus); #else - this->impl_->on_sample_lost (the_reader, status); + this->impl_->on_sample_lost (the_reader, status); #endif - } + } - ::DDS::DataReaderListener_ptr - RTI_DataReaderListener_i::get_datareaderlistener (void) - { - return ::DDS::DataReaderListener::_duplicate (this->impl_.in ()); - } + ::DDS::DataReaderListener_ptr + CCM_DDS_DataReaderListener_i::get_datareaderlistener (void) + { + return ::DDS::DataReaderListener::_duplicate (this->impl_.in ()); } } } |