diff options
| author | Johnny Willemsen <jwillemsen@remedy.nl> | 2010-06-15 11:07:09 +0000 |
|---|---|---|
| committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2010-06-15 11:07:09 +0000 |
| commit | 4692c29b8eccbb0ad8e0dafe344b4be687309d46 (patch) | |
| tree | d1d55cc3641187efeac75117126fef5c9c979cd3 /CIAO/connectors/dds4ccm/tests/ListenNotEnabled | |
| parent | bcf860b9b43729972008c27384dd765d2f97e7b1 (diff) | |
| download | ATCD-4692c29b8eccbb0ad8e0dafe344b4be687309d46.tar.gz | |
Tue Jun 15 11:06:40 UTC 2010 Johnny Willemsen <jwillemsen@remedy.nl>
* connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender_exec.h:
* connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender_exec.cpp:
* connectors/dds4ccm/tests/ListenManyByMany/Sender/LMBM_Test_Sender_exec.cpp:
* connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.h:
* connectors/dds4ccm/tests/ListenNotEnabled/Sender/LNE_Test_Sender_exec.cpp:
Cleanup, no caching in executors
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_; |