summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener_T.h
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener_T.h')
-rw-r--r--CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener_T.h57
1 files changed, 27 insertions, 30 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener_T.h b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener_T.h
index 94643166fc0..7dbd4af959d 100644
--- a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener_T.h
+++ b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderListener_T.h
@@ -20,37 +20,34 @@ namespace CIAO
{
namespace DDS4CCM
{
- namespace RTI
+ template <typename DDS_TYPE, typename CCM_TYPE>
+ class DataReaderListener_T :
+ public PortStatusListener_T <DDS_TYPE, CCM_TYPE>
{
- template <typename DDS_TYPE, typename CCM_TYPE>
- class DataReaderListener_T :
- public PortStatusListener_T <DDS_TYPE, CCM_TYPE>
- {
- public:
- /// Constructor
- DataReaderListener_T (
- typename CCM_TYPE::listener_type::_ptr_type listener,
- ::CCM_DDS::PortStatusListener_ptr port_status_listener,
- ::CCM_DDS::DataListenerControl_ptr control,
- ACE_Reactor* reactor);
-
- /// Destructor
- virtual ~DataReaderListener_T (void);
-
- virtual void on_data_available( ::DDS::DataReader *rdr);
-
- static ::DDS::StatusMask get_mask (
- typename CCM_TYPE::listener_type::_ptr_type listener);
-
- void on_data_available_i ( ::DDS::DataReader *rdr);
-
- private:
- typename CCM_TYPE::listener_type::_var_type listener_;
- ::CCM_DDS::DataListenerControl_var control_;
-
- typedef ::CIAO::DDS4CCM::RTI::DataReaderHandler_T<DDS_TYPE, CCM_TYPE> drh;
- };
- }
+ public:
+ /// Constructor
+ DataReaderListener_T (
+ typename CCM_TYPE::listener_type::_ptr_type listener,
+ ::CCM_DDS::PortStatusListener_ptr port_status_listener,
+ ::CCM_DDS::DataListenerControl_ptr control,
+ ACE_Reactor* reactor);
+
+ /// Destructor
+ virtual ~DataReaderListener_T (void);
+
+ virtual void on_data_available( ::DDS::DataReader *rdr);
+
+ static ::DDS::StatusMask get_mask (
+ typename CCM_TYPE::listener_type::_ptr_type listener);
+
+ void on_data_available_i ( ::DDS::DataReader *rdr);
+
+ private:
+ typename CCM_TYPE::listener_type::_var_type listener_;
+ ::CCM_DDS::DataListenerControl_var control_;
+
+ typedef ::CIAO::DDS4CCM::DataReaderHandler_T<DDS_TYPE, CCM_TYPE> drh;
+ };
}
}