summaryrefslogtreecommitdiff
path: root/TAO/tao/Messaging/Asynch_Invocation_Adapter.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Messaging/Asynch_Invocation_Adapter.cpp')
-rw-r--r--TAO/tao/Messaging/Asynch_Invocation_Adapter.cpp32
1 files changed, 11 insertions, 21 deletions
diff --git a/TAO/tao/Messaging/Asynch_Invocation_Adapter.cpp b/TAO/tao/Messaging/Asynch_Invocation_Adapter.cpp
index 67dfb1386bc..c4c15850c87 100644
--- a/TAO/tao/Messaging/Asynch_Invocation_Adapter.cpp
+++ b/TAO/tao/Messaging/Asynch_Invocation_Adapter.cpp
@@ -47,8 +47,7 @@ namespace TAO
void
Asynch_Invocation_Adapter::invoke (
Messaging::ReplyHandler_ptr reply_handler_ptr,
- const TAO_Reply_Handler_Skeleton &reply_handler_skel
- )
+ const TAO_Reply_Handler_Skeleton &reply_handler_skel)
{
TAO_Stub * stub =
this->get_stub ();
@@ -131,8 +130,7 @@ namespace TAO
return Invocation_Adapter::invoke_collocated_i (stub,
details,
effective_target,
- strat
- );
+ strat);
}
Invocation_Status
@@ -140,19 +138,17 @@ namespace TAO
TAO_Operation_Details &op,
CORBA::Object_var &effective_target,
Profile_Transport_Resolver &r,
- ACE_Time_Value *&max_wait_time
- )
+ ACE_Time_Value *&max_wait_time)
{
// Simple sanity check
if (this->mode_ != TAO_ASYNCHRONOUS_CALLBACK_INVOCATION
|| this->type_ != TAO_TWOWAY_INVOCATION)
{
- ACE_THROW_RETURN (CORBA::INTERNAL (
- CORBA::SystemException::_tao_minor_code (
- TAO::VMCID,
- EINVAL),
- CORBA::COMPLETED_NO),
- TAO_INVOKE_FAILURE);
+ throw ::CORBA::INTERNAL (
+ CORBA::SystemException::_tao_minor_code (
+ TAO::VMCID,
+ EINVAL),
+ CORBA::COMPLETED_NO);
}
if (this->safe_rd_.get ())
@@ -163,8 +159,7 @@ namespace TAO
// AMI Timeout Handling Begin
ACE_Time_Value tmp;
- if (this->get_timeout (r.stub (),
- tmp))
+ if (this->get_timeout (r.stub (), tmp))
{
this->safe_rd_->schedule_timer (
op.request_id (),
@@ -180,9 +175,7 @@ namespace TAO
op,
this->safe_rd_.release ());
- Invocation_Status const s =
- asynch.remote_invocation (max_wait_time
- );
+ Invocation_Status const s = asynch.remote_invocation (max_wait_time);
if (s == TAO_INVOKE_RESTART &&
asynch.is_forwarded ())
@@ -196,10 +189,7 @@ namespace TAO
CORBA::Boolean const permanent_forward = false;
#endif
- this->object_forwarded (effective_target,
- r.stub (),
- permanent_forward
- );
+ this->object_forwarded (effective_target, r.stub (), permanent_forward);
}
return s;