summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/tests/SLManyByMany/Receiver/SL_ManyByMany_Receiver_exec.cpp
diff options
context:
space:
mode:
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.cpp12
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