summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/AVStreams/Modify_QoS/sender.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Modify_QoS/sender.cpp')
-rw-r--r--TAO/orbsvcs/tests/AVStreams/Modify_QoS/sender.cpp42
1 files changed, 21 insertions, 21 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Modify_QoS/sender.cpp b/TAO/orbsvcs/tests/AVStreams/Modify_QoS/sender.cpp
index 36ee0a3a896..cbc8c86e533 100644
--- a/TAO/orbsvcs/tests/AVStreams/Modify_QoS/sender.cpp
+++ b/TAO/orbsvcs/tests/AVStreams/Modify_QoS/sender.cpp
@@ -34,7 +34,7 @@ Sender_StreamEndPoint::set_protocol_object (const char *,
CORBA::Boolean
Sender_StreamEndPoint::modify_QoS (AVStreams::streamQoS &new_qos,
const AVStreams::flowSpec &/* the_flows */
- TAO_ENV_ARG_DECL_NOT_USED)
+ ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC((CORBA::SystemException,
AVStreams::noSuchFlow,
AVStreams::QoSRequestFailed ))
@@ -119,7 +119,7 @@ Sender::parse_args (int argc,
// Method to get the object reference of the receiver
int
-Sender::bind_to_receiver (TAO_ENV_SINGLE_ARG_DECL)
+Sender::bind_to_receiver (ACE_ENV_SINGLE_ARG_DECL)
{
CosNaming::Name name (1);
name.length (1);
@@ -129,12 +129,12 @@ Sender::bind_to_receiver (TAO_ENV_SINGLE_ARG_DECL)
// Resolve the receiver object reference from the Naming Service
CORBA::Object_var receiver_mmdevice_obj =
this->naming_client_->resolve (name
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
this->receiver_mmdevice_ =
AVStreams::MMDevice::_narrow (receiver_mmdevice_obj.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
if (CORBA::is_nil (this->receiver_mmdevice_.in ()))
@@ -148,7 +148,7 @@ Sender::bind_to_receiver (TAO_ENV_SINGLE_ARG_DECL)
int
Sender::init (int argc,
char **argv
- TAO_ENV_ARG_DECL)
+ ACE_ENV_ARG_DECL)
{
// Initialize the endpoint strategy with the orb and poa.
int result =
@@ -185,7 +185,7 @@ Sender::init (int argc,
"File opened successfully\n"));
// Resolve the object reference of the receiver from the Naming Service.
- result = this->bind_to_receiver (TAO_ENV_SINGLE_ARG_PARAMETER);
+ result = this->bind_to_receiver (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
if (result != 0)
@@ -219,7 +219,7 @@ Sender::init (int argc,
this->sender_mmdevice_;
AVStreams::MMDevice_var mmdevice =
- this->sender_mmdevice_->_this (TAO_ENV_SINGLE_ARG_PARAMETER);
+ this->sender_mmdevice_->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
ACE_NEW_RETURN (this->streamctrl_,
@@ -235,7 +235,7 @@ Sender::init (int argc,
this->receiver_mmdevice_.in (),
the_qos.inout (),
flow_spec
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
if (bind_result == 0)
@@ -248,7 +248,7 @@ Sender::init (int argc,
// Method to send data at the specified rate
int
-Sender::pace_data (TAO_ENV_SINGLE_ARG_DECL)
+Sender::pace_data (ACE_ENV_SINGLE_ARG_DECL)
{
@@ -325,7 +325,7 @@ Sender::pace_data (TAO_ENV_SINGLE_ARG_DECL)
// Run the orb for the wait time so the sender can
// continue other orb requests.
TAO_AV_CORE::instance ()->orb ()->run (wait_time
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
}
@@ -354,11 +354,11 @@ Sender::pace_data (TAO_ENV_SINGLE_ARG_DECL)
// File reading is complete, destroy the stream.
AVStreams::flowSpec stop_spec;
- this->streamctrl_->destroy (stop_spec TAO_ENV_ARG_PARAMETER);
+ this->streamctrl_->destroy (stop_spec ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Shut the orb down.
- TAO_AV_CORE::instance ()->orb ()->shutdown (1 TAO_ENV_ARG_PARAMETER);
+ TAO_AV_CORE::instance ()->orb ()->shutdown (1 ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
@@ -375,44 +375,44 @@ int
main (int argc,
char **argv)
{
- TAO_ENV_DECLARE_NEW_ENV;
+ ACE_DECLARE_NEW_CORBA_ENV;
ACE_TRY
{
CORBA::ORB_var orb =
CORBA::ORB_init (argc,
argv,
0
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
CORBA::Object_var obj
= orb->resolve_initial_references ("RootPOA"
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Get the POA_var object from Object_var
PortableServer::POA_var root_poa
= PortableServer::POA::_narrow (obj.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::POAManager_var mgr
- = root_poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER);
+ = root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
- mgr->activate (TAO_ENV_SINGLE_ARG_PARAMETER);
+ mgr->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
// Initialize the AV Stream components.
TAO_AV_CORE::instance ()->init (orb.in (),
root_poa.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Initialize the Sender.
int result = 0;
result = SENDER::instance ()->init (argc,
argv
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (result < 0)
@@ -421,7 +421,7 @@ main (int argc,
-1);
// Start sending data.
- result = SENDER::instance ()->pace_data (TAO_ENV_SINGLE_ARG_PARAMETER);
+ result = SENDER::instance ()->pace_data (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}