summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp
diff options
context:
space:
mode:
authoryamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2001-04-01 22:20:44 +0000
committeryamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2001-04-01 22:20:44 +0000
commitb042ef6ee7729d1c8aadc6052f6d24ba29fd06fe (patch)
treefb08b886cb364e3527754ffa7b3c1ab7b667f32f /TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp
parentacfa08e28a54440b32d1377e86147fedb380fb08 (diff)
downloadATCD-b042ef6ee7729d1c8aadc6052f6d24ba29fd06fe.tar.gz
*** empty log message ***
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp')
-rw-r--r--TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp23
1 files changed, 16 insertions, 7 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp b/TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp
index c6d648a585a..66d080ef8c4 100644
--- a/TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp
+++ b/TAO/orbsvcs/tests/AVStreams/Pluggable/ftp.cpp
@@ -171,9 +171,11 @@ Client::init (int argc,
TAO_AV_CORE::instance ()->poa ());
// Parse the command line arguments
- this->parse_args (argc,
- argv);
+ int result = this->parse_args (argc,
+ argv);
+ if (result != 0)
+ return result;
// Open file to read.
this->fp_ = ACE_OS::fopen (this->filename_,
@@ -184,12 +186,15 @@ Client::init (int argc,
this->filename_),
-1);
+ result
+ = this->bind_to_server (ACE_TRY_ENV);
+
// Resolve the object reference of the server from the Naming Service.
- if (this->bind_to_server (ACE_TRY_ENV) == -1)
+ if (result != 0)
ACE_ERROR_RETURN ((LM_ERROR,
"(%P|%t) Error binding to the naming service\n"),
-1);
-
+
// Create the Flow protocol name
char flow_protocol_str [BUFSIZ];
if (this->use_sfp_)
@@ -226,16 +231,20 @@ Client::init (int argc,
flow_spec [0] = CORBA::string_dup (entry.entry_to_string ());
flow_spec.length (1);
+ AVStreams::MMDevice_var client_mmdevice =
+ this->client_mmdevice_._this (ACE_TRY_ENV);
+ ACE_CHECK_RETURN (-1);
+
// Bind/Connect the client and server MMDevices.
- CORBA::Boolean result =
- this->streamctrl_.bind_devs (this->client_mmdevice_._this (ACE_TRY_ENV),
+ CORBA::Boolean bind_result =
+ this->streamctrl_.bind_devs (client_mmdevice.in (),
this->server_mmdevice_.in (),
the_qos.inout (),
flow_spec,
ACE_TRY_ENV);
ACE_CHECK_RETURN (-1);
- if (result == 0)
+ if (bind_result == 0)
ACE_ERROR_RETURN ((LM_ERROR,"streamctrl::bind_devs failed\n"),-1);
return 0;