diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/ListenNotEnabled')
-rw-r--r-- | CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.cpp | 7 | ||||
-rw-r--r-- | CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.h | 1 |
2 files changed, 5 insertions, 3 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.cpp b/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.cpp index 5336eb191b5..f2bf04d1231 100644 --- a/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.cpp +++ b/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.cpp @@ -54,11 +54,15 @@ namespace CIAO_LNE_Test_Sender_Impl write_many[key + iter - 2] = new_key; } } + +::LNE_Test::ListenNotEnabledTestConnector::Writer_var writer = + this->context_->get_connection_info_write_data (); + try { ACE_Time_Value tv (1, 0); ACE_OS::sleep (tv); - this->writer_->write_many (write_many); + writer->write_many (write_many); ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("write_many : written <%u> samples\n"), write_many.length ())); } @@ -124,7 +128,6 @@ namespace CIAO_LNE_Test_Sender_Impl { try { - this->writer_ = this->context_->get_connection_info_write_data (); start (); } catch (const CORBA::Exception& ex) diff --git a/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.h b/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.h index b0f9fc64974..209a0b8ee14 100644 --- a/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.h +++ b/CIAO/connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.h @@ -61,7 +61,6 @@ namespace CIAO_LNE_Test_Sender_Impl private: ::LNE_Test::CCM_Sender_Context_var context_; - ::LNE_Test::ListenNotEnabledTestConnector::Writer_var writer_; CORBA::UShort iterations_; CORBA::UShort keys_; |