diff options
author | naga <naga@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-07-12 21:15:01 +0000 |
---|---|---|
committer | naga <naga@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-07-12 21:15:01 +0000 |
commit | f4bad79baf2834bb377ee9996b4fc5d453b02db0 (patch) | |
tree | 6f60d7d9f2a9a42de9c25c84aad16757d5e05922 | |
parent | 00928bfee8b7b66184302fbaebdbdc2e6b827fc1 (diff) | |
download | ATCD-f4bad79baf2834bb377ee9996b4fc5d453b02db0.tar.gz |
Removed the flowname from the flowspec for start and stop and made use
of the "empty flowspec will start all flows" feature of the Streamctrl.
-rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.cpp b/TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.cpp index af9e19167b0..b75a6d26903 100644 --- a/TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.cpp +++ b/TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.cpp @@ -87,11 +87,11 @@ FTP_Client_Flow_Handler::handle_timeout (const ACE_Time_Value &tv, this->count_++; if (this->count_ == 10) { + ACE_DECLARE_NEW_CORBA_ENV; ACE_DEBUG ((LM_DEBUG,"handle_timeout:End of file\n")); AVStreams::flowSpec stop_spec (1); - stop_spec.length (1); - ACE_DECLARE_NEW_CORBA_ENV; - stop_spec [0] = CORBA::string_dup (CLIENT::instance ()->flowname ()); +// stop_spec.length (1); +// stop_spec [0] = CORBA::string_dup (CLIENT::instance ()->flowname ()); CLIENT::instance ()->streamctrl ()->stop (stop_spec,ACE_TRY_ENV); ACE_CHECK_RETURN (-1); return 0; @@ -375,8 +375,8 @@ Client::run (void) if (result == 0) ACE_ERROR_RETURN ((LM_ERROR,"streamctrl::bind_devs failed\n"),-1); AVStreams::flowSpec start_spec (1); - start_spec.length (1); - start_spec [0] = CORBA::string_dup (this->flowname_); +// start_spec.length (1); +// start_spec [0] = CORBA::string_dup (this->flowname_); this->streamctrl_.start (start_spec,ACE_TRY_ENV); ACE_TRY_CHECK; // Schedule a timer for the for the flow handler. |