TAO_ECG_CDR_Message_Receiver::Requests Class Reference

#include <ECG_CDR_Message_Receiver.h>

Collaboration diagram for TAO_ECG_CDR_Message_Receiver::Requests:

[legend]List of all members.

Public Member Functions
	Requests (void)
	~Requests (void)
int	init (size_t size, size_t min_purge_count)
	Allocates and initializes <fragmented_requests_>.
TAO_ECG_UDP_Request_Entry **	get_request (CORBA::ULong request_id)
Private Member Functions
void	purge_requests (CORBA::ULong purge_first, CORBA::ULong purge_last)
Requests &	operator= (const Requests &rhs)
	Requests (const Requests &rhs)
Private Attributes
TAO_ECG_UDP_Request_Entry **	fragmented_requests_
size_t	size_
	Size of <fragmented_requests_> array.
size_t	min_purge_count_
	Minimum range shifting amount.
CORBA::ULong	id_range_low_
CORBA::ULong	id_range_high_

---

Detailed Description

Once init() has been called: Invariant: id_range_high_- id_range_low_ == size_ - 1

Definition at line 259 of file ECG_CDR_Message_Receiver.h.

---

Constructor & Destructor Documentation

TAO_ECG_CDR_Message_Receiver::Requests::Requests

(

void

)

TAO_ECG_CDR_Message_Receiver::Requests::~Requests

(

void

)

Definition at line 159 of file ECG_CDR_Message_Receiver.cpp.

References fragmented_requests_, id_range_high_, id_range_low_, TAO_ECG_CDR_Message_Receiver::Request_Completed_, and size_.

{
  for (size_t i = 0; i < this->size_; ++i)
    {
      TAO_ECG_UDP_Request_Entry* request =
        this->fragmented_requests_[i];

      if (request != &TAO_ECG_CDR_Message_Receiver::Request_Completed_)
        delete request;
    }

  delete [] this->fragmented_requests_;

  this->fragmented_requests_ = 0;
  this->size_ = 0;
  this->id_range_low_ = 0;
  this->id_range_high_ = 0;
}

TAO_ECG_CDR_Message_Receiver::Requests::Requests

(

const Requests &

rhs

)

[private]

---

Member Function Documentation

TAO_ECG_UDP_Request_Entry ** TAO_ECG_CDR_Message_Receiver::Requests::get_request

(

CORBA::ULong

request_id

)

If <request_id> < <id_range_low> return 0. If <request_id> > <id_range_high>, shift the range so it includes <request_id>, purging incomplete requests as needed.

Definition at line 179 of file ECG_CDR_Message_Receiver.cpp.

References fragmented_requests_, id_range_high_, id_range_low_, min_purge_count_, purge_requests(), and size_.

{
  if (request_id < this->id_range_low_)
    // <request_id> is below the current range.
    {
      return 0;
    }

  if (request_id > this->id_range_high_)
    // <request_id> is above the current range - need to shift the range
    // to include it.
    {
      CORBA::ULong new_slots_needed = request_id - this->id_range_high_;

      if (new_slots_needed < this->min_purge_count_)
        new_slots_needed = this->min_purge_count_;

      if (new_slots_needed > this->size_)
        // Shifting the range by more than the size of array.
        {
          this->purge_requests (this->id_range_low_, this->id_range_high_);
          this->id_range_high_ = request_id;
          this->id_range_low_ = request_id - this->size_ + 1;
        }
      else
        {
          this->purge_requests (this->id_range_low_,
                                this->id_range_low_ + new_slots_needed - 1);
          this->id_range_high_ += new_slots_needed;
          this->id_range_low_ += new_slots_needed;
        }
    }

  // Return array location for <request_id>.
  int index = request_id % this->size_;
  return this->fragmented_requests_ + index;
}

int TAO_ECG_CDR_Message_Receiver::Requests::init	(	size_t	size,
		size_t	min_purge_count
	)

Allocates and initializes <fragmented_requests_>.

Definition at line 135 of file ECG_CDR_Message_Receiver.cpp.

References ACE_NEW_RETURN, id_range_high_, id_range_low_, min_purge_count_, and size_.

{
  // Already initialized.
  if (this->fragmented_requests_)
    return -1;

  ACE_NEW_RETURN (this->fragmented_requests_,
                  TAO_ECG_UDP_Request_Entry*[size],
                  -1);

  this->size_ = size;
  this->id_range_low_ = 0;
  this->id_range_high_ = size - 1;
  this->min_purge_count_ = min_purge_count;

  for (size_t i = 0; i < size; ++i)
    {
      this->fragmented_requests_[i] = 0;
    }

  return 0;
}

Requests& TAO_ECG_CDR_Message_Receiver::Requests::operator=

(

const Requests &

rhs

)

[private]

void TAO_ECG_CDR_Message_Receiver::Requests::purge_requests	(	CORBA::ULong	purge_first,
		CORBA::ULong	purge_last
	)			[private]

Delete any outstanding requests with ids in the range [<purge_first>, <purge_last>] from <fragmented_requests> and and reset their slots.

Definition at line 219 of file ECG_CDR_Message_Receiver.cpp.

References fragmented_requests_, and TAO_ECG_CDR_Message_Receiver::Request_Completed_.

Referenced by get_request().

{
  for (CORBA::ULong i = purge_first; i <= purge_last; ++i)
    {
      size_t index = i % this->size_;
      if (this->fragmented_requests_[index]
          != &TAO_ECG_CDR_Message_Receiver::Request_Completed_)
        {
          delete this->fragmented_requests_[index];
        }
      this->fragmented_requests_[index] = 0;
    }
}

---

Member Data Documentation

TAO_ECG_UDP_Request_Entry** TAO_ECG_CDR_Message_Receiver::Requests::fragmented_requests_ [private]

Array, used in a circular fashion, that stores partially received requests (and info on which requests have been fully received and processed) for a range of request ids.

Definition at line 293 of file ECG_CDR_Message_Receiver.h.

Referenced by get_request(), purge_requests(), and ~Requests().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Requests::id_range_high_ [private]

The range of request ids, currently represented in <fragmented_requests>.

Definition at line 302 of file ECG_CDR_Message_Receiver.h.

Referenced by get_request(), init(), and ~Requests().

CORBA::ULong TAO_ECG_CDR_Message_Receiver::Requests::id_range_low_ [private]

The range of request ids, currently represented in <fragmented_requests>.

Definition at line 301 of file ECG_CDR_Message_Receiver.h.

Referenced by get_request(), init(), and ~Requests().

size_t TAO_ECG_CDR_Message_Receiver::Requests::min_purge_count_ [private]

Minimum range shifting amount.

Definition at line 306 of file ECG_CDR_Message_Receiver.h.

Referenced by get_request(), and init().

size_t TAO_ECG_CDR_Message_Receiver::Requests::size_ [private]

Size of <fragmented_requests_> array.

Definition at line 296 of file ECG_CDR_Message_Receiver.h.

Referenced by get_request(), init(), and ~Requests().

---

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

• ECG_CDR_Message_Receiver.h
• ECG_CDR_Message_Receiver.cpp

---