diff options
Diffstat (limited to 'ACE/TAO/tao/TAO_Server_Request.inl')
| -rw-r--r-- | ACE/TAO/tao/TAO_Server_Request.inl | 263 |
1 files changed, 263 insertions, 0 deletions
diff --git a/ACE/TAO/tao/TAO_Server_Request.inl b/ACE/TAO/tao/TAO_Server_Request.inl new file mode 100644 index 00000000000..ef3532f4c6c --- /dev/null +++ b/ACE/TAO/tao/TAO_Server_Request.inl @@ -0,0 +1,263 @@ +// -*- C++ -*- +// +// $Id$ + +#include "tao/GIOP_Utils.h" + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +// This constructor is used by the CSD clone. +ACE_INLINE +TAO_ServerRequest::TAO_ServerRequest (void) + : mesg_base_ (0), + operation_ (0), + operation_len_ (0), + release_operation_ (false), + incoming_ (0), + outgoing_ (0), + response_expected_ (false), + deferred_reply_ (false), + sync_with_server_ (false), + is_dsi_ (false), + reply_status_ (GIOP::NO_EXCEPTION), + orb_core_ (0), + request_id_ (0), + profile_ (0), + requesting_principal_ (0), + dsi_nvlist_align_ (0), + operation_details_ (0), + argument_flag_ (true) +#if TAO_HAS_INTERCEPTORS == 1 + , interceptor_count_ (0) + , rs_pi_current_ () + , caught_exception_ (0) + , pi_reply_status_ (-1) +#endif /* TAO_HAS_INTERCEPTORS == 1 */ + , transport_(0) +{ +} + +ACE_INLINE TAO_ORB_Core * +TAO_ServerRequest::orb_core (void) const +{ + return this->orb_core_; +} + +ACE_INLINE TAO_InputCDR * +TAO_ServerRequest::incoming (void) const +{ + return this->incoming_; +} + +ACE_INLINE TAO_OutputCDR * +TAO_ServerRequest::outgoing (void) const +{ + return this->outgoing_; +} + +ACE_INLINE const char * +TAO_ServerRequest::operation (void) const +{ + return (this->operation_ == 0 ? "" : this->operation_); +} + +ACE_INLINE void +TAO_ServerRequest::operation (const char *operation, + size_t length, + int release) +{ + if (this->release_operation_) + CORBA::string_free (const_cast <char*> (this->operation_)); + + this->operation_len_ = (length == 0 ? ACE_OS::strlen (operation) : length); + this->release_operation_ = release; + this->operation_ = operation; +} + +ACE_INLINE size_t +TAO_ServerRequest::operation_length (void) const +{ + return this->operation_len_; +} + +ACE_INLINE CORBA::Boolean +TAO_ServerRequest::response_expected (void) const +{ + return this->response_expected_; +} + +ACE_INLINE CORBA::Boolean +TAO_ServerRequest::deferred_reply (void) const +{ + return this->deferred_reply_; +} + +ACE_INLINE void +TAO_ServerRequest::response_expected (CORBA::Boolean response) +{ + this->response_expected_ = response; +} + +ACE_INLINE CORBA::Boolean +TAO_ServerRequest::sync_with_server (void) const +{ + return this->sync_with_server_; +} + +ACE_INLINE void +TAO_ServerRequest::sync_with_server (CORBA::Boolean sync_flag) +{ + this->sync_with_server_ = sync_flag; +} + +ACE_INLINE TAO::ObjectKey & +TAO_ServerRequest::object_key (void) +{ + return this->profile_.object_key (); +} + +ACE_INLINE TAO_Service_Context & +TAO_ServerRequest::request_service_context (void) +{ + return this->request_service_context_; +} + +ACE_INLINE IOP::ServiceContextList & +TAO_ServerRequest::reply_service_info (void) +{ + return this->reply_service_context ().service_info (); +} + +ACE_INLINE IOP::ServiceContextList & +TAO_ServerRequest::request_service_info (void) +{ + return this->request_service_context ().service_info (); +} + +ACE_INLINE TAO_Transport * +TAO_ServerRequest::transport (void) +{ + return this->transport_.get (); +} + +ACE_INLINE CORBA::ULong +TAO_ServerRequest::request_id (void) +{ + return this->request_id_; +} + +ACE_INLINE void +TAO_ServerRequest::request_id (CORBA::ULong req) +{ + this->request_id_ = req; +} + +ACE_INLINE void +TAO_ServerRequest::requesting_principal (const CORBA::OctetSeq &principal) +{ + this->requesting_principal_ = principal; +} + +ACE_INLINE TAO_Tagged_Profile & +TAO_ServerRequest::profile (void) +{ + return this->profile_; +} + +ACE_INLINE void +TAO_ServerRequest::forward_location (CORBA::Object_ptr forward_reference) +{ + this->forward_location_ = + CORBA::Object::_duplicate (forward_reference); + this->is_forwarded_ = true; +} + +ACE_INLINE CORBA::Object_ptr +TAO_ServerRequest::forward_location (void) +{ + return CORBA::Object::_duplicate (this->forward_location_.in ()); +} + +ACE_INLINE bool +TAO_ServerRequest::is_forwarded (void) const +{ + return this->is_forwarded_; +} + +ACE_INLINE GIOP::ReplyStatusType +TAO_ServerRequest::reply_status (void) +{ + return this->reply_status_; +} + +ACE_INLINE void +TAO_ServerRequest::reply_status (GIOP::ReplyStatusType reply_status) +{ + this->reply_status_ = reply_status; +} + +ACE_INLINE void +TAO_ServerRequest::is_dsi (void) +{ + this->is_dsi_ = true; +} + +ACE_INLINE TAO_Operation_Details const * +TAO_ServerRequest::operation_details (void) const +{ + return this->operation_details_; +} + +ACE_INLINE void +TAO_ServerRequest::dsi_nvlist_align (ptrdiff_t alignment) +{ + this->dsi_nvlist_align_ = alignment; +} + +ACE_INLINE CORBA::Boolean +TAO_ServerRequest::argument_flag (void) +{ + return this->argument_flag_; +} + +ACE_INLINE void +TAO_ServerRequest::argument_flag (CORBA::Boolean flag) +{ + this->argument_flag_ = flag; +} + +ACE_INLINE bool +TAO_ServerRequest::collocated (void) const +{ + return this->transport_.get () == 0; +} + + +#if TAO_HAS_INTERCEPTORS == 1 +ACE_INLINE size_t & +TAO_ServerRequest::interceptor_count (void) +{ + return this->interceptor_count_; +} + +ACE_INLINE CORBA::Exception * +TAO_ServerRequest::caught_exception (void) +{ + return this->caught_exception_; +} + +ACE_INLINE void +TAO_ServerRequest::pi_reply_status (PortableInterceptor::ReplyStatus s) +{ + this->pi_reply_status_ = s; +} + +ACE_INLINE PortableInterceptor::ReplyStatus +TAO_ServerRequest::pi_reply_status (void) +{ + return this->pi_reply_status_; +} + +#endif /* TAO_HAS_INTERCEPTORS == 1 */ + +TAO_END_VERSIONED_NAMESPACE_DECL |