diff options
Diffstat (limited to 'TAO/tao/PortableInterceptor.i')
| -rw-r--r-- | TAO/tao/PortableInterceptor.i | 266 |
1 files changed, 0 insertions, 266 deletions
diff --git a/TAO/tao/PortableInterceptor.i b/TAO/tao/PortableInterceptor.i index 83b10444fef..8d607f70c47 100644 --- a/TAO/tao/PortableInterceptor.i +++ b/TAO/tao/PortableInterceptor.i @@ -12,122 +12,6 @@ TAO_ClientRequestInterceptor_Adapter::TAO_ClientRequestInterceptor_Adapter this->len_ = interceptors.size (); } -ACE_INLINE void -TAO_ClientRequestInterceptor_Adapter:: -send_request (PortableInterceptor::ClientRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This method implements one of the "starting" client side - // interception point. - for (size_t i = 0 ; i < this->len_; ++i) - { - this->interceptors_[i]->send_request (ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - - // The starting interception point completed successfully. Push - // the interceptor on to the flow stack. - ++this->stack_size_; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); -} - -ACE_INLINE void -TAO_ClientRequestInterceptor_Adapter:: -receive_reply (PortableInterceptor::ClientRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This is an "ending" interception point so we only process the - // interceptors pushed on to the flow stack. - - // Notice that the interceptors are processed in the opposite order - // they were pushed onto the stack since this is an "ending" - // interception point. - - // Unwind the stack. - size_t len = this->stack_size_; - for (size_t i = 0; i < len; ++i) - { - // Pop the interceptor off of the flow stack before it is - // invoked. This is necessary to prevent an interceptor already - // invoked in this "ending" interception point from being - // invoked in another "ending" interception point. - --this->stack_size_; - - this->interceptors_[this->stack_size_]->receive_reply ( - ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); - -} - -ACE_INLINE void -TAO_ClientRequestInterceptor_Adapter:: -receive_exception (PortableInterceptor::ClientRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This is an "ending" interception point so we only process the - // interceptors pushed on to the flow stack. - - // Notice that the interceptors are processed in the opposite order - // they were pushed onto the stack since this is an "ending" - // interception point. - - // Unwind the flow stack. - size_t len = this->stack_size_; - for (size_t i = 0; i < len; ++i) - { - // Pop the interceptor off of the flow stack before it is - // invoked. This is necessary to prevent an interceptor already - // invoked in this "ending" interception point from being - // invoked in another "ending" interception point. - --this->stack_size_; - - this->interceptors_[this->stack_size_]->receive_exception ( - ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); -} - -ACE_INLINE void -TAO_ClientRequestInterceptor_Adapter:: -receive_other (PortableInterceptor::ClientRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This is an "ending" interception point so we only process the - // interceptors pushed on to the flow stack. - - // Notice that the interceptors are processed in the opposite order - // they were pushed onto the stack since this is an "ending" - // interception point. - - // Unwind the stack. - size_t len = this->stack_size_; - for (size_t i = 0; i < len; ++i) - { - // Pop the interceptor off of the flow stack before it is - // invoked. This is necessary to prevent an interceptor already - // invoked in this "ending" interception point from being - // invoked in another "ending" interception point. - --this->stack_size_; - - this->interceptors_[this->stack_size_]->receive_other ( - ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); - -} - // ------------------------------------------------------------------- ACE_INLINE @@ -140,153 +24,3 @@ TAO_ServerRequestInterceptor_Adapter::TAO_ServerRequestInterceptor_Adapter { this->len_ = interceptors.size (); } - -ACE_INLINE void -TAO_ServerRequestInterceptor_Adapter:: -receive_request_service_contexts ( - PortableInterceptor::ServerRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This method implements one of the "starting" server side - // interception point. - for (size_t i = 0 ; i < this->len_; ++i) - { - this->interceptors_[i]->receive_request_service_contexts ( - ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - - // The starting interception point completed successfully. Push - // the interceptor on to the flow stack. - ++this->stack_size_; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); -} - -ACE_INLINE void -TAO_ServerRequestInterceptor_Adapter:: -receive_request (PortableInterceptor::ServerRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This method implements an "intermediate" server side interception - // point. Interceptors are invoked in the same order they were - // pushed on to the flow stack. - - if (this->len_ != this->stack_size_) - { - // This method (i.e. the receive_request() interception point) - // should only be invoked if all of the interceptors registered - // with the ORB were pushed on to the flow stack by one of the - // starting endpoints (such as - // receive_request_service_contexts()). If the above condition - // evaluates to "true," then it is likely that a starting - // interception point was never invoked. This is of course, an - // internal error that must be corrected. - ACE_THROW (CORBA::INTERNAL ()); - } - - for (size_t i = 0; i < this->stack_size_; ++i) - { - this->interceptors_[i]->receive_request (ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - - // Note that no interceptors are pushed on to or popped off of - // the flow stack in this interception point since it is an - // intermediate interception point. - } -} - -ACE_INLINE void -TAO_ServerRequestInterceptor_Adapter:: -send_reply (PortableInterceptor::ServerRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This is an "ending" interception point so we only process the - // interceptors pushed on to the flow stack. - - // Notice that the interceptors are processed in the opposite order - // they were pushed onto the stack since this is an "ending" - // interception point. - - // Unwind the stack. - size_t len = this->stack_size_; - for (size_t i = 0; i < len; ++i) - { - // Pop the interceptor off of the flow stack before it is - // invoked. This is necessary to prevent an interceptor already - // invoked in this "ending" interception point from being - // invoked in another "ending" interception point. - --this->stack_size_; - - this->interceptors_[this->stack_size_]->send_reply ( - ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); -} - -ACE_INLINE void -TAO_ServerRequestInterceptor_Adapter:: -send_exception (PortableInterceptor::ServerRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This is an "ending" server side interception point so we only - // process the interceptors pushed on to the flow stack. - - // Notice that the interceptors are processed in the opposite order - // they were pushed onto the stack since this is an "ending" server - // side interception point. - - // Unwind the flow stack. - size_t len = this->stack_size_; - for (size_t i = 0; i < len; ++i) - { - // Pop the interceptor off of the flow stack before it is - // invoked. This is necessary to prevent an interceptor already - // invoked in this "ending" interception point from being - // invoked in another "ending" interception point. - --this->stack_size_; - - this->interceptors_[this->stack_size_]->send_exception ( - ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); -} - -ACE_INLINE void -TAO_ServerRequestInterceptor_Adapter:: -send_other (PortableInterceptor::ServerRequestInfo_ptr ri, - CORBA::Environment &ACE_TRY_ENV) -{ - // This is an "ending" server side interception point so we only - // process the interceptors pushed on to the flow stack. - - // Notice that the interceptors are processed in the opposite order - // they were pushed onto the stack since this is an "ending" server - // side interception point. - - // Unwind the flow stack. - size_t len = this->stack_size_; - for (size_t i = 0; i < len; ++i) - { - // Pop the interceptor off of the flow stack before it is - // invoked. This is necessary to prevent an interceptor already - // invoked in this "ending" interception point from being - // invoked in another "ending" interception point. - --this->stack_size_; - - this->interceptors_[this->stack_size_]->send_other ( - ri - TAO_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - ACE_UNUSED_ARG (ACE_TRY_ENV); -} |