diff options
Diffstat (limited to 'ACE/TAO/tao/PI_Server/ServerInterceptorAdapter.h')
| -rw-r--r-- | ACE/TAO/tao/PI_Server/ServerInterceptorAdapter.h | 187 |
1 files changed, 187 insertions, 0 deletions
diff --git a/ACE/TAO/tao/PI_Server/ServerInterceptorAdapter.h b/ACE/TAO/tao/PI_Server/ServerInterceptorAdapter.h new file mode 100644 index 00000000000..ad9893d4ba5 --- /dev/null +++ b/ACE/TAO/tao/PI_Server/ServerInterceptorAdapter.h @@ -0,0 +1,187 @@ +// -*- C++ -*- + +//============================================================================= +/** + * @file ServerInterceptorAdapter.h + * + * $Id$ + * + * This file contains a helper class to simplify the support of + * interceptors in TAO_IDL generated skeletons. + * + * @author Nanbor Wang <nanbor@cs.wustl.edu> + * @author Ossama Othman <ossama@uci.edu> + * @author Kirthika Parameswaran <kirthika@cs.wustl.edu> + */ +//============================================================================= + +#ifndef TAO_SERVER_INTERCEPTOR_ADAPTER_H +#define TAO_SERVER_INTERCEPTOR_ADAPTER_H + +#include /**/ "ace/pre.h" + +#include "tao/orbconf.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +#if TAO_HAS_INTERCEPTORS == 1 + +#include "tao/PI_Server/PI_Server_includeC.h" + +#include "tao/PI/Interceptor_List_T.h" +#include "tao/ServerRequestInterceptor_Adapter.h" +#include "tao/PI/RequestInterceptor_Adapter_Impl.h" +#include "tao/Basic_Types.h" +#include "tao/PI_Server/ServerRequestDetails.h" + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +namespace TAO +{ + typedef Interceptor_List< ::PortableInterceptor::ServerRequestInterceptor, + ServerRequestDetails> + ServerRequestInterceptor_List; +} + +namespace CORBA +{ + class PolicyList; +} + +class TAO_ServerRequest; + +namespace TAO +{ + class ServerRequestInfo; + + /** + * @class ServerRequestInterceptor_Adapter_Impl + * + * @brief ServerRequestInterceptor_Adapter_Impl + * + * A convenient helper class to invoke registered server request + * interceptor(s). + */ + class ServerRequestInterceptor_Adapter_Impl + : public ServerRequestInterceptor_Adapter + , public TAO_RequestInterceptor_Adapter_Impl + { + public: + /// Constructor. + ServerRequestInterceptor_Adapter_Impl (void); + + /** + * @name PortableInterceptor Server Side Interception Points + * + * Each of these methods corresponds to a server side interception + * point. + */ + //@{ +#if TAO_HAS_EXTENDED_FT_INTERCEPTORS == 1 + /// This method implements the "starting" server side interception + /// point. It will be used as the first interception point and it is + /// proprietary to TAO. + void tao_ft_interception_point ( + TAO_ServerRequest &server_request, + TAO::Argument * const args[], + size_t nargs, + void * servant_upcall, + CORBA::TypeCode_ptr const * exceptions, + CORBA::ULong nexceptions, + CORBA::OctetSeq_out oc); +#endif /*TAO_HAS_EXTENDED_FT_INTERCEPTORS*/ + + /// This method implements the "intermediate" server side + /// interception point if the above #ifdef is set to 1 and a + /// starting intercetion point if it is not set to 1. + /// + /// @note This method should have been the "starting" interception + /// point according to the interceptor spec. This will be + /// fixed once Bug 1369 is completely done. + void receive_request_service_contexts ( + TAO_ServerRequest &server_request, + TAO::Argument * const args[], + size_t nargs, + void * servant_upcall, + CORBA::TypeCode_ptr const * exceptions, + CORBA::ULong nexceptions); + + /// This method an "intermediate" server side interception point. + void receive_request ( + TAO_ServerRequest &server_request, + TAO::Argument * const args[], + size_t nargs, + void * servant_upcall, + CORBA::TypeCode_ptr const * exceptions, + CORBA::ULong nexceptions); + + /// This method implements one of the "ending" server side + /// interception points. + void send_reply ( + TAO_ServerRequest &server_request, + TAO::Argument * const args[], + size_t nargs, + void * servant_upcall, + CORBA::TypeCode_ptr const * exceptions, + CORBA::ULong nexceptions); + + /// This method implements one of the "ending" server side + /// interception points. + void send_exception ( + TAO_ServerRequest &server_request, + TAO::Argument * const args[], + size_t nargs, + void * servant_upcall, + CORBA::TypeCode_ptr const * exceptions, + CORBA::ULong nexceptions); + + /// This method implements one of the "ending" server side + /// interception points. + void send_other ( + TAO_ServerRequest &server_request, + TAO::Argument * const args[], + size_t nargs, + void * servant_upcall, + CORBA::TypeCode_ptr const * exceptions, + CORBA::ULong nexceptions); + //@} + + /// Register an interceptor. + virtual void add_interceptor ( + PortableInterceptor::ServerRequestInterceptor_ptr interceptor + ); + + virtual void add_interceptor ( + PortableInterceptor::ServerRequestInterceptor_ptr interceptor, + const CORBA::PolicyList& policies); + + virtual void destroy_interceptors (void); + + virtual TAO::PICurrent_Impl *allocate_pi_current (void); + + virtual void deallocate_pi_current (TAO::PICurrent_Impl *picurrent); + + virtual void execute_command ( + TAO_ServerRequest &server_request, + TAO::Upcall_Command &command); + + void popTSC (TAO_ORB_Core *orb_core) + {TAO_RequestInterceptor_Adapter_Impl::popTSC (orb_core);} + void pushTSC (TAO_ORB_Core *orb_core) + {TAO_RequestInterceptor_Adapter_Impl::pushTSC (orb_core);} + + private: + /// List of registered interceptors. + ServerRequestInterceptor_List interceptor_list_; + }; +} // End namespace TAO + +TAO_END_VERSIONED_NAMESPACE_DECL + +#endif /* TAO_HAS_INTERCEPTORS */ + +#include /**/ "ace/post.h" + +#endif /* TAO_SERVER_INTERCEPTOR_ADAPTER_H */ |