diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/Reader_T.h')
-rw-r--r-- | CIAO/connectors/dds4ccm/impl/Reader_T.h | 104 |
1 files changed, 0 insertions, 104 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/Reader_T.h b/CIAO/connectors/dds4ccm/impl/Reader_T.h deleted file mode 100644 index bde38f6ae7d..00000000000 --- a/CIAO/connectors/dds4ccm/impl/Reader_T.h +++ /dev/null @@ -1,104 +0,0 @@ -/** - * @author William R. Otte <wotte@dre.vanderbilt.edu> - * @author Johnny Willemsen (jwillemsen@remedy.nl) - * - * Wrapper facade for NDDS. - */ -#ifndef READER_T_H_ -#define READER_T_H_ - -#include "dds4ccm/idl/ccm_ddsC.h" -#include "ace/Copy_Disabled.h" -#include "dds4ccm/impl/dds4ccm_conf.h" -#include "dds4ccm/impl/LocalObject.h" - -namespace CIAO -{ - namespace DDS4CCM - { - class ConditionManager; - - template <typename READER_TYPE, typename TYPED_DDS_READER, typename VALUE_TYPE, typename SEQ_VALUE_TYPE> - class Reader_T : - public virtual READER_TYPE, - public virtual LocalObject, - private virtual ACE_Copy_Disabled - { - public: - /// Constructor - Reader_T (void); - - /// Destructor - virtual ~Reader_T (void); - - virtual void read_last ( - SEQ_VALUE_TYPE& instances, - ::CCM_DDS::ReadInfoSeq& infos); - - virtual void read_all ( - SEQ_VALUE_TYPE& instances, - ::CCM_DDS::ReadInfoSeq& infos); - - virtual void read_one_last ( - VALUE_TYPE& an_instance, - ::CCM_DDS::ReadInfo_out info, - DDS_INSTANCE_HANDLE_T_IN instance_handle); - - virtual void read_one_all ( - const VALUE_TYPE& an_instance, - SEQ_VALUE_TYPE& instances, - ::CCM_DDS::ReadInfoSeq& infos, - DDS_INSTANCE_HANDLE_T_IN instance_handle); - - virtual ::CCM_DDS::QueryFilter *query (void); - - virtual void query (const ::CCM_DDS::QueryFilter & filter); - - void set_dds_reader (::DDS::DataReader_ptr dr, - ::CIAO::DDS4CCM::ConditionManager * condition_manager); - - ::DDS::DataReader_ptr get_dds_reader (void); - - private: - typename TYPED_DDS_READER::_var_type dds_reader_; - ::CIAO::DDS4CCM::ConditionManager * condition_manager_; - - typename TYPED_DDS_READER::_ptr_type dds_reader (void); - - // Helper methods - ::CORBA::ULong get_nr_valid_samples ( - const ::DDS::SampleInfoSeq& sample_infos, - const bool determine_last); - - ::DDS::InstanceHandle_t check_handle ( - const VALUE_TYPE& an_instance, - DDS_INSTANCE_HANDLE_T_IN instance_handle); - - void convert_data ( - const SEQ_VALUE_TYPE& all_data, - SEQ_VALUE_TYPE& data_to_return, - ::CCM_DDS::ReadInfoSeq& infos, - const ::DDS::SampleInfoSeq & sample_info); - - void read_wo_instance ( - SEQ_VALUE_TYPE& data, - ::DDS::SampleInfoSeq & sample_info, - ::DDS::QueryCondition_ptr qc); - - void read_w_instance ( - SEQ_VALUE_TYPE& data, - ::DDS::SampleInfoSeq & sample_info, - DDS_INSTANCE_HANDLE_T_IN lookup_hnd); - - void return_loan ( - SEQ_VALUE_TYPE& data, - ::DDS::SampleInfoSeq sample_info, - bool throw_exception=true); - }; - } -} - -#include "dds4ccm/impl/Reader_T.cpp" - -#endif /* READER_T_H_ */ - |