summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/tests/ListenManyByMany/Receiver/LMBM_Test_Receiver_exec.h
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/ListenManyByMany/Receiver/LMBM_Test_Receiver_exec.h')
-rw-r--r--CIAO/connectors/dds4ccm/tests/ListenManyByMany/Receiver/LMBM_Test_Receiver_exec.h107
1 files changed, 0 insertions, 107 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/ListenManyByMany/Receiver/LMBM_Test_Receiver_exec.h b/CIAO/connectors/dds4ccm/tests/ListenManyByMany/Receiver/LMBM_Test_Receiver_exec.h
deleted file mode 100644
index 5ed192bd716..00000000000
--- a/CIAO/connectors/dds4ccm/tests/ListenManyByMany/Receiver/LMBM_Test_Receiver_exec.h
+++ /dev/null
@@ -1,107 +0,0 @@
-// -*- C++ -*-
-#ifndef CIAO_RECEIVER_EXEC_H_
-#define CIAO_RECEIVER_EXEC_H_
-
-#include "LMBM_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_LMBM_Test_Receiver_Impl
-{
- class Receiver_exec_i;
-
- typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::ULong> Atomic_ULong;
- typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, bool> Atomic_Bool;
-
- //============================================================
- // ListenManyByManyTest_Listener_exec_i
- //============================================================
- class RECEIVER_EXEC_Export ListenManyByManyTest_Listener_exec_i
- : public virtual ::LMBM_Test::ListenManyByManyTestConnector::CCM_Listener,
- public virtual ::CORBA::LocalObject
- {
- public:
- ListenManyByManyTest_Listener_exec_i (
- ::LMBM_Test::CCM_Receiver_Context_ptr context,
- Atomic_ULong &received_one_by_one,
- Atomic_ULong &received_many_by_many,
- Atomic_ULong &samples_read_);
- virtual ~ListenManyByManyTest_Listener_exec_i (void);
-
- virtual void
- on_one_data (
- const ListenManyByManyTest & an_instance,
- const ::CCM_DDS::ReadInfo & info);
- virtual void
- on_many_data (
- const ListenManyByManyTestSeq & an_instance,
- const ::CCM_DDS::ReadInfoSeq & info);
- private:
- ::LMBM_Test::CCM_Receiver_Context_var context_;
- Atomic_ULong &received_one_by_one_;
- Atomic_ULong &received_many_by_many_;
- Atomic_ULong &samples_read_;
- };
-
- //============================================================
- // 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);
-
- void start ();
-
- virtual ::CORBA::UShort iterations (void);
-
- virtual void iterations (::CORBA::UShort iterations);
-
- virtual ::CORBA::UShort keys (void);
-
- virtual void keys (::CORBA::UShort keys);
-
- virtual ::LMBM_Test::ListenManyByManyTestConnector::CCM_Listener_ptr
- get_info_listen_data_listener (void);
-
- virtual ::CCM_DDS::CCM_PortStatusListener_ptr
- get_info_listen_status (void);
-
- virtual ::CCM_DDS::CCM_ConnectorStatusListener_ptr
- get_info_listen_connector_status (void);
-
- 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:
- ::LMBM_Test::CCM_Receiver_Context_var context_;
-
- Atomic_ULong received_one_by_one_;
- Atomic_ULong received_many_by_many_;
- Atomic_ULong samples_read_;
-
- CORBA::UShort iterations_;
- CORBA::UShort keys_;
- };
-
- extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr
- create_LMBM_Test_Receiver_Impl (void);
-}
-
-#endif /* ifndef */