// -*- C++ -*-

//=============================================================================
/**
 *  @file     GIOP_Message_State.h
 *
 *   GIOP utility definitions
 *
 *  @author  Chris Cleeland <cleeland@cs.wustl.edu>
 *  @author  Carlos O' Ryan <coryan@uci.edu>
 *  @author  Balachandran Natarajan <bala@cs.wustl.edu>
 *  @author  Johnny Willemsen <jwillemsen@remedy.nl>
 */
//=============================================================================
#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 */

#include "tao/GIOPC.h"

TAO_BEGIN_VERSIONED_NAMESPACE_DECL

/**
 * @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:
  /// Constructor
  TAO_GIOP_Message_State () = default;
  ~TAO_GIOP_Message_State () = default;

  /// 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 () const;

  /// Return the message size
  CORBA::ULong payload_size () const;

  /// Return the byte order information
  CORBA::Octet byte_order () const;

  /// Return the message type
  GIOP::MsgType message_type () const;

  /// Return the more fragments
  CORBA::Boolean more_fragments () const;

  void more_fragments (CORBA::Boolean fragment);

  /// Get the GIOP version
  TAO_GIOP_Message_Version const &giop_version () const;

  /// Return the compressed information
  CORBA::Boolean compressed () const;

private:
  /// Parse the message header.
  int parse_message_header_i (ACE_Message_Block &incoming);

  /// Checks for the magic word 'GIOP' in the start of the incoming
  /// 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 @a 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_ {TAO_DEF_GIOP_MAJOR, TAO_DEF_GIOP_MINOR};

  /// 0 = big, 1 = little
  CORBA::Octet byte_order_ {0};

  /// MsgType above
  GIOP::MsgType message_type_ {GIOP::Request};

  /// In byte_order!
  CORBA::ULong payload_size_ {0};

  /// (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::Boolean more_fragments_ {false};

  /// Compressed
  CORBA::Boolean compressed_ {false};
};

TAO_END_VERSIONED_NAMESPACE_DECL

constexpr size_t TAO_GIOP_MESSAGE_HEADER_LEN = 12;
constexpr size_t TAO_GIOP_MESSAGE_SIZE_OFFSET = 8;
constexpr size_t TAO_GIOP_MESSAGE_FLAGS_OFFSET = 6;
constexpr size_t TAO_GIOP_MESSAGE_TYPE_OFFSET  = 7;
constexpr size_t TAO_GIOP_VERSION_MINOR_OFFSET = 5;
constexpr size_t TAO_GIOP_VERSION_MAJOR_OFFSET = 4;
constexpr 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*/