summaryrefslogtreecommitdiff
path: root/modules/CIAO/connectors/dds4ccm/tests/Event_Connection_Test/Receiver/Event_Connection_Test_Receiver_exec.h
diff options
context:
space:
mode:
Diffstat (limited to 'modules/CIAO/connectors/dds4ccm/tests/Event_Connection_Test/Receiver/Event_Connection_Test_Receiver_exec.h')
-rw-r--r--modules/CIAO/connectors/dds4ccm/tests/Event_Connection_Test/Receiver/Event_Connection_Test_Receiver_exec.h87
1 files changed, 87 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/dds4ccm/tests/Event_Connection_Test/Receiver/Event_Connection_Test_Receiver_exec.h b/modules/CIAO/connectors/dds4ccm/tests/Event_Connection_Test/Receiver/Event_Connection_Test_Receiver_exec.h
new file mode 100644
index 00000000000..7536df834d0
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/tests/Event_Connection_Test/Receiver/Event_Connection_Test_Receiver_exec.h
@@ -0,0 +1,87 @@
+// -*- C++ -*-
+// $Id$
+
+#ifndef EVENT_CONNECTION_RECEIVER_EXEC_H_
+#define EVENT_CONNECTION_RECEIVER_EXEC_H_
+
+#include "Event_Connection_Test_ReceiverEC.h"
+
+#include /**/ "Receiver_exec_export.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "tao/LocalObject.h"
+
+namespace CIAO_Event_Connection_Test_Receiver_Impl
+{
+ //============================================================
+ // Receiver_exec_i
+ //============================================================
+ class RECEIVER_EXEC_Export Receiver_exec_i
+ : public virtual Receiver_Exec,
+ public virtual ::CORBA::LocalObject
+ {
+ public:
+ Receiver_exec_i (void);
+ virtual ~Receiver_exec_i (void);
+
+ // Port operations.
+ virtual ::CCM_DDS::Event_ConnectionTest::CCM_Listener_ptr
+ get_info_listen_data_listener (void);
+
+ virtual ::CCM_DDS::CCM_PortStatusListener_ptr
+ get_info_listen_status (void);
+
+ //DDS_Get
+ virtual ::CCM_DDS::CCM_PortStatusListener_ptr
+ get_info_get_status (void);
+
+ virtual CCM_DDS::CCM_ConnectorStatusListener_ptr
+ get_status_listener(void);
+
+ // Operations from Components::SessionComponent.
+ virtual void
+ set_session_context (
+ ::Components::SessionContext_ptr ctx);
+
+ virtual void configuration_complete (void);
+
+ virtual void ccm_activate (void);
+ virtual void ccm_passivate (void);
+ virtual void ccm_remove (void);
+
+ private:
+ ::Event_Connection_Test::CCM_Receiver_Context_var context_;
+ //DDS_Get
+ ::CCM_DDS::Event_ConnectionTest::Getter_var getter_getter_;
+ ::DDS::DataReader_var getter_dds_data_reader_;
+ ::CCM_DDS::Event_ConnectionTest::Reader_var getter_reader_;
+
+ bool getter_ok_;
+ bool getter_dds_data_reader_ok_;
+ bool getter_reader_ok_;
+
+ //DDS_Listen
+ ::CCM_DDS::DataListenerControl_var listen_data_control_;
+ ::CCM_DDS::Event_ConnectionTest::Reader_var listen_reader_;
+ ::DDS::DataReader_var listen_dds_data_reader_;
+
+ bool listen_data_control_ok_;
+ bool listen_reader_ok_;
+ bool listen_dds_data_reader_ok_;
+
+ //Provide checks
+ bool listen_port_status_created_;
+ bool get_port_status_created_;
+ bool get_status_listener_created_;
+ bool raw_listener_created_;
+ };
+
+ extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr
+ create_Event_Connection_Test_Receiver_Impl (void);
+}
+
+#endif /* ifndef */
+