TAO_Offer_Iterator_Collection Class Reference

#include <Offer_Iterators.h>

Collaboration diagram for TAO_Offer_Iterator_Collection:

[legend]List of all members.

Public Member Functions
	TAO_Offer_Iterator_Collection (void)
virtual	~TAO_Offer_Iterator_Collection (void)
virtual CORBA::Boolean	next_n (CORBA::ULong n, CosTrading::OfferSeq_out offers)
	Retrieve n offers from the set of iterators.
virtual void	destroy (void)
	Destroy the collection of iterators.
virtual CORBA::ULong	max_left (void)
	Determine how many offers are left in the collection.
void	add_offer_iterator (CosTrading::OfferIterator_ptr offer_iter)
	Add an iterator to the collection.
Private Types
typedef ACE_Unbounded_Queue< CosTrading::OfferIterator * >	Offer_Iters
Private Member Functions
	TAO_Offer_Iterator_Collection (const TAO_Offer_Iterator_Collection &)
TAO_Offer_Iterator_Collection &	operator= (const TAO_Offer_Iterator_Collection &)
Private Attributes
Offer_Iters	iters_
	The iterator collection.

---

Detailed Description

Definition at line 156 of file Offer_Iterators.h.

---

Member Typedef Documentation

typedef ACE_Unbounded_Queue<CosTrading::OfferIterator*> TAO_Offer_Iterator_Collection::Offer_Iters [private]

Definition at line 199 of file Offer_Iterators.h.

---

Constructor & Destructor Documentation

TAO_Offer_Iterator_Collection::TAO_Offer_Iterator_Collection

(

void

)

Definition at line 78 of file Offer_Iterators.cpp.

{
}

TAO_Offer_Iterator_Collection::~TAO_Offer_Iterator_Collection

(

void

)

[virtual]

Definition at line 82 of file Offer_Iterators.cpp.

References ACE_Unbounded_Queue< T >::dequeue_head(), iters_, and CORBA::release().

{
  while (! this->iters_.is_empty ())
    {
      CosTrading::OfferIterator* offer_iter = 0;
      this->iters_.dequeue_head (offer_iter);

      try
        {
          offer_iter->destroy ();

          CORBA::release (offer_iter);
        }
      catch (const CORBA::Exception&)
        {
          // Don't let the exceptions propagate since we're in a
          // destructor!
        }
    }
}

TAO_Offer_Iterator_Collection::TAO_Offer_Iterator_Collection

(

const TAO_Offer_Iterator_Collection &

)

[private]

---

Member Function Documentation

void TAO_Offer_Iterator_Collection::add_offer_iterator

(

CosTrading::OfferIterator_ptr

offer_iter

)

Add an iterator to the collection.

Definition at line 105 of file Offer_Iterators.cpp.

References ACE_Unbounded_Queue< T >::enqueue_tail(), CORBA::is_nil(), and iters_.

Referenced by TAO_Lookup< TRADER_LOCK_TYPE, MAP_LOCK_TYPE >::federated_query().

{
  if (! CORBA::is_nil (offer_iter))
    this->iters_.enqueue_tail (offer_iter);
}

void TAO_Offer_Iterator_Collection::destroy

(

void

)

[virtual]

Destroy the collection of iterators.

Definition at line 164 of file Offer_Iterators.cpp.

{
  // Destroy all iterators in the collection.
  for (Offer_Iters::ITERATOR iters_iter (this->iters_);
       ! iters_iter.done ();
       iters_iter.advance ())
    {
      CosTrading::OfferIterator** iter = 0;

      iters_iter.next (iter);
      (*iter)->destroy ();
    }

  // Remove self from POA

  PortableServer::POA_var poa =
    this->_default_POA ();

  PortableServer::ObjectId_var id =
    poa->servant_to_id (this);

  poa->deactivate_object (id.in ());
}

CORBA::ULong TAO_Offer_Iterator_Collection::max_left

(

void

)

[virtual]

Determine how many offers are left in the collection.

Definition at line 189 of file Offer_Iterators.cpp.

{
  throw CosTrading::UnknownMaxLeft();
}

CORBA::Boolean TAO_Offer_Iterator_Collection::next_n	(	CORBA::ULong	n,
		CosTrading::OfferSeq_out	offers
	)			[virtual]

Retrieve n offers from the set of iterators.

Definition at line 112 of file Offer_Iterators.cpp.

References ACE_NEW_THROW_EX, ACE_Unbounded_Queue< T >::dequeue_head(), CosTrading::OfferIterator::destroy(), ACE_Unbounded_Queue< T >::enqueue_head(), iters_, CosTrading::OfferIterator::next_n(), and CORBA::release().

{
  CORBA::ULong offers_left = n;
  CORBA::Boolean return_value = 1;
  CosTrading::OfferSeq_var out_offers;

  ACE_NEW_THROW_EX (offers,
                    CosTrading::OfferSeq,
                    CORBA::NO_MEMORY ());

  while (offers_left > 0 && ! this->iters_.is_empty ())
    {
      CORBA::ULong offset = 0;
      CORBA::Boolean any_left = 0;
      CosTrading::OfferIterator* iter =  0;
      this->iters_.dequeue_head (iter);

      // Determine how many offers we should retrieve from this
      // iterator.

      // Retrieve the set of offers.
      any_left =
        iter->next_n (offers_left,
                      CosTrading::OfferSeq_out (out_offers.out ()));

      // If we've exhausted this iterator, destroy it.
      if (any_left == 0)
        {
          iter->destroy ();
          CORBA::release (iter);
        }
      else
        this->iters_.enqueue_head (iter);

      // Merge it with the passed set.
      offset = offers->length ();
      offers->length (out_offers->length () + offset);
      for (CORBA::ULong j = out_offers->length (); j > 0; j--)
        offers[j + offset - 1] = out_offers[j - 1];

      offers_left -= out_offers->length ();
    }

  // Determine if we have anything left to offer.
  if (this->iters_.is_empty ())
    return_value = 0;

  return return_value;
}

TAO_Offer_Iterator_Collection& TAO_Offer_Iterator_Collection::operator=

(

const TAO_Offer_Iterator_Collection &

)

[private]

---

Member Data Documentation

Offer_Iters TAO_Offer_Iterator_Collection::iters_ [private]

The iterator collection.

Definition at line 202 of file Offer_Iterators.h.

Referenced by add_offer_iterator(), next_n(), and ~TAO_Offer_Iterator_Collection().

---

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

• Offer_Iterators.h
• Offer_Iterators.cpp

---