summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Sender/CSL_USTest_Sender_exec.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Sender/CSL_USTest_Sender_exec.cpp')
-rw-r--r--CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Sender/CSL_USTest_Sender_exec.cpp495
1 files changed, 49 insertions, 446 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Sender/CSL_USTest_Sender_exec.cpp b/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Sender/CSL_USTest_Sender_exec.cpp
index d16f7c1e436..88c136904ed 100644
--- a/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Sender/CSL_USTest_Sender_exec.cpp
+++ b/CIAO/connectors/dds4ccm/tests/CSLUnexpStat/Sender/CSL_USTest_Sender_exec.cpp
@@ -13,44 +13,11 @@
namespace CIAO_CSL_USTest_Sender_Impl
{
//============================================================
- // pulse_Generator
+ // Facet Executor Implementation Class: ConnectorStatusListener_exec_i
//============================================================
- pulse_Generator::pulse_Generator (Sender_exec_i &callback)
- : pulse_callback_ (callback)
- {
- }
-
- int
- pulse_Generator::handle_timeout (const ACE_Time_Value &, const void *)
- {
- // Notify the subscribers
- this->pulse_callback_.tick ();
- return 0;
- }
-
- //============================================================
- // ConnectorStatusListener_exec_i
- //============================================================
- ConnectorStatusListener_exec_i::ConnectorStatusListener_exec_i (Atomic_Boolean &subscription_matched_received,
- Atomic_Boolean &publication_matched_received,
- Atomic_Boolean &liveliness_changed_received,
- Atomic_Boolean &liveliness_lost_received,
- Atomic_Boolean &reliable_dr_activity_changed_received,
- Atomic_ThreadId &thread_id_subcription_matched,
- Atomic_ThreadId &thread_id_publication_matched,
- Atomic_ThreadId &thread_id_liveliness_changed,
- Atomic_ThreadId &thread_id_liveliness_lost,
- Atomic_ThreadId &thread_id_reliable_dr_activity_changed)
- : subscription_matched_received_ (subscription_matched_received),
- publication_matched_received_ (publication_matched_received),
- liveliness_changed_received_ (liveliness_changed_received),
- liveliness_lost_received_ (liveliness_lost_received),
- reliable_dr_activity_changed_received_ (reliable_dr_activity_changed_received),
- thread_id_subcription_matched_ (thread_id_subcription_matched),
- thread_id_publication_matched_ (thread_id_publication_matched),
- thread_id_liveliness_changed_ (thread_id_liveliness_changed),
- thread_id_liveliness_lost_ (thread_id_liveliness_lost),
- thread_id_reliable_dr_activity_changed_ (thread_id_reliable_dr_activity_changed)
+ ConnectorStatusListener_exec_i::ConnectorStatusListener_exec_i (Atomic_Boolean &unexpected_matched, Atomic_Boolean &unexpected_liveliness)
+ : unexpected_matched_ (unexpected_matched),
+ unexpected_liveliness_ (unexpected_liveliness)
{
}
@@ -59,84 +26,53 @@ namespace CIAO_CSL_USTest_Sender_Impl
}
// Operations from ::CCM_DDS::ConnectorStatusListener
- void ConnectorStatusListener_exec_i::on_inconsistent_topic (
+ void ConnectorStatusListener_exec_i::on_inconsistent_topic(
::DDS::Topic_ptr /*the_topic*/,
const DDS::InconsistentTopicStatus & /*status*/)
- {
- }
+ {
+ }
- void ConnectorStatusListener_exec_i::on_requested_incompatible_qos (
+ void ConnectorStatusListener_exec_i::on_requested_incompatible_qos(
::DDS::DataReader_ptr /*the_reader*/,
- const DDS::RequestedIncompatibleQosStatus & /*status*/)
- {
- }
+ const DDS::RequestedIncompatibleQosStatus & /*status*/) {
+ }
- void ConnectorStatusListener_exec_i::on_sample_rejected (
+ void ConnectorStatusListener_exec_i::on_sample_rejected(
::DDS::DataReader_ptr /*the_reader*/,
- const DDS::SampleRejectedStatus & /*status*/)
- {
- }
+ const DDS::SampleRejectedStatus & /*status*/) {
+ }
- void ConnectorStatusListener_exec_i::on_offered_deadline_missed (
+ void ConnectorStatusListener_exec_i::on_offered_deadline_missed(
::DDS::DataWriter_ptr /*the_writer*/,
- const DDS::OfferedDeadlineMissedStatus & /*status*/)
- {
- }
+ const DDS::OfferedDeadlineMissedStatus & /*status*/) {
+ }
- void ConnectorStatusListener_exec_i::on_offered_incompatible_qos (
+ void ConnectorStatusListener_exec_i::on_offered_incompatible_qos(
::DDS::DataWriter_ptr /*the_writer*/,
- const DDS::OfferedIncompatibleQosStatus & /*status*/)
- {
- }
+ const DDS::OfferedIncompatibleQosStatus & /*status*/) {
+ }
- void ConnectorStatusListener_exec_i::on_unexpected_status (
+ void ConnectorStatusListener_exec_i::on_unexpected_status(
::DDS::Entity_ptr the_entity,
- ::DDS::StatusKind status_kind)
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER\t\tConnectorStatusListener_exec_i::on_unexpected_status: "
- "received <%C>\n",
- CIAO::DDS4CCM::translate_statuskind (status_kind)));
-
- if (!CORBA::is_nil (the_entity) && status_kind == DDS::SUBSCRIPTION_MATCHED_STATUS)
- {
- this->subscription_matched_received_ = true;
- this->thread_id_subcription_matched_ = ACE_Thread::self ();
- }
- else if (!CORBA::is_nil(the_entity) && status_kind == DDS::LIVELINESS_CHANGED_STATUS)
- {
- this->liveliness_changed_received_ = true;
- this->thread_id_liveliness_changed_ = ACE_Thread::self ();
- }
- else if (!CORBA::is_nil(the_entity) && status_kind == DDS::LIVELINESS_LOST_STATUS)
+ ::DDS::StatusKind status_kind) {
+ CORBA::ULong kind = status_kind;
+ if((!CORBA::is_nil(the_entity)) && (kind==DDS::PUBLICATION_MATCHED_STATUS))
{
- this->liveliness_lost_received_ = true;
- this->thread_id_liveliness_lost_ = ACE_Thread::self ();
+ this->unexpected_matched_ = true;
}
- else if (!CORBA::is_nil(the_entity) && status_kind == DDS::PUBLICATION_MATCHED_STATUS)
+ if((!CORBA::is_nil(the_entity)) && (kind==DDS::LIVELINESS_CHANGED_STATUS))
{
- this->publication_matched_received_ = true;
- this->thread_id_publication_matched_ = ACE_Thread::self ();
+ this->unexpected_liveliness_ = true;
}
- else if (!CORBA::is_nil(the_entity) && status_kind == DDS::RELIABLE_READER_ACTIVITY_CHANGED_STATUS)
- {
- this->reliable_dr_activity_changed_received_ = true;
- this->thread_id_reliable_dr_activity_changed_ = ACE_Thread::self ();
- }
- }
-
+ }
//============================================================
- // Sender_exec_i
+ // Component Executor Implementation Class: Sender_exec_i
//============================================================
+
Sender_exec_i::Sender_exec_i (void)
- : subscription_matched_received_ (false),
- publication_matched_received_ (false),
- liveliness_changed_received_ (false),
- liveliness_lost_received_ (false),
- thread_id_listener_subscription_matched_ (0),
- thread_id_listener_publication_matched_ (0),
- thread_id_listener_liveliness_lost_ (0)
+ : unexpected_matched_ (false),
+ unexpected_liveliness_ (false)
{
- this->ticker_ = new pulse_Generator (*this);
}
Sender_exec_i::~Sender_exec_i (void)
@@ -146,55 +82,7 @@ namespace CIAO_CSL_USTest_Sender_Impl
::CCM_DDS::CCM_ConnectorStatusListener_ptr
Sender_exec_i::get_test_topic_connector_status (void)
{
- return new ConnectorStatusListener_exec_i (this->subscription_matched_received_,
- this->publication_matched_received_,
- this->liveliness_changed_received_,
- this->liveliness_lost_received_,
- this->reliable_dr_activity_changed_received_,
- this->thread_id_listener_subscription_matched_,
- this->thread_id_listener_publication_matched_,
- this->thread_id_listener_liveliness_changed_,
- this->thread_id_listener_liveliness_lost_,
- this->thread_id_reliable_dr_activity_changed_);
- }
-
- // Supported operations and attributes.
- void
- Sender_exec_i::tick ()
- {
- for (CSL_SRTest_Table::iterator i = this->_ktests_.begin ();
- i != this->_ktests_.end ();
- ++i)
- {
- try
- {
- if (!CORBA::is_nil (this->writer_))
- {
- this->writer_->write_one(i->second,::DDS::HANDLE_NIL);
- ACE_DEBUG ((LM_DEBUG, "Written sample: <%C> - <%d>\n",
- i->first.c_str (),
- i->second->x));
- i->second->x++;
- }
- else ACE_ERROR ((LM_ERROR, "Unable to write sample: <%C> - <%d>\n",
- i->first.c_str (),
- i->second->x));
- }
- catch (const CCM_DDS::InternalError& )
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("Internal Error while creating topic for <%C>.\n"),
- i->first.c_str ()));
- }
- }
- }
-
- void
- Sender_exec_i::add_instance_of_topic (const char * key, int x)
- {
- TestTopic *new_key = new TestTopic;
- new_key->key = CORBA::string_dup(key);
- new_key->x = x;
- this->_ktests_[key] = new_key;
+ return new ConnectorStatusListener_exec_i (this->unexpected_matched_,this->unexpected_liveliness_);
}
// Supported operations and attributes.
@@ -203,7 +91,7 @@ namespace CIAO_CSL_USTest_Sender_Impl
{
this->context_ = ::CSL_USTest::CCM_Sender_Context::_narrow (ctx);
- if (::CORBA::is_nil (this->context_.in ()))
+ if ( ::CORBA::is_nil (this->context_.in ()))
{
throw ::CORBA::INTERNAL ();
}
@@ -216,326 +104,41 @@ namespace CIAO_CSL_USTest_Sender_Impl
}
void
+ Sender_exec_i::add_instance_of_topic (const char * key, int x)
+ {
+ TestTopic *new_key = new TestTopic;
+ new_key->key = CORBA::string_dup(key);
+ new_key->x = x;
+ this->_ktests_[key] = new_key;
+ }
+ void
Sender_exec_i::ccm_activate (void)
{
//add 2 different instances of topic
- this->add_instance_of_topic ("ONE", 1);
- this->add_instance_of_topic ("TWO", 2);
- // calculate the interval time
- if (this->context_->get_CCM_object()->_get_orb ()->orb_core ()->reactor ()->schedule_timer (
- this->ticker_,
- 0,
- ACE_Time_Value (3, 0),
- ACE_Time_Value (1, 0)) == -1)
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("Sender_exec_i::start : ")
- ACE_TEXT ("Error scheduling timer\n")));
- }
- }
+ this->add_instance_of_topic ("ONE",1);
+ this->add_instance_of_topic ("TWO",2);
+ }
void
Sender_exec_i::ccm_passivate (void)
{
- this->context_->get_CCM_object()->_get_orb ()->orb_core ()->reactor ()->cancel_timer (this->ticker_);
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Sender_exec_i::stop : Timer canceled.\n")));
- delete this->ticker_;
}
void
Sender_exec_i::ccm_remove (void)
{
- if (!this->subscription_matched_received_.value ())
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("SENDER ERROR: Didn't receive the expected ")
- ACE_TEXT ("'SUBSCRIPTION_MATCHED_STATUS'\n")
- ));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("SENDER OK: Received the expected ")
- ACE_TEXT ("'SUBSCRIPTION_MATCHED_STATUS'\n")
- ));
- }
- if (!this->publication_matched_received_.value ())
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("SENDER ERROR: Didn't receive the expected ")
- ACE_TEXT ("'PUBLICATION_MATCHED_STATUS'\n")
- ));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("SENDER OK: Received the expected ")
- ACE_TEXT ("'PUBLICATION_MATCHED_STATUS'\n")
- ));
- }
- if (!this->liveliness_changed_received_.value ())
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("SENDER ERROR: Didn't receive the expected ")
- ACE_TEXT ("'LIVELINESS_CHANGED_STATUS'\n")
- ));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("SENDER OK: Received the expected ")
- ACE_TEXT ("'LIVELINESS_CHANGED_STATUS'\n")
- ));
- }
- if (!this->liveliness_lost_received_.value ())
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("SENDER ERROR: Didn't receive the expected ")
- ACE_TEXT ("'LIVELINESS_LOST_STATUS'\n")
- ));
- }
- else
+ if(!this->unexpected_matched_.value () || !this->unexpected_liveliness_.value ())
{
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("SENDER OK: Received the expected ")
- ACE_TEXT ("'LIVELINESS_LOST_STATUS'\n")
- ));
- }
- if (!this->reliable_dr_activity_changed_received_.value ())
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("SENDER ERROR: Didn't receive the expected ")
- ACE_TEXT ("'RELIABLE_READER_ACTIVITY_CHANGED_STATUS'\n")
+ ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: did not receive the expected ")
+ ACE_TEXT ("states 'PUBLICATION_MATCHED_STATUS and/or LIVELINESS_CHANGED_STATUS' in Sender\n")
));
}
else
{
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("SENDER OK: Received the expected ")
- ACE_TEXT ("'RELIABLE_READER_ACTIVITY_CHANGED_STATUS'\n")
+ ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Received the expected ")
+ ACE_TEXT ("'LIVELINESS_CHANGED_STATUS' and 'PUBLICATION_MATCHED_STATUS' in Sender\n")
));
}
-
- //test thread switch for SUBSCRIPTION_MATCHED_STATUS
- if (this->thread_id_listener_subscription_matched_.value () == 0)
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread ID for 'SUBSCRIPTION_MATCHED_STATUS' not set!\n"));
- }
- #if defined (CIAO_DDS4CCM_CONTEXT_SWITCH) && (CIAO_DDS4CCM_CONTEXT_SWITCH == 1)
- else if (ACE_OS::thr_equal (this->thread_id_listener_subscription_matched_.value (),
- ACE_Thread::self ()))
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: "
- "Thread switch for 'SUBSCRIPTION_MATCHED_STATUS' seems OK. "
- "(DDS uses the CCM thread for its callback) "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_subscription_matched_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread switch for 'SUBSCRIPTION_MATCHED_STATUS' "
- "doesn't seem to work! "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_subscription_matched_.value (),
- ACE_Thread::self ()));
- }
- #else
- else if (ACE_OS::thr_equal (this->thread_id_listener_subscription_matched_.value (),
- ACE_Thread::self ()))
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: 'SUBSCRIPTION_MATCHED_STATUS': "
- "DDS seems to use a CCM thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_subscription_matched_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: 'SUBSCRIPTION_MATCHED_STATUS': "
- "DDS seems to use its own thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_subscription_matched_.value (),
- ACE_Thread::self ()));
- }
- #endif
-
- //test thread switch for PUBLICATION_MATCHED_STATUS
- if (this->thread_id_listener_publication_matched_.value () == 0)
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread ID for 'PUBLICATION_MATCHED_STATUS' not set!\n"));
- }
- #if defined (CIAO_DDS4CCM_CONTEXT_SWITCH) && (CIAO_DDS4CCM_CONTEXT_SWITCH == 1)
- else if (ACE_OS::thr_equal (this->thread_id_listener_publication_matched_.value (),
- ACE_Thread::self ()))
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: "
- "Thread switch for 'PUBLICATION_MATCHED_STATUS' seems OK. "
- "(DDS uses the CCM thread for its callback) "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_publication_matched_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread switch for 'PUBLICATION_MATCHED_STATUS' "
- "doesn't seem to work! "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_publication_matched_.value (),
- ACE_Thread::self ()));
- }
- #else
- else if (ACE_OS::thr_equal (this->thread_id_listener_publication_matched_.value (),
- ACE_Thread::self ()))
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: 'PUBLICATION_MATCHED_STATUS': "
- "DDS seems to use a CCM thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_publication_matched_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: 'PUBLICATION_MATCHED_STATUS': "
- "DDS seems to use its own thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_publication_matched_.value (),
- ACE_Thread::self ()));
- }
- #endif
-
- //test thread switch for LIVELINESS_CHANGED_STATUS
- if (this->thread_id_listener_liveliness_changed_.value () == 0)
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread ID for 'LIVELINESS_CHANGED_STATUS' not set!\n"));
- }
- #if defined (CIAO_DDS4CCM_CONTEXT_SWITCH) && (CIAO_DDS4CCM_CONTEXT_SWITCH == 1)
- else if (ACE_OS::thr_equal (this->thread_id_listener_liveliness_changed_.value (),
- ACE_Thread::self ()))
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: "
- "Thread switch for 'LIVELINESS_CHANGED_STATUS' seems OK. "
- "(DDS uses the CCM thread for its callback) "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_changed_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread switch for 'LIVELINESS_CHANGED_STATUS' "
- "doesn't seem to work! "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_changed_.value (),
- ACE_Thread::self ()));
- }
- #else
- else if (ACE_OS::thr_equal (this->thread_id_listener_liveliness_changed_.value (),
- ACE_Thread::self ()))
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: 'LIVELINESS_CHANGED_STATUS': "
- "DDS seems to use a CCM thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_changed_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: 'LIVELINESS_CHANGED_STATUS': "
- "DDS seems to use its own thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_changed_.value (),
- ACE_Thread::self ()));
- }
- #endif
-
- //test thread switch for LIVELINESS_LOST_STATUS
- if (this->thread_id_listener_liveliness_lost_.value () == 0)
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread ID for 'LIVELINESS_LOST_STATUS' not set!\n"));
- }
- #if defined (CIAO_DDS4CCM_CONTEXT_SWITCH) && (CIAO_DDS4CCM_CONTEXT_SWITCH == 1)
- else if (ACE_OS::thr_equal (this->thread_id_listener_liveliness_lost_.value (),
- ACE_Thread::self ()))
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: "
- "Thread switch for 'LIVELINESS_LOST_STATUS' seems OK. "
- "(DDS uses the CCM thread for its callback) "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_lost_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread switch for 'LIVELINESS_LOST_STATUS' "
- "doesn't seem to work! "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_lost_.value (),
- ACE_Thread::self ()));
- }
- #else
- else if (ACE_OS::thr_equal (this->thread_id_listener_liveliness_lost_.value (),
- ACE_Thread::self ()))
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: 'LIVELINESS_LOST_STATUS': "
- "DDS seems to use a CCM thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_lost_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: 'LIVELINESS_LOST_STATUS': "
- "DDS seems to use its own thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_listener_liveliness_lost_.value (),
- ACE_Thread::self ()));
- }
- #endif
-
-/*
- //test thread switch for RELIABLE_READER_ACTIVITY_CHANGED_STATUS
- if (this->thread_id_reliable_dr_activity_changed_.value () == 0)
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread ID for 'RELIABLE_READER_ACTIVITY_CHANGED_STATUS' not set!\n"));
- }
- #if defined (CIAO_DDS4CCM_CONTEXT_SWITCH) && (CIAO_DDS4CCM_CONTEXT_SWITCH == 1)
- else if (ACE_OS::thr_equal (this->thread_id_reliable_dr_activity_changed_.value (),
- ACE_Thread::self ()))
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: "
- "Thread switch for 'RELIABLE_READER_ACTIVITY_CHANGED_STATUS' seems OK. "
- "(DDS uses the CCM thread for its callback) "
- "listener <%u> - component <%u>\n",
- this->thread_id_reliable_dr_activity_changed_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: "
- "Thread switch for 'RELIABLE_READER_ACTIVITY_CHANGED_STATUS' "
- "doesn't seem to work! "
- "listener <%u> - component <%u>\n",
- this->thread_id_reliable_dr_activity_changed_.value (),
- ACE_Thread::self ()));
- }
- #else
- else if (ACE_OS::thr_equal (this->thread_id_listener_liveliness_lost_.value (),
- ACE_Thread::self ()))
- {
- ACE_ERROR ((LM_ERROR, "SENDER ERROR: 'RELIABLE_READER_ACTIVITY_CHANGED_STATUS': "
- "DDS seems to use a CCM thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_reliable_dr_activity_changed_.value (),
- ACE_Thread::self ()));
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG, "SENDER OK: 'RELIABLE_READER_ACTIVITY_CHANGED_STATUS': "
- "DDS seems to use its own thread for its callback: "
- "listener <%u> - component <%u>\n",
- this->thread_id_reliable_dr_activity_changed_.value (),
- ACE_Thread::self ()));
- }
- #endif
-*/
}
extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr
View Lorry Controller Status