1 files changed, 136 insertions, 0 deletions
diff --git a/TAO/tao/GIOP_Message_State.h b/TAO/tao/GIOP_Message_State.h
new file mode 100644
index 00000000000..9de7eee5b7e
--- /dev/null
+++ b/TAO/tao/GIOP_Message_State.h
@@ -0,0 +1,136 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file     GIOP_Message_State.h
+ *
+ *  $Id$
+ *
+ *   GIOP utility definitions
+ *
+ *
+ *  @author  Chris Cleeland <cleeland@cs.wustl.edu>
+ *  @author  Carlos O' Ryan <coryan@uci.edu>
+ *  @author  Balachandran Natarajan <bala@cs.wustl.edu>
+ */
+//=============================================================================
+#ifndef TAO_GIOP_MESSAGE_STATE_H
+#define TAO_GIOP_MESSAGE_STATE_H
+
+#include /**/ "ace/pre.h"
+
+#include "tao/GIOP_Message_Version.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+class TAO_ORB_Core;
+class TAO_GIOP_Message_Base;
+
+
+/**
+ * @class TAO_GIOP_Message_State
+ *
+ * @brief Generic definitions for Message States.
+ *
+ *  This helps to establish the state of the incoming messages.
+ */
+
+class TAO_Export TAO_GIOP_Message_State
+{
+public:
+
+  /// Ctor
+  TAO_GIOP_Message_State (void);
+
+  /// Parse the message header.
+  ///
+  /// \return -1 There was some error parsing the GIOP header
+  /// \return 0  The GIOP header was parsed correctly
+  /// \return 1  There was not enough data in the message block to
+  ///            parse the header
+  int parse_message_header (ACE_Message_Block &incoming);
+
+  /// Return the message size
+  CORBA::ULong message_size (void) const;
+
+  /// Return the message size
+  CORBA::ULong payload_size (void) const;
+
+  /// Return the byte order information
+  CORBA::Octet byte_order (void) const;
+
+  /// Reset the state..
+  void reset (void);
+
+private:
+
+  friend class TAO_GIOP_Message_Base;
+
+  /// Parse the message header.
+  int parse_message_header_i (ACE_Message_Block &incoming);
+
+  /// Checks for the magic word 'GIOP' in the start of the incoing
+  /// stream
+  int parse_magic_bytes (char *buf);
+
+  /// Extracts the version information from the incoming
+  /// stream. Performs a check for  whether the version information is
+  /// right and sets the information in the <state>
+  int get_version_info (char *buf);
+
+  /// Extracts the byte order information from the incoming
+  /// stream. Performs a check for  whether the byte order information
+  /// right and sets the information in the <state>
+  int get_byte_order_info (char *buf);
+
+  /// Gets the size of the payload and set the size in the <state>
+  void get_payload_size (char *buf);
+
+  /// Read the unsigned long from the buffer. The <buf> should just
+  /// point to the next 4 bytes data that represent the ULong
+  CORBA::ULong read_ulong (const char *buf) const;
+
+private:
+  // GIOP version information..
+  TAO_GIOP_Message_Version giop_version_;
+
+  /// 0 = big, 1 = little
+  CORBA::Octet byte_order_;
+
+  /// MsgType above
+  CORBA::Octet message_type_;
+
+  /// in byte_order!
+  CORBA::ULong message_size_;
+
+  /// (Requests and Replys)
+  /// A value of zero indicates that this message does not have any
+  /// fragments.  A value of non-zero indicates that it does have
+  /// fragments.
+  CORBA::Octet more_fragments_;
+
+  /// Missing data
+  CORBA::ULong missing_data_;
+};
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+static const size_t TAO_GIOP_MESSAGE_HEADER_LEN = 12;
+static const size_t TAO_GIOP_MESSAGE_SIZE_OFFSET = 8;
+static const size_t TAO_GIOP_MESSAGE_FLAGS_OFFSET = 6;
+static const size_t TAO_GIOP_MESSAGE_TYPE_OFFSET  = 7;
+static const size_t TAO_GIOP_VERSION_MINOR_OFFSET = 5;
+static const size_t TAO_GIOP_VERSION_MAJOR_OFFSET = 4;
+static const size_t TAO_GIOP_MESSAGE_FRAGMENT_HEADER = 4;
+
+#if defined (__ACE_INLINE__)
+# include "tao/GIOP_Message_State.inl"
+#endif /* __ACE_INLINE__ */
+
+#include /**/ "ace/post.h"
+#endif /*TAO_GIOP_MESSAGE_STATE_H*/