diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/Publisher.h')
| -rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/Publisher.h | 137 |
1 files changed, 67 insertions, 70 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/Publisher.h b/CIAO/connectors/dds4ccm/impl/ndds/Publisher.h index da2a338e9b6..24d218429a3 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/Publisher.h +++ b/CIAO/connectors/dds4ccm/impl/ndds/Publisher.h @@ -31,104 +31,101 @@ namespace CIAO { namespace DDS4CCM { - namespace RTI + class DDS4CCM_NDDS_IMPL_Export CCM_DDS_Publisher_i : + public virtual ::DDS::CCM_Publisher, + public virtual ::CORBA::LocalObject { - class DDS4CCM_NDDS_IMPL_Export RTI_Publisher_i : - public virtual ::DDS::CCM_Publisher, - public virtual ::CORBA::LocalObject - { - public: - // Constructor - RTI_Publisher_i (void); + public: + /// Constructor + CCM_DDS_Publisher_i (DDSPublisher * dw); - // Destructor - virtual ~RTI_Publisher_i (void); + /// Destructor + virtual ~CCM_DDS_Publisher_i (void); - virtual - ::DDS::DataWriter_ptr create_datawriter (::DDS::Topic_ptr a_topic, - const ::DDS::DataWriterQos & qos, - ::DDS::DataWriterListener_ptr a_listener, - ::DDS::StatusMask mask); + virtual + ::DDS::DataWriter_ptr create_datawriter (::DDS::Topic_ptr a_topic, + const ::DDS::DataWriterQos & qos, + ::DDS::DataWriterListener_ptr a_listener, + ::DDS::StatusMask mask); - virtual - ::DDS::DataWriter_ptr create_datawriter_with_profile (::DDS::Topic_ptr a_topic, - const char* library_name, - const char *profile_name, - ::DDS::DataWriterListener_ptr a_listener, - ::DDS::StatusMask mask); + virtual + ::DDS::DataWriter_ptr create_datawriter_with_profile (::DDS::Topic_ptr a_topic, + const char* library_name, + const char *profile_name, + ::DDS::DataWriterListener_ptr a_listener, + ::DDS::StatusMask mask); - virtual - ::DDS::ReturnCode_t delete_datawriter (::DDS::DataWriter_ptr a_datawriter); + virtual + ::DDS::ReturnCode_t delete_datawriter (::DDS::DataWriter_ptr a_datawriter); - virtual - ::DDS::DataWriter_ptr lookup_datawriter (const char * impl_name); + virtual + ::DDS::DataWriter_ptr lookup_datawriter (const char * impl_name); - virtual - ::DDS::ReturnCode_t delete_contained_entities (void); + virtual + ::DDS::ReturnCode_t delete_contained_entities (void); - virtual - ::DDS::ReturnCode_t set_qos (const ::DDS::PublisherQos & qos); + virtual + ::DDS::ReturnCode_t set_qos (const ::DDS::PublisherQos & qos); - virtual - ::DDS::ReturnCode_t get_qos (::DDS::PublisherQos & qos); + virtual + ::DDS::ReturnCode_t get_qos (::DDS::PublisherQos & qos); - virtual - ::DDS::ReturnCode_t set_listener (::DDS::PublisherListener_ptr a_listener, - ::DDS::StatusMask mask); + virtual + ::DDS::ReturnCode_t set_listener (::DDS::PublisherListener_ptr a_listener, + ::DDS::StatusMask mask); - virtual - ::DDS::PublisherListener_ptr get_listener (void); + virtual + ::DDS::PublisherListener_ptr get_listener (void); - virtual - ::DDS::ReturnCode_t suspend_publications (void); + virtual + ::DDS::ReturnCode_t suspend_publications (void); - virtual - ::DDS::ReturnCode_t resume_publications (void); + virtual + ::DDS::ReturnCode_t resume_publications (void); - virtual - ::DDS::ReturnCode_t begin_coherent_changes (void); + virtual + ::DDS::ReturnCode_t begin_coherent_changes (void); - virtual - ::DDS::ReturnCode_t end_coherent_changes (void); + virtual + ::DDS::ReturnCode_t end_coherent_changes (void); - virtual - ::DDS::ReturnCode_t wait_for_acknowledgments (const ::DDS::Duration_t & max_wait); + virtual + ::DDS::ReturnCode_t wait_for_acknowledgments (const ::DDS::Duration_t & max_wait); - virtual - ::DDS::DomainParticipant_ptr get_participant (void); + virtual + ::DDS::DomainParticipant_ptr get_participant (void); - virtual - ::DDS::ReturnCode_t set_default_datawriter_qos (const ::DDS::DataWriterQos & qos); + virtual + ::DDS::ReturnCode_t set_default_datawriter_qos (const ::DDS::DataWriterQos & qos); - virtual - ::DDS::ReturnCode_t get_default_datawriter_qos (::DDS::DataWriterQos & qos); + virtual + ::DDS::ReturnCode_t get_default_datawriter_qos (::DDS::DataWriterQos & qos); - virtual - ::DDS::ReturnCode_t copy_from_topic_qos (::DDS::DataWriterQos & a_dataimpl_qos, - const ::DDS::TopicQos & a_impl_qos); + virtual + ::DDS::ReturnCode_t copy_from_topic_qos (::DDS::DataWriterQos & a_dataimpl_qos, + const ::DDS::TopicQos & a_impl_qos); - 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); - DDSPublisher * get_impl (void); + DDSPublisher * get_impl (void); - void set_impl (DDSPublisher *p); + void set_impl (DDSPublisher *p); - private: - DDSPublisher *impl_; + private: + DDSPublisher *impl_; - DDSPublisher *impl (void); - }; - } + DDSPublisher *impl (void); + }; } } |