TAO_ECG_CDR_Message_Receiver::Mcast_Header Struct Reference

Helper for decoding, validating and storing mcast header. More...

#include <ECG_CDR_Message_Receiver.h>

List of all members.

Public Member Functions
int	read (char *header, size_t bytes_received, CORBA::Boolean checkcrc=0)
Public Attributes
int	byte_order
CORBA::ULong	request_id
CORBA::ULong	request_size
CORBA::ULong	fragment_size
CORBA::ULong	fragment_offset
CORBA::ULong	fragment_id
CORBA::ULong	fragment_count
CORBA::ULong	crc

---

Detailed Description

Helper for decoding, validating and storing mcast header.

Definition at line 240 of file ECG_CDR_Message_Receiver.h.

---

Member Function Documentation

int TAO_ECG_CDR_Message_Receiver::Mcast_Header::read	(	char *	header,
		size_t	bytes_received,
		CORBA::Boolean	checkcrc = 0
	)

Definition at line 530 of file ECG_CDR_Message_Receiver.cpp.

References ACE_ERROR_RETURN, ACE_NTOHL, byte_order, crc, TAO_ECG_CDR_Message_Sender::ECG_HEADER_SIZE, LM_ERROR, ACE_InputCDR::read_boolean(), ACE_InputCDR::read_octet(), ACE_InputCDR::read_octet_array(), and ACE_InputCDR::read_ulong().

Referenced by TAO_ECG_CDR_Message_Receiver::handle_input().

{
  // Decode.
  this->byte_order = header[0];
  if(this->byte_order != 0 && this->byte_order != 1)
    {
      ACE_ERROR_RETURN ((LM_ERROR, "Reading mcast packet header: byte "
                                   "order is neither 0 nor 1, it is %d.\n",
                         this->byte_order),
                        -1);
    }

  TAO_InputCDR header_cdr (header,
                           TAO_ECG_CDR_Message_Sender::ECG_HEADER_SIZE,
                           byte_order);
  CORBA::Boolean unused;
  CORBA::Octet a, b, c;
  if (!header_cdr.read_boolean (unused)
      || !header_cdr.read_octet (a)
      || !header_cdr.read_octet (b)
      || !header_cdr.read_octet (c)
      || a != 'A' || b != 'B' || c != 'C')
    {
      ACE_ERROR_RETURN ((LM_ERROR, "Error reading magic bytes "
                                   "in mcast packet header.\n"),
                        -1);
    }

  if (!header_cdr.read_ulong (this->request_id)
      || !header_cdr.read_ulong (this->request_size)
      || !header_cdr.read_ulong (this->fragment_size)
      || !header_cdr.read_ulong (this->fragment_offset)
      || !header_cdr.read_ulong (this->fragment_id)
      || !header_cdr.read_ulong (this->fragment_count))
    {
      ACE_ERROR_RETURN ((LM_ERROR,
                        "Error decoding mcast packet header.\n"),
                        -1);
    }

  if (checkcrc)
    {
      CORBA::Octet padding[4];
      header_cdr.read_octet_array (padding, 4);

      unsigned char *crcparts = (unsigned char *)(&this->crc);

      for (int cnt=0; cnt != 4; ++cnt)
        {
          crcparts[cnt] = padding[cnt];
        }

      this->crc = ACE_NTOHL (this->crc);
    }

  // Validate.
  size_t const data_bytes_received =
    bytes_received - TAO_ECG_CDR_Message_Sender::ECG_HEADER_SIZE;

  if (this->request_size < this->fragment_size
      || this->fragment_offset >= this->request_size
      || this->fragment_id >= this->fragment_count
      || (this->fragment_count == 1
          && (this->fragment_size != this->request_size
              || this->request_size != data_bytes_received)))
    {
      ACE_ERROR_RETURN ((LM_ERROR,
                        "Invalid mcast fragment: "
                        "inconsistent header fields.\n"),
                        -1);
    }

  return 0;
}

---

Member Data Documentation

int TAO_ECG_CDR_Message_Receiver::Mcast_Header::byte_order

Definition at line 242 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::handle_input(), TAO_ECG_CDR_Message_Receiver::process_fragment(), and read().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Mcast_Header::crc

Definition at line 249 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::handle_input(), and read().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Mcast_Header::fragment_count

Definition at line 248 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::handle_input(), and TAO_ECG_CDR_Message_Receiver::process_fragment().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Mcast_Header::fragment_id

Definition at line 247 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::process_fragment().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Mcast_Header::fragment_offset

Definition at line 246 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::process_fragment().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Mcast_Header::fragment_size

Definition at line 245 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::process_fragment().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Mcast_Header::request_id

Definition at line 243 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::handle_input(), and TAO_ECG_CDR_Message_Receiver::process_fragment().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Mcast_Header::request_size

Definition at line 244 of file ECG_CDR_Message_Receiver.h.

Referenced by TAO_ECG_CDR_Message_Receiver::handle_input(), and TAO_ECG_CDR_Message_Receiver::process_fragment().

---

The documentation for this struct was generated from the following files:

• ECG_CDR_Message_Receiver.h
• ECG_CDR_Message_Receiver.cpp

---