diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/Subscriber.h')
| -rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/Subscriber.h | 204 |
1 files changed, 97 insertions, 107 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/Subscriber.h b/CIAO/connectors/dds4ccm/impl/ndds/Subscriber.h index efc943e5b33..12e59f178ed 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/Subscriber.h +++ b/CIAO/connectors/dds4ccm/impl/ndds/Subscriber.h @@ -35,149 +35,139 @@ namespace CIAO { namespace DDS4CCM { - namespace RTI + class DDS4CCM_NDDS_IMPL_Export CCM_DDS_Subscriber_i : + public virtual ::DDS::CCM_Subscriber, + public virtual ::CORBA::LocalObject { - class DDS4CCM_NDDS_IMPL_Export RTI_Subscriber_i : - public virtual ::DDS::CCM_Subscriber, - public virtual ::CORBA::LocalObject - { - public: - // Constructor - RTI_Subscriber_i (void); + public: + /// Constructor + CCM_DDS_Subscriber_i (DDSSubscriber * sub); - // Destructor - virtual ~RTI_Subscriber_i (void); + /// Destructor + virtual ~CCM_DDS_Subscriber_i (void); - virtual ::DDS::ReturnCode_t - enable (void); + virtual ::DDS::ReturnCode_t enable (void); - virtual ::DDS::StatusCondition_ptr - get_statuscondition (void); + virtual ::DDS::StatusCondition_ptr get_statuscondition (void); - virtual ::DDS::StatusMask - get_status_changes (void); + virtual ::DDS::StatusMask get_status_changes (void); - virtual ::DDS::InstanceHandle_t - get_instance_handle (void); + virtual ::DDS::InstanceHandle_t get_instance_handle (void); - virtual ::DDS::DataReader_ptr - create_datareader ( - ::DDS::TopicDescription_ptr a_topic, - const ::DDS::DataReaderQos & qos, - ::DDS::DataReaderListener_ptr a_listener, - ::DDS::StatusMask mask); + virtual ::DDS::DataReader_ptr create_datareader ( + ::DDS::TopicDescription_ptr a_topic, + const ::DDS::DataReaderQos & qos, + ::DDS::DataReaderListener_ptr a_listener, + ::DDS::StatusMask mask); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - virtual ::DDS::DataReader_ptr - create_datareader_with_profile ( - ::DDS::TopicDescription_ptr a_topic, - const char* library_name, - const char *profile_name, - ::DDS::DataReaderListener_ptr a_listener, - ::DDS::StatusMask mask); + virtual ::DDS::DataReader_ptr + create_datareader_with_profile ( + ::DDS::TopicDescription_ptr a_topic, + const char* library_name, + const char *profile_name, + ::DDS::DataReaderListener_ptr a_listener, + ::DDS::StatusMask mask); #endif - virtual ::DDS::ReturnCode_t - delete_datareader ( - ::DDS::DataReader_ptr a_datareader); + virtual ::DDS::ReturnCode_t + delete_datareader ( + ::DDS::DataReader_ptr a_datareader); - virtual ::DDS::ReturnCode_t - delete_contained_entities (void); + virtual ::DDS::ReturnCode_t delete_contained_entities (void); - virtual ::DDS::DataReader_ptr - lookup_datareader ( - const char * impl_name); + virtual ::DDS::DataReader_ptr lookup_datareader ( + const char * impl_name); - virtual ::DDS::ReturnCode_t - get_datareaders ( - ::DDS::DataReaderSeq & readers, - ::DDS::SampleStateMask sample_states, - ::DDS::ViewStateMask view_states, - ::DDS::InstanceStateMask instance_states); + virtual ::DDS::ReturnCode_t + get_datareaders ( + ::DDS::DataReaderSeq & readers, + ::DDS::SampleStateMask sample_states, + ::DDS::ViewStateMask view_states, + ::DDS::InstanceStateMask instance_states); - virtual ::DDS::ReturnCode_t - notify_datareaders (void); + virtual ::DDS::ReturnCode_t + notify_datareaders (void); - virtual ::DDS::ReturnCode_t - set_qos ( - const ::DDS::SubscriberQos & qos); + virtual ::DDS::ReturnCode_t + set_qos ( + const ::DDS::SubscriberQos & qos); - virtual ::DDS::ReturnCode_t - get_qos ( - ::DDS::SubscriberQos & qos); + virtual ::DDS::ReturnCode_t + get_qos ( + ::DDS::SubscriberQos & qos); - virtual ::DDS::ReturnCode_t - set_listener ( - ::DDS::SubscriberListener_ptr a_listener, - ::DDS::StatusMask mask); + virtual ::DDS::ReturnCode_t + set_listener ( + ::DDS::SubscriberListener_ptr a_listener, + ::DDS::StatusMask mask); - virtual ::DDS::SubscriberListener_ptr - get_listener (void); + virtual ::DDS::SubscriberListener_ptr + get_listener (void); - virtual ::DDS::ReturnCode_t - begin_access (void); + virtual ::DDS::ReturnCode_t + begin_access (void); - virtual ::DDS::ReturnCode_t - end_access (void); + virtual ::DDS::ReturnCode_t + end_access (void); - virtual ::DDS::DomainParticipant_ptr - get_participant (void); + virtual ::DDS::DomainParticipant_ptr + get_participant (void); - virtual ::DDS::ReturnCode_t - set_default_datareader_qos ( - const ::DDS::DataReaderQos & qos); + virtual ::DDS::ReturnCode_t + set_default_datareader_qos ( + const ::DDS::DataReaderQos & qos); - virtual ::DDS::ReturnCode_t - get_default_datareader_qos ( - ::DDS::DataReaderQos & qos); + virtual ::DDS::ReturnCode_t + get_default_datareader_qos ( + ::DDS::DataReaderQos & qos); - virtual ::DDS::ReturnCode_t - copy_from_topic_qos ( - ::DDS::DataReaderQos & a_datareader_qos, - const ::DDS::TopicQos & a_impl_qos); + virtual ::DDS::ReturnCode_t + copy_from_topic_qos ( + ::DDS::DataReaderQos & a_datareader_qos, + const ::DDS::TopicQos & a_impl_qos); - DDSSubscriber * get_impl (void); + DDSSubscriber * get_impl (void); - void set_impl (DDSSubscriber * sub); + void set_impl (DDSSubscriber * sub); - private: - DDSSubscriber *impl_; + private: + DDSSubscriber *impl_; - DDSSubscriber *impl (void); + DDSSubscriber *impl (void); - DDSDataReader * - create_datareader ( - DDSTopic * topic, - DDSDataReaderListener * rti_drl, - ::DDS::StatusMask mask); + DDSDataReader * + create_datareader ( + DDSTopic * topic, + DDSDataReaderListener * rti_drl, + ::DDS::StatusMask mask); - DDSDataReader * - create_datareader ( - DDSContentFilteredTopic * topic, - DDSDataReaderListener * rti_drl, - ::DDS::StatusMask mask); + DDSDataReader * + create_datareader ( + DDSContentFilteredTopic * topic, + DDSDataReaderListener * rti_drl, + ::DDS::StatusMask mask); #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - DDSDataReader * - create_datareader_with_profile ( - DDSContentFilteredTopic * topic, - const char* library_name, - const char *profile_name, - DDSDataReaderListener * rti_drl, - ::DDS::StatusMask mask); + DDSDataReader * + create_datareader_with_profile ( + DDSContentFilteredTopic * topic, + const char* library_name, + const char *profile_name, + DDSDataReaderListener * rti_drl, + ::DDS::StatusMask mask); #endif #if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1) - DDSDataReader * - create_datareader_with_profile ( - DDSTopic * topic, - const char* library_name, - const char *profile_name, - DDSDataReaderListener * rti_drl, - ::DDS::StatusMask mask); -#endif - }; - } + DDSDataReader * + create_datareader_with_profile ( + DDSTopic * topic, + const char* library_name, + const char *profile_name, + DDSDataReaderListener * rti_drl, + ::DDS::StatusMask mask); +#endif + }; } } |