diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/FixedSizeStruct/EventConnector/Receiver/FSS_Event_Receiver_exec.cpp')
| -rw-r--r-- | CIAO/connectors/dds4ccm/tests/FixedSizeStruct/EventConnector/Receiver/FSS_Event_Receiver_exec.cpp | 260 |
1 files changed, 0 insertions, 260 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/FixedSizeStruct/EventConnector/Receiver/FSS_Event_Receiver_exec.cpp b/CIAO/connectors/dds4ccm/tests/FixedSizeStruct/EventConnector/Receiver/FSS_Event_Receiver_exec.cpp deleted file mode 100644 index 780998fda8c..00000000000 --- a/CIAO/connectors/dds4ccm/tests/FixedSizeStruct/EventConnector/Receiver/FSS_Event_Receiver_exec.cpp +++ /dev/null @@ -1,260 +0,0 @@ -// -*- C++ -*- -// -// $Id$ - -#include "FSS_Event_Receiver_exec.h" -#include "ciao/Logger/Log_Macros.h" - -namespace CIAO_FSS_Event_Receiver_Impl -{ - //============================================================ - // FixedStructSizeTest_Listener_exec_i - //============================================================ - FixedStructSizeTest_Listener_exec_i::FixedStructSizeTest_Listener_exec_i ( - Atomic_ULong &received_one_by_one, - Atomic_ULong &received_many_by_many, - Atomic_ThreadId &thread_id) - : received_one_by_one_ (received_one_by_one), - received_many_by_many_ (received_many_by_many), - thread_id_ (thread_id) - { - } - - FixedStructSizeTest_Listener_exec_i::~FixedStructSizeTest_Listener_exec_i (void) - { - } - - void - FixedStructSizeTest_Listener_exec_i::on_one_data ( - const FixedStructSizeTest & an_instance, - const ::CCM_DDS::ReadInfo & info) - { - this->thread_id_ = ACE_Thread::self (); - ACE_DEBUG ((LM_DEBUG, "FixedStructSizeTest_Listener_exec_i::on_one_data: " - "key <%u> - iteration <%u>\n", - an_instance.one, - an_instance.two)); - if (!info.instance_handle.isValid) - { - ACE_ERROR ((LM_ERROR, "ERROR: FixedStructSizeTest_Listener_exec_i::on_one_data: " - "instance handle seems to be invalid " - "key <%u> - iteration <%u>\n", - an_instance.one, - an_instance.two)); - } - if (info.source_timestamp.sec == 0 && - info.source_timestamp.nanosec == 0) - { - ACE_ERROR ((LM_ERROR, "ERROR: FixedStructSizeTest_Listener_exec_i::on_one_data: " - "source timestamp seems to be invalid (nil) " - "key <%u> - iteration <%u>\n", - an_instance.one, - an_instance.two)); - } - ++this->received_one_by_one_; - } - - void - FixedStructSizeTest_Listener_exec_i::on_many_data ( - const FixedStructSizeTest_Seq & an_instance, - const ::CCM_DDS::ReadInfoSeq & /*info*/) - { - //just count. Is checked on ccm_remove. - this->received_many_by_many_ += an_instance.length (); - } - - //============================================================ - // Receiver_exec_i - //============================================================ - Receiver_exec_i::Receiver_exec_i (void) - : received_one_by_one_ (0), - received_many_by_many_ (0), - thread_id_listener_ (0), - iterations_ (10), - keys_ (5) - { - } - - Receiver_exec_i::~Receiver_exec_i (void) - { - } - - void - Receiver_exec_i::start () - { - ::CCM_DDS::DataListenerControl_var dlc = - this->context_->get_connection_info_listen_data_control (); - dlc->mode (::CCM_DDS::ONE_BY_ONE); - } - - ::FSS_Event::FixedStructSizeTestConn::CCM_Listener_ptr - Receiver_exec_i::get_info_listen_data_listener (void) - { - return new FixedStructSizeTest_Listener_exec_i ( - this->received_one_by_one_, - this->received_many_by_many_, - this->thread_id_listener_); - } - - ::CCM_DDS::CCM_PortStatusListener_ptr - Receiver_exec_i::get_info_listen_status (void) - { - return ::CCM_DDS::CCM_PortStatusListener::_nil (); - } - - ::CCM_DDS::CCM_ConnectorStatusListener_ptr - Receiver_exec_i::get_info_listen_connector_status (void) - { - return ::CCM_DDS::CCM_ConnectorStatusListener::_nil (); - } - - ::CORBA::UShort - Receiver_exec_i::iterations (void) - { - return this->iterations_; - } - - void - Receiver_exec_i::iterations (::CORBA::UShort iterations) - { - this->iterations_ = iterations; - } - - ::CORBA::UShort - Receiver_exec_i::keys (void) - { - return this->keys_; - } - - void - Receiver_exec_i::keys (::CORBA::UShort keys) - { - this->keys_ = keys; - } - - void - Receiver_exec_i::set_session_context ( - ::Components::SessionContext_ptr ctx) - { - this->context_ = - ::FSS_Event::CCM_Receiver_Context::_narrow (ctx); - if ( ::CORBA::is_nil (this->context_.in ())) - { - throw ::CORBA::INTERNAL (); - } - } - - void - Receiver_exec_i::configuration_complete (void) - { - } - - void - Receiver_exec_i::ccm_activate (void) - { - start (); - } - - void - Receiver_exec_i::ccm_passivate (void) - { - } - - void - Receiver_exec_i::ccm_remove (void) - { - CORBA::ULong expected = this->keys_ * this->iterations_; - if (this->received_one_by_one_.value () == 0) - { - ACE_ERROR ((LM_ERROR, "ERROR: ONE_BY_ONE: " - "Didn't receive samples on one_by_one " - "callback while mode is ONE_BY_ONE " - "expected <%u> - received <%u>\n", - expected, - this->received_one_by_one_.value ())); - } - else if (expected != this->received_one_by_one_.value ()) - { - ACE_ERROR ((LM_ERROR, "ERROR: ONE_BY_ONE: " - "Didn't receive the expected " - "number of samples on one_by_one " - "callback while mode is ONE_BY_ONE " - "expected <%u> - received <%u>\n", - expected, - this->received_one_by_one_.value ())); - } - if (this->received_many_by_many_.value () > 0) - { - ACE_ERROR ((LM_ERROR, "ERROR: ONE_BY_ONE: " - "Received samples on many_by_many " - "callback while mode is ONE_BY_ONE " - "expected <0> - received <%u>\n", - this->received_many_by_many_.value ())); - } - if (this->received_one_by_one_.value () > 0 && - this->received_many_by_many_.value () == 0) - { - ACE_DEBUG ((LM_DEBUG, "ONE_BY_ONE: " - "Received only data on " - "one_by_one callback. " - "Test passed!\n")); - } - if (this->thread_id_listener_.value () == 0) - { - ACE_ERROR ((LM_ERROR, "ERROR: " - "Thread ID for ReaderListener not set!\n")); - } - #if defined (CIAO_DDS4CCM_CONTEXT_SWITCH) && (CIAO_DDS4CCM_CONTEXT_SWITCH == 1) - else if (ACE_OS::thr_equal (this->thread_id_listener_.value (), - ACE_Thread::self ())) - { - ACE_DEBUG ((LM_DEBUG, "ONE_BY_ONE: " - "Thread switch for ReaderListener seems OK. " - "(DDS uses the CCM thread for its callback) " - "listener <%u> - component <%u>\n", - this->thread_id_listener_.value (), - ACE_Thread::self ())); - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR: ONE_BY_ONE: " - "Thread switch for ReaderListener " - "doesn't seem to work! " - "listener <%u> - component <%u>\n", - this->thread_id_listener_.value (), - ACE_Thread::self ())); - } - #else - else if (ACE_OS::thr_equal (this->thread_id_listener_.value (), - ACE_Thread::self ())) - { - ACE_ERROR ((LM_ERROR, "ERROR: ONE_BY_ONE: ReaderListener: " - "DDS seems to use a CCM thread for its callback: " - "listener <%u> - component <%u>\n", - this->thread_id_listener_.value (), - ACE_Thread::self ())); - } - else - { - ACE_DEBUG ((LM_DEBUG, "ONE_BY_ONE: ReaderListener: " - "DDS seems to use its own thread for its callback: " - "listener <%u> - component <%u>\n", - this->thread_id_listener_.value (), - ACE_Thread::self ())); - } - #endif - } - - extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_FSS_Event_Receiver_Impl (void) - { - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - - ACE_NEW_NORETURN ( - retval, - Receiver_exec_i); - - return retval; - } -} |