summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/impl/ndds/DDS_Base_Connector_T.h
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/DDS_Base_Connector_T.h')
-rw-r--r--CIAO/connectors/dds4ccm/impl/ndds/DDS_Base_Connector_T.h59
1 files changed, 59 insertions, 0 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DDS_Base_Connector_T.h b/CIAO/connectors/dds4ccm/impl/ndds/DDS_Base_Connector_T.h
new file mode 100644
index 00000000000..cb798ddf337
--- /dev/null
+++ b/CIAO/connectors/dds4ccm/impl/ndds/DDS_Base_Connector_T.h
@@ -0,0 +1,59 @@
+/**
+ * @author Johnny Willemsen <jwillemsen@remedy.nl>
+ *
+ * $Id$
+ */
+#ifndef DDS_BASE_CONNECTOR_T_H
+#define DDS_BASE_CONNECTOR_T_H
+
+#include "dds4ccm/idl/dds_rtf2_dcpsC.h"
+#include "ace/Copy_Disabled.h"
+#include "tao/LocalObject.h"
+#include "dds4ccm/impl/ndds/DomainParticipantListener_T.h"
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+class DDS_Base_Connector_T
+ : public virtual CCM_TYPE::base_type,
+ public virtual ::CORBA::LocalObject,
+ private virtual ACE_Copy_Disabled
+{
+public:
+ DDS_Base_Connector_T (void);
+ virtual ~DDS_Base_Connector_T (void);
+
+ virtual ::DDS::DomainId_t domain_id (void);
+
+ virtual void domain_id (::DDS::DomainId_t domain_id);
+
+ virtual char *qos_profile (void);
+
+ virtual void qos_profile (const char * qos_profile);
+
+ virtual void set_session_context (::Components::SessionContext_ptr ctx);
+
+ virtual void configuration_complete (void);
+ virtual void ccm_remove (void);
+ virtual void ccm_activate (void);
+ virtual void ccm_passivate (void);
+
+protected:
+ void init_default_domain (void);
+
+ DDS::DomainId_t domain_id_;
+ CORBA::String_var qos_profile_;
+ bool configuration_complete_;
+ const char* library_name_;
+ const char* profile_name_;
+
+ ::DDS::DomainParticipant_var domain_participant_;
+ ::DDS::DomainParticipantListener_var domainparticipantlistener_;
+ typename CCM_TYPE::context_type::_var_type context_;
+
+ ::CCM_DDS::ConnectorStatusListener_var error_listener_;
+
+ typedef ::CIAO::DDS4CCM::DomainParticipantListener_T<DDS_TYPE, CCM_TYPE> DomainParticipantListener;
+};
+
+#include "dds4ccm/impl/ndds/DDS_Base_Connector_T.cpp"
+
+#endif /* CONNECTOR_T_H_ */