diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Receiver/CSL_USTest_Receiver_exec.h')
| -rw-r--r-- | CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Receiver/CSL_USTest_Receiver_exec.h | 120 |
1 files changed, 44 insertions, 76 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Receiver/CSL_USTest_Receiver_exec.h b/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Receiver/CSL_USTest_Receiver_exec.h index e351f24a8b3..34f2f251151 100644 --- a/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Receiver/CSL_USTest_Receiver_exec.h +++ b/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Receiver/CSL_USTest_Receiver_exec.h @@ -20,37 +20,16 @@ namespace CIAO_CSL_USTest_Receiver_Impl { typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::ULong > Atomic_ULong; typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::Boolean > Atomic_Boolean; - typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, ACE_thread_t> Atomic_ThreadId; - class Receiver_exec_i; - //============================================================ - // Pulser - //============================================================ - class Pulser : - public ACE_Event_Handler - { - public: - Pulser (Receiver_exec_i &callback); - - virtual int handle_timeout (const ACE_Time_Value &tv, - const void *arg); - private: - Receiver_exec_i &callback_; - }; - - //============================================================ - // TestTopic_RawListener_exec_i - //============================================================ class RECEIVER_EXEC_Export TestTopic_RawListener_exec_i - : public virtual ::CSL_USTest::TestTopicConn::CCM_Listener, + : public virtual ::CCM_DDS::TestTopic::CCM_Listener, public virtual ::CORBA::LocalObject { public: - TestTopic_RawListener_exec_i (Atomic_ULong &, - Receiver_exec_i &callback); + TestTopic_RawListener_exec_i (Atomic_ULong &); virtual ~TestTopic_RawListener_exec_i (void); - + virtual void on_one_data ( const TestTopic & an_instance, @@ -59,41 +38,31 @@ namespace CIAO_CSL_USTest_Receiver_Impl virtual void on_many_data ( const ::TestTopic_Seq & data, - const ::CCM_DDS::ReadInfoSeq & info); + const ::CCM_DDS::ReadInfoSeq & info ); private: Atomic_ULong &received_; - Receiver_exec_i &callback_; }; - - //============================================================ - // ConnectorStatusListener_exec_i - //============================================================ - class RECEIVER_EXEC_Export ConnectorStatusListener_exec_i + +class RECEIVER_EXEC_Export ConnectorStatusListener_exec_i : public virtual ::CCM_DDS::CCM_ConnectorStatusListener, public virtual ::CORBA::LocalObject { public: - ConnectorStatusListener_exec_i (Atomic_Boolean &, - Atomic_Boolean &, - Atomic_Boolean &, - Atomic_ThreadId &, - Atomic_ThreadId &, - Atomic_ThreadId &); - + ConnectorStatusListener_exec_i (Atomic_Boolean &,Atomic_Boolean &); virtual ~ConnectorStatusListener_exec_i (void); - + virtual - void on_inconsistent_topic (::DDS::Topic_ptr the_topic, + void on_inconsistent_topic( ::DDS::Topic_ptr the_topic, const DDS::InconsistentTopicStatus & status); virtual - void on_requested_incompatible_qos (::DDS::DataReader_ptr the_reader, + void on_requested_incompatible_qos( ::DDS::DataReader_ptr the_reader, const DDS::RequestedIncompatibleQosStatus & status); virtual - void on_sample_rejected (::DDS::DataReader_ptr the_reader, + void on_sample_rejected( ::DDS::DataReader_ptr the_reader, const DDS::SampleRejectedStatus & status); virtual - void on_offered_deadline_missed (::DDS::DataWriter_ptr the_writer, + void on_offered_deadline_missed( ::DDS::DataWriter_ptr the_writer, const DDS::OfferedDeadlineMissedStatus & status); virtual void on_offered_incompatible_qos( ::DDS::DataWriter_ptr the_writer, @@ -103,17 +72,30 @@ namespace CIAO_CSL_USTest_Receiver_Impl ::DDS::StatusKind status_kind); private: - Atomic_Boolean &subscription_matched_received_; - Atomic_Boolean &publication_matched_received_; - Atomic_Boolean &liveliness_changed_received_; - Atomic_ThreadId &thread_id_subcription_matched_; - Atomic_ThreadId &thread_id_publication_matched_; - Atomic_ThreadId &thread_id_liveliness_changed_; + Atomic_Boolean &unexpected_matched_; + Atomic_Boolean &unexpected_liveliness_; + + }; + +class RECEIVER_EXEC_Export PortStatusListener_exec_i + : public virtual ::CCM_DDS::CCM_PortStatusListener, + public virtual ::CORBA::LocalObject + { + public: + PortStatusListener_exec_i (void); + virtual ~PortStatusListener_exec_i (void); + + virtual void + on_requested_deadline_missed ( + ::DDS::DataReader_ptr the_reader, + const ::DDS::RequestedDeadlineMissedStatus & status); + + virtual void + on_sample_lost ( + ::DDS::DataReader_ptr the_reader, + const ::DDS::SampleLostStatus & status); }; - //============================================================ - // Receiver_exec_i - //============================================================ class RECEIVER_EXEC_Export Receiver_exec_i : public virtual Receiver_Exec, public virtual ::CORBA::LocalObject @@ -122,24 +104,18 @@ namespace CIAO_CSL_USTest_Receiver_Impl Receiver_exec_i (void); virtual ~Receiver_exec_i (void); - // Supported operations and attributes. - void stop (void); - void start (void); - void read_all (void); - + // Supported operations and attributes. + // Port operations. - virtual ::CCM_DDS::CCM_PortStatusListener_ptr - get_info_out_status (void); - - virtual ::CSL_USTest::TestTopicConn::CCM_Listener_ptr + virtual ::CCM_DDS::TestTopic::CCM_Listener_ptr get_info_out_data_listener (void); + virtual ::CCM_DDS::CCM_PortStatusListener_ptr + get_info_out_status (void); + virtual ::CCM_DDS::CCM_ConnectorStatusListener_ptr get_info_out_connector_status (void); - - virtual ::CCM_DDS::CCM_PortStatusListener_ptr - get_info_read_status (void); - + // Operations from Components::SessionComponent. virtual void set_session_context ( @@ -152,18 +128,10 @@ namespace CIAO_CSL_USTest_Receiver_Impl private: ::CSL_USTest::CCM_Receiver_Context_var context_; - ::CCM_DDS::DataListenerControl_var lc_; - ::CSL_USTest::TestTopicConn::Reader_var reader_; - - Pulser *pulser_; - - Atomic_Boolean subscription_matched_received_; - Atomic_Boolean publication_matched_received_; - Atomic_Boolean liveliness_changed_received_; - Atomic_ThreadId thread_id_listener_subscription_matched_; - Atomic_ThreadId thread_id_listener_publication_matched_; - Atomic_ThreadId thread_id_listener_liveliness_changed_; + Atomic_Boolean unexpected_matched_; + Atomic_Boolean unexpected_liveliness_; Atomic_ULong received_; + ::CCM_DDS::TestTopic::Reader_var reader_; }; extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr |