diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/CCM_DataReader.cpp')
| -rw-r--r-- | CIAO/connectors/dds4ccm/impl/CCM_DataReader.cpp | 215 |
1 files changed, 0 insertions, 215 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/CCM_DataReader.cpp b/CIAO/connectors/dds4ccm/impl/CCM_DataReader.cpp deleted file mode 100644 index 5199451e5be..00000000000 --- a/CIAO/connectors/dds4ccm/impl/CCM_DataReader.cpp +++ /dev/null @@ -1,215 +0,0 @@ -#include "CCM_DataReader.h" -#include "dds4ccm/impl/logger/Log_Macros.h" - -CIAO::DDS4CCM::CCM_DataReader::CCM_DataReader (void) -{ - DDS4CCM_TRACE ("CIAO::DDS4CCM::CCM_DataReader::CCM_DataReader"); -} - -CIAO::DDS4CCM::CCM_DataReader::~CCM_DataReader (void) -{ - DDS4CCM_TRACE ("CIAO::DDS4CCM::CCM_DataReader::~CCM_DataReader"); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::enable (void) -{ - return this->dds_entity ()->enable (); -} - -::DDS::StatusCondition_ptr -CIAO::DDS4CCM::CCM_DataReader::get_statuscondition (void) -{ - return this->dds_entity ()->get_statuscondition (); -} - -::DDS::StatusMask -CIAO::DDS4CCM::CCM_DataReader::get_status_changes (void) -{ - return this->dds_entity ()->get_status_changes (); -} - -::DDS::InstanceHandle_t -CIAO::DDS4CCM::CCM_DataReader::get_instance_handle (void) -{ - return this->dds_entity ()->get_instance_handle (); -} - -::DDS::ReadCondition_ptr -CIAO::DDS4CCM::CCM_DataReader::create_readcondition ( - ::DDS::SampleStateMask sample_states, - ::DDS::ViewStateMask view_states, - ::DDS::InstanceStateMask instance_states) -{ - return this->dds_entity ()->create_readcondition (sample_states, - view_states, - instance_states); -} - -::DDS::QueryCondition_ptr -CIAO::DDS4CCM::CCM_DataReader::create_querycondition ( - ::DDS::SampleStateMask sample_states, - ::DDS::ViewStateMask view_states, - ::DDS::InstanceStateMask instance_states, - const char * query_expression, - const ::DDS::StringSeq & query_parameters) -{ - return this->dds_entity ()->create_querycondition (sample_states, - view_states, - instance_states, - query_expression, - query_parameters); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::delete_readcondition ( - ::DDS::ReadCondition_ptr a_condition) -{ - return this->dds_entity ()->delete_readcondition (a_condition); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::delete_contained_entities (void) -{ - return this->dds_entity ()->delete_contained_entities (); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::set_qos ( - const ::DDS::DataReaderQos & qos) -{ - return this->dds_entity ()->set_qos (qos); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_qos ( - ::DDS::DataReaderQos & qos) -{ - return this->dds_entity ()->get_qos (qos); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::set_listener ( - ::DDS::DataReaderListener_ptr a_listener, - ::DDS::StatusMask mask) -{ - return this->dds_entity ()->set_listener (a_listener, mask); -} - -::DDS::DataReaderListener_ptr -CIAO::DDS4CCM::CCM_DataReader::get_listener (void) -{ - return this->dds_entity ()->get_listener (); -} - -::DDS::TopicDescription_ptr -CIAO::DDS4CCM::CCM_DataReader::get_topicdescription (void) -{ - return this->dds_entity ()->get_topicdescription(); -} - -::DDS::Subscriber_ptr -CIAO::DDS4CCM::CCM_DataReader::get_subscriber (void) -{ - return this->dds_entity ()->get_subscriber (); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_sample_rejected_status ( - ::DDS::SampleRejectedStatus & status) -{ - return this->get_dds_entity ()->get_sample_rejected_status (status); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_liveliness_changed_status ( - ::DDS::LivelinessChangedStatus & status) -{ - return this->dds_entity ()->get_liveliness_changed_status (status); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_requested_deadline_missed_status ( - ::DDS::RequestedDeadlineMissedStatus & status) -{ - return this->dds_entity ()->get_requested_deadline_missed_status (status); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_requested_incompatible_qos_status ( - ::DDS::RequestedIncompatibleQosStatus & status) -{ - return this->dds_entity ()->get_requested_incompatible_qos_status (status); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_subscription_matched_status ( - ::DDS::SubscriptionMatchedStatus & status) -{ - return this->dds_entity ()->get_subscription_matched_status (status); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_sample_lost_status ( - ::DDS::SampleLostStatus & status) -{ - return this->dds_entity ()->get_sample_lost_status (status); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::wait_for_historical_data ( - const ::DDS::Duration_t & max_wait) -{ - return this->dds_entity ()->wait_for_historical_data (max_wait); -} - -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_matched_publications ( - ::DDS::InstanceHandleSeq & publication_handles) -{ - return this->dds_entity ()->get_matched_publications (publication_handles); -} - -#if !defined (DDS_HAS_MINIMUM_BIT) -::DDS::ReturnCode_t -CIAO::DDS4CCM::CCM_DataReader::get_matched_publication_data ( - ::DDS::PublicationBuiltinTopicData & publication_data, - DDS_INSTANCE_HANDLE_T_IN publication_handle) -{ - return this->dds_entity ()->get_matched_publication_data (publication_data, - publication_handle); -} -#endif - -void -CIAO::DDS4CCM::CCM_DataReader::set_dds_entity (::DDS::DataReader_ptr dr) -{ - DDS4CCM_TRACE ("CIAO::DDS4CCM::CCM_DataReader::set_dds_entity"); - this->dds_entity_ = ::DDS::DataReader::_duplicate (dr); -} - -::DDS::DataReader_ptr -CIAO::DDS4CCM::CCM_DataReader::get_dds_entity (void) -{ - DDS4CCM_TRACE ("CIAO::DDS4CCM::CCM_DataReader::get_dds_entity"); - - return ::DDS::DataReader::_duplicate (this->dds_entity_); -} - -::DDS::DataReader_ptr -CIAO::DDS4CCM::CCM_DataReader::dds_entity (void) -{ - DDS4CCM_TRACE ("CIAO::DDS4CCM::CCM_DataReader::dds_entity"); - - if (::CORBA::is_nil (this->dds_entity_.in ())) - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, - "CIAO::DDS4CCM::CCM_DataReader::dds_entity - " - "Throwing BAD_INV_ORDER.\n")); - throw ::CORBA::BAD_INV_ORDER (); - } - else - { - return this->dds_entity_.in (); - } -} |