diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/SLManyByMany/Receiver/SL_ManyByMany_Receiver_exec.cpp')
-rw-r--r-- | CIAO/connectors/dds4ccm/tests/SLManyByMany/Receiver/SL_ManyByMany_Receiver_exec.cpp | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/SLManyByMany/Receiver/SL_ManyByMany_Receiver_exec.cpp b/CIAO/connectors/dds4ccm/tests/SLManyByMany/Receiver/SL_ManyByMany_Receiver_exec.cpp index d824260966e..d0d8e720e88 100644 --- a/CIAO/connectors/dds4ccm/tests/SLManyByMany/Receiver/SL_ManyByMany_Receiver_exec.cpp +++ b/CIAO/connectors/dds4ccm/tests/SLManyByMany/Receiver/SL_ManyByMany_Receiver_exec.cpp @@ -193,15 +193,18 @@ namespace CIAO_SL_ManyByMany_Receiver_Impl void Receiver_exec_i::read_all (void) { - if (::CORBA::is_nil (this->reader_.in ())) + ::SL_ManyByMany::SLManyByManyConnector::Reader_var reader = + this->context_->get_connection_info_out_data(); + + if (::CORBA::is_nil (reader.in ())) { return; } - TestTopicSeq TestTopic_infos; - ::CCM_DDS::ReadInfoSeq readinfoseq; try { - this->reader_->read_all(TestTopic_infos, readinfoseq); + TestTopicSeq TestTopic_infos; + ::CCM_DDS::ReadInfoSeq readinfoseq; + reader->read_all(TestTopic_infos, readinfoseq); for(CORBA::ULong i = 0; i < readinfoseq.length(); ++i) { ACE_Time_Value tv; @@ -262,7 +265,6 @@ namespace CIAO_SL_ManyByMany_Receiver_Impl void Receiver_exec_i::configuration_complete (void) { - this->reader_ = this->context_->get_connection_info_out_data(); } void |