diff options
Diffstat (limited to 'TAO/tao/Invocation.cpp')
-rw-r--r-- | TAO/tao/Invocation.cpp | 54 |
1 files changed, 27 insertions, 27 deletions
diff --git a/TAO/tao/Invocation.cpp b/TAO/tao/Invocation.cpp index b103f7aebfb..b68e6904a83 100644 --- a/TAO/tao/Invocation.cpp +++ b/TAO/tao/Invocation.cpp @@ -135,14 +135,14 @@ TAO_GIOP_Invocation::start (CORBA::Boolean is_roundtrip, // assert (this->stub_ != 0); if (this->stub_ == 0) - ACE_THROW (CORBA::INV_OBJREF ()); + ACE_THROW (CORBA::INV_OBJREF (CORBA::COMPLETED_NO)); // Get a pointer to the connector registry, which might be in // thread-specific storage, depending on the concurrency model. TAO_Connector_Registry *conn_reg = this->orb_core_->connector_registry (); if (conn_reg == 0) - ACE_THROW (CORBA::INTERNAL ()); + ACE_THROW (CORBA::INTERNAL (CORBA::COMPLETED_NO)); // @@ It seems like this is the right spot to re-order the profiles // based on the policies in the ORB. @@ -171,7 +171,7 @@ TAO_GIOP_Invocation::start (CORBA::Boolean is_roundtrip, // Try moving to the next profile and starting over, if that // fails then we must raise the TRANSIENT exception. if (this->stub_->next_profile_retry () == 0) - ACE_THROW (CORBA::TRANSIENT ()); + ACE_THROW (CORBA::TRANSIENT (CORBA::COMPLETED_NO)); } const TAO_ObjectKey& key = this->profile_->object_key(); @@ -201,7 +201,7 @@ TAO_GIOP_Invocation::start (CORBA::Boolean is_roundtrip, if (TAO_GIOP::start_message (message_type, this->out_stream_, this->orb_core_) == 0) - ACE_THROW (CORBA::MARSHAL ()); + ACE_THROW (CORBA::MARSHAL (CORBA::COMPLETED_NO)); ACE_TIMEPROBE (TAO_GIOP_INVOCATION_START_START_MSG); @@ -243,11 +243,11 @@ TAO_GIOP_Invocation::start (CORBA::Boolean is_roundtrip, break; default: - ACE_THROW (CORBA::INTERNAL ()); + ACE_THROW (CORBA::INTERNAL (CORBA::COMPLETED_NO)); } if (!this->out_stream_.good_bit ()) - ACE_THROW (CORBA::MARSHAL ()); + ACE_THROW (CORBA::MARSHAL (CORBA::COMPLETED_NO)); ACE_TIMEPROBE (TAO_GIOP_INVOCATION_START_REQUEST_HDR); } @@ -322,7 +322,7 @@ TAO_GIOP_Invocation::invoke (CORBA::Boolean is_roundtrip, { if (this->transport_ == 0) - ACE_THROW_RETURN (CORBA::INTERNAL (), + ACE_THROW_RETURN (CORBA::INTERNAL (CORBA::COMPLETED_NO), TAO_INVOKE_EXCEPTION); int result = @@ -417,7 +417,7 @@ TAO_GIOP_Invocation::location_forward (TAO_InputCDR &inp_stream, // @@ If a forward exception or a LOCATION_FORWARD reply is sent // then the request couldn't have completed. But we need to // re-validate this to ensure "at most once" semantics. - ACE_THROW_RETURN (CORBA::MARSHAL (), + ACE_THROW_RETURN (CORBA::MARSHAL (CORBA::COMPLETED_NO), TAO_INVOKE_EXCEPTION); } @@ -434,7 +434,7 @@ TAO_GIOP_Invocation::location_forward (TAO_InputCDR &inp_stream, // @@ If a forward exception or a LOCATION_FORWARD reply is sent // then the request couldn't have completed. But we need to // re-validate this to ensure "at most once" semantics. - ACE_THROW_RETURN (CORBA::INTERNAL (), + ACE_THROW_RETURN (CORBA::INTERNAL (CORBA::COMPLETED_NO), TAO_INVOKE_EXCEPTION); } @@ -451,7 +451,7 @@ TAO_GIOP_Invocation::location_forward (TAO_InputCDR &inp_stream, // New for Multiple profile. Get the MProfile list from the // forwarded object refererence - this->stub_->add_forward_profiles (*stubobj->get_profiles ()); + this->stub_->add_forward_profiles (stubobj->get_profiles ()); // store the new profile list and set the first forwarding profile // note: this has to be and is thread safe. Also get_profiles returns // a pointer to a new MProfile object which we give to our @@ -464,7 +464,7 @@ TAO_GIOP_Invocation::location_forward (TAO_InputCDR &inp_stream, // get created on a per-call basis. For now we'll play it safe. if (this->stub_->next_profile () == 0) - ACE_THROW_RETURN (CORBA::TRANSIENT (), + ACE_THROW_RETURN (CORBA::TRANSIENT (CORBA::COMPLETED_NO), TAO_INVOKE_EXCEPTION); return TAO_INVOKE_RESTART; @@ -500,7 +500,7 @@ TAO_GIOP_Twoway_Invocation::invoke (CORBA::ExceptionList &exceptions, // failed, but the connection seems to be still // valid! // this->transport_->close_connection (); - ACE_THROW_RETURN (CORBA::MARSHAL (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_YES), + ACE_THROW_RETURN (CORBA::MARSHAL (CORBA::COMPLETED_YES), TAO_INVOKE_EXCEPTION); } @@ -526,11 +526,11 @@ TAO_GIOP_Twoway_Invocation::invoke (CORBA::ExceptionList &exceptions, const ACE_Message_Block* cdr = this->inp_stream_.start (); - CORBA_Any any (tcp, 0, cdr); + CORBA_Any any (tcp, cdr); CORBA_Exception *exception; ACE_NEW_THROW_EX (exception, CORBA_UnknownUserException (any), - CORBA::NO_MEMORY (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_YES)); + CORBA::NO_MEMORY (CORBA::COMPLETED_YES)); ACE_CHECK_RETURN (TAO_INVOKE_EXCEPTION); // @@ Think about a better way to raise the exception here, @@ -545,7 +545,7 @@ TAO_GIOP_Twoway_Invocation::invoke (CORBA::ExceptionList &exceptions, // @@ It would seem like if the remote exception is a // UserException we can assume that the request was // completed. - ACE_THROW_RETURN (CORBA::UNKNOWN (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_YES), + ACE_THROW_RETURN (CORBA::UNKNOWN (CORBA::COMPLETED_YES), TAO_INVOKE_EXCEPTION); } @@ -586,7 +586,7 @@ TAO_GIOP_Twoway_Invocation::invoke (TAO_Exception_Data *excepts, // failed, but the connection seems to be still // valid! // this->transport_->close_connection (); - ACE_THROW_RETURN (CORBA::MARSHAL (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_YES), + ACE_THROW_RETURN (CORBA::MARSHAL (CORBA::COMPLETED_YES), TAO_INVOKE_EXCEPTION); } @@ -605,7 +605,7 @@ TAO_GIOP_Twoway_Invocation::invoke (TAO_Exception_Data *excepts, CORBA::Exception_ptr exception = excepts[i].alloc (); if (exception == 0) - ACE_THROW_RETURN (CORBA::NO_MEMORY (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_YES), + ACE_THROW_RETURN (CORBA::NO_MEMORY (CORBA::COMPLETED_YES), TAO_INVOKE_EXCEPTION); this->inp_stream_.decode (exception->_type (), @@ -627,7 +627,7 @@ TAO_GIOP_Twoway_Invocation::invoke (TAO_Exception_Data *excepts, // If we couldn't find the right exception, report it as // CORBA::UNKNOWN. - ACE_THROW_RETURN (CORBA::UNKNOWN (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_YES), + ACE_THROW_RETURN (CORBA::UNKNOWN (CORBA::COMPLETED_YES), TAO_INVOKE_EXCEPTION); } @@ -736,7 +736,7 @@ TAO_GIOP_Twoway_Invocation::invoke_i (CORBA::Environment &ACE_TRY_ENV) // invocation may perfectly work. this->close_connection (); - ACE_THROW_RETURN (CORBA::COMM_FAILURE (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_MAYBE), + ACE_THROW_RETURN (CORBA::COMM_FAILURE (CORBA::COMPLETED_MAYBE), TAO_INVOKE_EXCEPTION); } @@ -781,7 +781,7 @@ TAO_GIOP_Twoway_Invocation::invoke_i (CORBA::Environment &ACE_TRY_ENV) // is a problem, but we haven't lost synchronization with the // server or anything. this->transport_->close_connection (); - ACE_THROW_RETURN (CORBA::MARSHAL (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_MAYBE), + ACE_THROW_RETURN (CORBA::MARSHAL (CORBA::COMPLETED_MAYBE), TAO_INVOKE_EXCEPTION); } @@ -796,7 +796,7 @@ TAO_GIOP_Twoway_Invocation::invoke_i (CORBA::Environment &ACE_TRY_ENV) this->transport_->close_connection (); if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG, "TAO: (%P|%t) bad Response header\n")); - ACE_THROW_RETURN (CORBA::COMM_FAILURE (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_MAYBE), + ACE_THROW_RETURN (CORBA::COMM_FAILURE (CORBA::COMPLETED_MAYBE), TAO_INVOKE_EXCEPTION); } @@ -849,7 +849,7 @@ TAO_GIOP_Twoway_Invocation::invoke_i (CORBA::Environment &ACE_TRY_ENV) // failed, but the connection seems to be still // valid! this->transport_->close_connection (); - ACE_THROW_RETURN (CORBA::MARSHAL (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_MAYBE), + ACE_THROW_RETURN (CORBA::MARSHAL (CORBA::COMPLETED_MAYBE), TAO_INVOKE_EXCEPTION); } @@ -903,7 +903,7 @@ TAO_GIOP_Locate_Request_Invocation::invoke (CORBA::Environment &ACE_TRY_ENV) // to refactor them. if (this->transport_ == 0) - ACE_THROW_RETURN (CORBA::INTERNAL (), + ACE_THROW_RETURN (CORBA::INTERNAL (CORBA::COMPLETED_NO), TAO_INVOKE_EXCEPTION); int result = @@ -923,7 +923,7 @@ TAO_GIOP_Locate_Request_Invocation::invoke (CORBA::Environment &ACE_TRY_ENV) // works? Or is that something that a higher level component // should decide? Remember that LocateRequests are part of // the strategy to establish a connection. - ACE_THROW_RETURN (CORBA::TRANSIENT (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_MAYBE), + ACE_THROW_RETURN (CORBA::TRANSIENT (CORBA::COMPLETED_MAYBE), TAO_INVOKE_EXCEPTION); } @@ -985,7 +985,7 @@ TAO_GIOP_Locate_Request_Invocation::invoke (CORBA::Environment &ACE_TRY_ENV) this->close_connection (); - ACE_THROW_RETURN (CORBA::COMM_FAILURE (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_MAYBE), + ACE_THROW_RETURN (CORBA::COMM_FAILURE (CORBA::COMPLETED_MAYBE), TAO_INVOKE_EXCEPTION); } @@ -1004,7 +1004,7 @@ TAO_GIOP_Locate_Request_Invocation::invoke (CORBA::Environment &ACE_TRY_ENV) this->transport_->close_connection (); if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG, "TAO: (%P|%t) bad Response header\n")); - ACE_THROW_RETURN (CORBA::COMM_FAILURE (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_MAYBE), + ACE_THROW_RETURN (CORBA::COMM_FAILURE (CORBA::COMPLETED_MAYBE), TAO_INVOKE_EXCEPTION); } @@ -1014,7 +1014,7 @@ TAO_GIOP_Locate_Request_Invocation::invoke (CORBA::Environment &ACE_TRY_ENV) break; case TAO_GIOP_UNKNOWN_OBJECT: - ACE_THROW_RETURN (CORBA::OBJECT_NOT_EXIST (TAO_DEFAULT_MINOR_CODE, CORBA::COMPLETED_YES), + ACE_THROW_RETURN (CORBA::OBJECT_NOT_EXIST (CORBA::COMPLETED_YES), TAO_INVOKE_EXCEPTION); // NOTREACHED |