diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2016-04-19 19:34:09 +0200 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2016-04-19 19:34:09 +0200 |
commit | 67fe053a4b2cd800bb0c12f546420fb358b86608 (patch) | |
tree | 23a13116f12541b9eee310f575086c0b7a994ad7 /CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.cpp | |
parent | fd904693d47bc0f9c3c110e1b6beff016581926d (diff) | |
download | ATCD-67fe053a4b2cd800bb0c12f546420fb358b86608.tar.gz |
Remove CIAO/DAnCE here because they are migrated to their own repositories
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.cpp')
-rw-r--r-- | CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.cpp | 266 |
1 files changed, 0 insertions, 266 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.cpp b/CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.cpp deleted file mode 100644 index ac725d4923d..00000000000 --- a/CIAO/connectors/dds4ccm/tests/ListenOneByOne/Receiver/LOBO_Test_Receiver_exec.cpp +++ /dev/null @@ -1,266 +0,0 @@ -// -*- C++ -*- -#include "LOBO_Test_Receiver_exec.h" -#include "ace/Log_Msg.h" -#include "dds4ccm/impl/dds4ccm_conf.h" - -namespace CIAO_LOBO_Test_Receiver_Impl -{ - //============================================================ - // ListenOneByOneTest_Listener_exec_i - //============================================================ - ListenOneByOneTest_Listener_exec_i::ListenOneByOneTest_Listener_exec_i ( - Atomic_ULong &received_one_by_one, - Atomic_ULong &received_many_by_many, - ACE_Thread_ID &thread_id) - : received_one_by_one_ (received_one_by_one), - received_many_by_many_ (received_many_by_many), - thread_id_ (thread_id) - { - } - - ListenOneByOneTest_Listener_exec_i::~ListenOneByOneTest_Listener_exec_i (void) - { - } - - void - ListenOneByOneTest_Listener_exec_i::on_one_data ( - const ListenOneByOneTest & an_instance, - const ::CCM_DDS::ReadInfo & info) - { - ACE_Thread_ID t_id; - this->thread_id_ = t_id; - - ACE_DEBUG ((LM_DEBUG, "ListenOneByOneTest_Listener_exec_i::on_one_data: " - "key <%C> - iteration <%d>\n", - an_instance.key.in (), - an_instance.iteration)); - if (info.instance_handle == ::DDS::HANDLE_NIL) - { - ACE_ERROR ((LM_ERROR, "ERROR: ListenOneByOneTest_Listener_exec_i::on_one_data: " - "instance handle seems to be nil " - "key <%C> - iteration <%d>\n", - an_instance.key.in (), - an_instance.iteration)); - } - if (info.source_timestamp.sec == 0 && - info.source_timestamp.nanosec == 0) - { - ACE_ERROR ((LM_ERROR, "ERROR: ListenOneByOneTest_Listener_exec_i::on_one_data: " - "source timestamp seems to be nil (nil) " - "key <%C> - iteration <%d>\n", - an_instance.key.in (), - an_instance.iteration)); - } - ++this->received_one_by_one_; - } - - void - ListenOneByOneTest_Listener_exec_i::on_many_data ( - const ListenOneByOneTestSeq & 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, 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); - } - - ::LOBO_Test::ListenOneByOneTestConnector::CCM_Listener_ptr - Receiver_exec_i::get_info_listen_data_listener (void) - { - return new ListenOneByOneTest_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_ = - ::LOBO_Test::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")); - } - //get current thread - char ccm_buf [65]; - ACE_Thread_ID ccm_thread_id; - ccm_thread_id.to_string (ccm_buf); - - char list_buf [65]; - this->thread_id_listener_.to_string (list_buf); - - if (this->thread_id_listener_.id () == 0) - { - ACE_ERROR ((LM_ERROR, "ERROR: " - "Thread ID for ReaderListener not set!\n")); - } - #if (CIAO_DDS4CCM_CONTEXT_SWITCH == 1) - else if (this->thread_id_listener_ == ccm_thread_id) - { - ACE_DEBUG ((LM_DEBUG, "ONE_BY_ONE: " - "Thread switch for ReaderListener seems OK. " - "(DDS uses the CCM thread for its callback) " - "listener <%C> - component <%C>\n", - list_buf, - ccm_buf)); - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR: ONE_BY_ONE: " - "Thread switch for ReaderListener " - "doesn't seem to work! " - "listener <%C> - component <%C>\n", - list_buf, - ccm_buf)); - } - #else - else if (this->thread_id_listener_ == ccm_thread_id) - { - ACE_ERROR ((LM_ERROR, "ERROR: ONE_BY_ONE: ReaderListener: " - "DDS seems to use a CCM thread for its callback: " - "listener <%C> - component <%C>\n", - list_buf, - ccm_buf)); - } - else - { - ACE_DEBUG ((LM_DEBUG, "ONE_BY_ONE: ReaderListener: " - "DDS seems to use its own thread for its callback: " - "listener <%C> - component <%C>\n", - list_buf, - ccm_buf)); - } - #endif - } - - extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_LOBO_Test_Receiver_Impl (void) - { - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - - ACE_NEW_NORETURN ( - retval, - Receiver_exec_i); - - return retval; - } -} |