diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.h')
| -rw-r--r-- | CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.h | 45 |
1 files changed, 37 insertions, 8 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.h b/CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.h index 2a27dff5876..6a64f454548 100644 --- a/CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.h +++ b/CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.h @@ -13,7 +13,6 @@ #endif /* ACE_LACKS_PRAGMA_ONCE */ #include "tao/LocalObject.h" -#include "ace/OS_NS_Thread.h" #include "ace/Reactor.h" #include "ace/Task.h" @@ -25,7 +24,6 @@ namespace CIAO_LOBO_Test_Receiver_Impl typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::ULong> Atomic_ULong; typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, bool> Atomic_Bool; - typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, ACE_thread_t> Atomic_ThreadId; //============================================================ // ListenOneByOneTest_Listener_exec_i @@ -37,8 +35,7 @@ namespace CIAO_LOBO_Test_Receiver_Impl public: ListenOneByOneTest_Listener_exec_i ( Atomic_ULong &received_one_by_one, - Atomic_ULong &received_many_by_many, - Atomic_ThreadId &thread_id); + Atomic_ULong &received_many_by_many); virtual ~ListenOneByOneTest_Listener_exec_i (void); virtual void @@ -52,7 +49,39 @@ namespace CIAO_LOBO_Test_Receiver_Impl private: Atomic_ULong &received_one_by_one_; Atomic_ULong &received_many_by_many_; - Atomic_ThreadId &thread_id_; + }; + + //============================================================ + // ConnectorStatusListener_exec_i + //============================================================ + class RECEIVER_EXEC_Export ConnectorStatusListener_exec_i + : public virtual ::CCM_DDS::CCM_ConnectorStatusListener, + public virtual ::CORBA::LocalObject + { + public: + ConnectorStatusListener_exec_i (Receiver_exec_i &callback); + virtual ~ConnectorStatusListener_exec_i (void); + + virtual + void on_inconsistent_topic( ::DDS::Topic_ptr , + const DDS::InconsistentTopicStatus & ); + virtual + void on_requested_incompatible_qos( ::DDS::DataReader_ptr , + const DDS::RequestedIncompatibleQosStatus & ); + virtual + void on_sample_rejected( ::DDS::DataReader_ptr , + const DDS::SampleRejectedStatus & ); + virtual + void on_offered_deadline_missed( ::DDS::DataWriter_ptr , + const DDS::OfferedDeadlineMissedStatus & ); + virtual + void on_offered_incompatible_qos( ::DDS::DataWriter_ptr , + const DDS::OfferedIncompatibleQosStatus & ); + virtual + void on_unexpected_status( ::DDS::Entity_ptr , + ::DDS::StatusKind ); + private: + Receiver_exec_i &callback_; }; //============================================================ @@ -98,9 +127,9 @@ namespace CIAO_LOBO_Test_Receiver_Impl private: ::LOBO_Test::CCM_Receiver_Context_var context_; - Atomic_ULong received_one_by_one_; - Atomic_ULong received_many_by_many_; - Atomic_ThreadId thread_id_listener_; + Atomic_ULong received_one_by_one_; + Atomic_ULong received_many_by_many_; + Atomic_Bool started_; CORBA::UShort iterations_; CORBA::UShort keys_; |