// -*- C++ -*- // =================================================================== /** * @file PICurrent.h * * $Id$ * * @author Ossama Othman */ // =================================================================== #ifndef TAO_PI_CURRENT_H #define TAO_PI_CURRENT_H #include /**/ "ace/pre.h" #include "tao/TAO_Export.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ #include "orbconf.h" #if TAO_HAS_INTERCEPTORS == 1 #include "ace/Array_Base.h" #include "Any.h" #include "PICurrentC.h" #include "LocalObject.h" #if defined(_MSC_VER) # pragma warning(push) # pragma warning(disable:4250) # pragma warning(disable:4251) #endif /* _MSC_VER */ /// Forward declarations. class TAO_ORB_Core; namespace TAO { class PICurrent_Copy_Callback; class PICurrent_Impl; /** * @class PICurrent * * @brief Implementation of the PortableInterceptor::Current * interface. * * PortableInterceptor::Current is useful for passing data between * request interceptors, in addition to passing data from an * interceptor to the calling thread. */ class TAO_Export PICurrent : public virtual PortableInterceptor::Current, public virtual TAO_Local_RefCounted_Object { public: /// Constructor. PICurrent (TAO_ORB_Core *orb_core); /** * @name PortableInterceptor::Current Methods * * These are methods exposed by the PortableInterceptor::Current * interface. */ //@{ /// Retrieve information stored in the slot table at the given /// SlotId. virtual CORBA::Any *get_slot (PortableInterceptor::SlotId id ACE_ENV_ARG_DECL_WITH_DEFAULTS) ACE_THROW_SPEC ((CORBA::SystemException, PortableInterceptor::InvalidSlot)); /// Set information in the slot table at the given SlotId. virtual void set_slot (PortableInterceptor::SlotId identifier, const CORBA::Any & data ACE_ENV_ARG_DECL_WITH_DEFAULTS) ACE_THROW_SPEC ((CORBA::SystemException, PortableInterceptor::InvalidSlot)); //@} /// Number of slots allocated in the slot table. PortableInterceptor::SlotId slot_count (void) const; /// Retrieve the PICurrent implementation from TSS, i.e. the thread /// scope current (TSC). PICurrent_Impl * tsc (void); /// Verify the validity of the given SlotId. void check_validity (const PortableInterceptor::SlotId &identifier ACE_ENV_ARG_DECL); /// Initialize the PICurrent object. void initialize (PortableInterceptor::SlotId sc); protected: /// Destructor /** * Protected destructor to enforce the fact this class is reference * counted, and should not be destroyed using delete() by anything * other than the reference counting mechanism. */ ~PICurrent (void); private: /// Prevent copying through the copy constructor and the assignment /// operator. //@{ PICurrent (const PICurrent &); void operator= (const PICurrent &); //@} private: /// Pointer to the orb core. TAO_ORB_Core * orb_core_; /// The number of allocated slots. PortableInterceptor::SlotId slot_count_; }; } #if defined (__ACE_INLINE__) # include "PICurrent.inl" #endif /* __ACE_INLINE__ */ #if defined(_MSC_VER) #pragma warning(pop) #endif /* _MSC_VER */ #endif /* TAO_HAS_INTERCEPTORS == 1 */ #include /**/ "ace/post.h" #endif /* TAO_PI_CURRENT_H */