diff options
Diffstat (limited to 'TAO/tao/GIOP_Utils.h')
| -rw-r--r-- | TAO/tao/GIOP_Utils.h | 268 |
1 files changed, 0 insertions, 268 deletions
diff --git a/TAO/tao/GIOP_Utils.h b/TAO/tao/GIOP_Utils.h deleted file mode 100644 index 4578663402a..00000000000 --- a/TAO/tao/GIOP_Utils.h +++ /dev/null @@ -1,268 +0,0 @@ -// -*- C++ -*- -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// TAO -// -// = FILENAME -// GIOP_Message.h -// -// = DESCRIPTION -// GIOP utility definitions -// -// = AUTHOR -// Chris Cleeland <cleeland@cs.wustl.edu> -// Carlos O' Ryan <coryan@uci.edu> -// -// ============================================================================ -#ifndef TAO_GIOP_UTILS_H -#define TAO_GIOP_UTILS_H -#include "tao/Pluggable_Messaging.h" -#include "tao/Object.h" - - - -typedef enum GIOP_Messages -{ - // = DESCRIPTION - // All GIOP messages include a header and message type. Not - // really a message type, but needed to bring that information - // back somehow. - - // = GIOP message types. - TAO_GIOP_REQUEST = 0, // sent by client. - TAO_GIOP_REPLY = 1, // by server. - TAO_GIOP_CANCELREQUEST = 2, // by client. - TAO_GIOP_LOCATEREQUEST = 3, // by client. - TAO_GIOP_LOCATEREPLY = 4, - TAO_GIOP_CLOSECONNECTION = 5, - TAO_GIOP_MESSAGERROR = 6, // by both. - TAO_GIOP_FRAGMENT = 7 // by both. -}TAO_GIOP_Message_Type; - - -typedef enum GIOP_LocateStatusType -{ - TAO_GIOP_UNKNOWN_OBJECT, - TAO_GIOP_OBJECT_HERE, - TAO_GIOP_OBJECT_FORWARD, - TAO_GIOP_OBJECT_FORWARD_PERM, //GIOP1.2 - TAO_GIOP_LOC_SYSTEM_EXCEPTION, // GIOP1.2 - TAO_GIOP_LOC_NEEDS_ADDRESSING_MODE //GIOP 1.2 -}TAO_GIOP_Locate_Status_Type; - - - -class TAO_GIOP_Locate_Status_Msg -{ - // =TITLE - // Hold the relevant information for every type of Locate mesg. - // - // =DESCRIPTION - // This class is there to hold the relevant info for different - // types of locate status messages. As on date we dont know much - // about other mesg types other than OBJECT_FORWARD. This clss can - // be clearly defined as time progresses. - // -public: - CORBA::Object_var forward_location_var; - // The value will need to be used when the Message type is - // TAO_GIOP_OBJECT_FORWARD - - TAO_GIOP_Locate_Status_Type status; - // Stype of Locate status message - //@@ Other mesg types. -}; - - -typedef enum GIOP_ReplyStatusType -{ - TAO_GIOP_NO_EXCEPTION, - // Request completed successfully - - TAO_GIOP_USER_EXCEPTION, - // Request terminated with user exception - - TAO_GIOP_SYSTEM_EXCEPTION, - // Request terminated with system exception - - TAO_GIOP_LOCATION_FORWARD, - // Reply is a location forward type - - TAO_GIOP_LOCATION_FORWARD_PERM, - // GIOP 1.2, Reply is a location forward perm type.. - - NEEDS_ADDRESSING_MODE - // GIOP1.2, - -} TAO_GIOP_Reply_Status_Type; - - -class TAO_GIOP_ReplyHeader -{ - // = TITLE - // This class embodies the header of a GIOP reply. - // @@Not used. Could be used in future -public: - IOP::ServiceContextList service_info; - // Information - - CORBA::ULong request_id; - // Unique identifier of the request for which this is a reply. - - TAO_GIOP_Reply_Status_Type reply_status; - // Status of the reply (see above enum). - -}; - - -class TAO_Export TAO_GIOP_Version -{ - // = TITLE - // Major and Minor version number of the Inter-ORB Protocol. -public: - CORBA::Octet major; - // Major version number - - CORBA::Octet minor; - // Minor version number - - TAO_GIOP_Version (const TAO_GIOP_Version &src); - // Copy constructor - - TAO_GIOP_Version (CORBA::Octet maj = TAO_DEF_GIOP_MAJOR, - CORBA::Octet min = TAO_DEF_GIOP_MINOR); - // Default constructor. - - ~TAO_GIOP_Version (void); - // Destructor. - - void set_version (CORBA::Octet maj, CORBA::Octet min); - // Explicitly set the major and minor version. - - TAO_GIOP_Version &operator= (const TAO_GIOP_Version &src); - // Copy operator. - - int operator== (const TAO_GIOP_Version &src); - int operator!= (const TAO_GIOP_Version &src); - // Equality operator -}; - - -class TAO_Export TAO_GIOP_Message_State: public TAO_Message_State_Factory -{ - // = TITLE - // Generic definitions for Message States. - // - // = DESCRIPTION - // This would represnt the state of the incoming message states. - // As the ORB processes incoming messages it need to keep track of - // how much of the message has been read. if there are any - // fragments following this message etc. This class attempts to - // give a generic interface to all the messaging protocols message - // states so that the Transport layer does not really know with - // whom it is interacting with. -public: - TAO_GIOP_Message_State (TAO_ORB_Core *orb_core); - // Ctor - - ~TAO_GIOP_Message_State (void); - // Dtor - - void reset (int reset_contents = 1); - //Reset the message header state and prepare it to receive the next - // event. - - CORBA::Boolean header_received (void) const; - // Has the header been received? - - int is_complete (void); - // Check if the current message is complete, adjusting the fragments - // if required... - - TAO_GIOP_Version giop_version; - // Version info - - CORBA::Octet byte_order; - // 0 = big, 1 = little - - CORBA::Octet more_fragments; - // (Requests and Replys) - - CORBA::Octet message_type; - // MsgType above - - CORBA::ULong message_size; - // in byte_order! - - CORBA::ULong current_offset; - // How much of the payload has been received - - TAO_InputCDR cdr; - // This is the InputCDR that will be used to decode the message. - - ACE_Message_Block* fragments_begin; - ACE_Message_Block* fragments_end; - // The fragments are collected in a chain of message blocks (using - // the cont() field). When the complete message is received the - // chain is reassembled into <cdr> - - CORBA::Octet first_fragment_byte_order; - // The byte order for the the first fragment - // @@ The current implementation cannot handle fragments with - // different byte orders, this should not be a major problem - // because: - // 1) It is unlikely that we are going to receive fragments. - // 2) The spec *seems* to allow different byte_orders, but it is - // unlikely that any ORB will do that. - // 3) Even if we allowed that at this layer the CDR classes are - // not prepared to handle that. - - TAO_GIOP_Version first_fragment_giop_version; - // The GIOP version for the first fragment - // @@ Same as above, all GIOP versions must match. - - CORBA::Octet first_fragment_message_type; - // If the messages are chained this represents the message type for - // the *complete* message (remember that the last message will be - // fragment and the upper level needs to know if it is a request, - // locate request or what). - - -private: - int append_fragment (ACE_Message_Block* current); - // Append <current> to the list of fragments - // Also resets the state, because the current message was consumed. - -}; - -class TAO_Export TAO_GIOP_Utils -{ - // = TITLE - // Utility class that has some commonly used methods for both GIOP - // Base & GIOP lite - - // = DESCRIPTION -public: - static int read_bytes_input (TAO_Transport *transport, - TAO_InputCDR &cdr, - CORBA::ULong buf_size, - ACE_Time_Value *value = 0); - - static ssize_t read_buffer (TAO_Transport *transport, - char *buf, - size_t len, - ACE_Time_Value *max_wait_time = 0); - - static TAO_GIOP_Reply_Status_Type - convert_CORBA_to_GIOP_exception (CORBA::exception_type corba_type); - // Convert the exception type from CORBA to GIOP -}; - -#if defined (__ACE_INLINE__) -# include "tao/GIOP_Utils.i" -#endif /* __ACE_INLINE__ */ - -#endif /*TAO_GIOP_UTILS_H */ |