diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/DataReaderHandler_T.h')
-rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/DataReaderHandler_T.h | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderHandler_T.h b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderHandler_T.h index 03eeab3a2c5..d4cfb988e54 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderHandler_T.h +++ b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderHandler_T.h @@ -4,10 +4,13 @@ * * $Id$ * - * Eventhandler on orb thread, handling the + * Eventhandler on orb thread, handling the * received data from DDS. */ +#ifndef CIAO_RTI_DATAREADERHANDLER_T_H +#define CIAO_RTI_DATAREADERHANDLER_T_H + #include "dds4ccm/idl/dds_rtf2_dcpsC.h" #include "ace/Reactor.h" @@ -18,18 +21,17 @@ namespace CIAO namespace RTI { template <typename DDS_TYPE, typename CCM_TYPE> - class DataReaderHandler_T : + class DataReaderHandler_T : public ACE_Event_Handler { public: DataReaderHandler_T ( - typename CCM_TYPE::context_type::_ptr_type context, + typename CCM_TYPE::listener_type::_ptr_type listener, typename DDS_TYPE::data_reader * reader); - ~DataReaderHandler_T (); + virtual ~DataReaderHandler_T (); virtual int handle_exception (ACE_HANDLE fc = ACE_INVALID_HANDLE); private: - typename CCM_TYPE::context_type::_var_type context_; typename DDS_TYPE::data_reader * reader_; typename CCM_TYPE::listener_type::_var_type listener_; }; @@ -38,3 +40,5 @@ namespace CIAO } #include "dds4ccm/impl/ndds/DataReaderHandler_T.cpp" + +#endif |