diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators.cpp | 387 |
1 files changed, 0 insertions, 387 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators.cpp b/TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators.cpp deleted file mode 100644 index 76cafa96275..00000000000 --- a/TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators.cpp +++ /dev/null @@ -1,387 +0,0 @@ -// ======================================================================== -// $Id$ -// -// = LIBRARY -// orbsvcs -// -// = FILENAME -// Offer_Iterators.cpp -// -// = AUTHOR -// Marina Spivak <marina@cs.wustl.edu> -// Seth Widoff <sbw1@cs.wustl.edu> -// -// ======================================================================== - -#include "Offer_Iterators.h" - -ACE_RCSID(Trader, Offer_Iterators, "$Id$") - - // ************************************************************* - // TAO_Offer_Iterator - // ************************************************************* - -TAO_Offer_Iterator::TAO_Offer_Iterator (const TAO_Property_Filter& pfilter) - : pfilter_ (pfilter) -{ -} - -TAO_Offer_Iterator::~TAO_Offer_Iterator (void) -{ -} - -void -TAO_Offer_Iterator::destroy (CORBA::Environment& env) - TAO_THROW_SPEC ((CORBA::SystemException)) -{ - // Remove self from POA - // - // Note that there is no real error checking here as we can't do - // much about errors here anyway - // - - TAO_TRY - { - PortableServer::POA_var poa = this->_default_POA (TAO_TRY_ENV); - TAO_CHECK_ENV; - - PortableServer::ObjectId_var id = poa->servant_to_id (this, TAO_TRY_ENV); - TAO_CHECK_ENV; - - poa->deactivate_object (id.in (), TAO_TRY_ENV); - } - TAO_CATCHANY - { - } - TAO_ENDTRY; - - delete this; -} - - // ************************************************************* - // TAO_Query_Only_Offer_Iterator - // ************************************************************* - -TAO_Query_Only_Offer_Iterator:: -TAO_Query_Only_Offer_Iterator(const TAO_Property_Filter& pfilter) - : TAO_Offer_Iterator (pfilter) -{ -} - -TAO_Query_Only_Offer_Iterator::~TAO_Query_Only_Offer_Iterator(void) -{ -} - -void -TAO_Query_Only_Offer_Iterator::add_offer (CosTrading::OfferId offer_id, - const CosTrading::Offer* offer) -{ - this->offers_.enqueue_tail ((CosTrading::Offer*) offer); - CORBA::string_free (offer_id); -} - -CORBA::ULong -TAO_Query_Only_Offer_Iterator::max_left (CORBA::Environment& _env) - TAO_THROW_SPEC((CORBA::SystemException, - CosTrading::UnknownMaxLeft)) -{ - return this->offers_.size (); -} - -CORBA::Boolean -TAO_Query_Only_Offer_Iterator::next_n (CORBA::ULong n, - CosTrading::OfferSeq_out offers, - CORBA::Environment& _env) - TAO_THROW_SPEC ((CORBA::SystemException)) -{ - offers = new CosTrading::OfferSeq; - - CORBA::ULong sequence_size = this->offers_.size (); - CORBA::ULong offers_in_sequence = (n < sequence_size) ? n : sequence_size; - offers->length (offers_in_sequence); - - // populate the sequence. - for (CORBA::ULong i = 0; i < offers_in_sequence; i++) - { - - CosTrading::Offer *source = 0; - this->offers_.dequeue_head (source); - this->pfilter_.filter_offer (source, offers[i]); - } - - return offers_in_sequence != 0; -} - - // ************************************************************* - // TAO_Offer_Iterator_Collection - // ************************************************************* - -TAO_Offer_Iterator_Collection::TAO_Offer_Iterator_Collection (void) -{ -} - -TAO_Offer_Iterator_Collection::~TAO_Offer_Iterator_Collection (void) -{ - while (! this->iters_.is_empty ()) - { - CosTrading::OfferIterator* offer_iter; - this->iters_.dequeue_head (offer_iter); - - TAO_TRY - { - offer_iter->destroy (TAO_TRY_ENV); - TAO_CHECK_ENV; - - CORBA::release (offer_iter); - } - TAO_CATCHANY {} - TAO_ENDTRY; - } -} - -void -TAO_Offer_Iterator_Collection:: -add_offer_iterator (CosTrading::OfferIterator_ptr offer_iter) -{ - if (! CORBA::is_nil (offer_iter)) - this->iters_.enqueue_tail (offer_iter); -} - -CORBA::Boolean -TAO_Offer_Iterator_Collection::next_n (CORBA::ULong n, - CosTrading::OfferSeq_out offers, - CORBA::Environment &env) - TAO_THROW_SPEC ((CORBA::SystemException)) -{ - CORBA::ULong offers_left = n; - CORBA::Boolean return_value = CORBA::B_TRUE; - CosTrading::OfferSeq_var out_offers; - - ACE_NEW_RETURN (offers, CosTrading::OfferSeq, return_value); - while (offers_left > 0 && ! this->iters_.is_empty ()) - { - CORBA::ULong offset = 0; - CORBA::Boolean any_left = CORBA::B_FALSE; - CosTrading::OfferIterator* iter = 0; - this->iters_.dequeue_head (iter); - - // Determine how many offers we should retrieve from this - // iterator. - - TAO_TRY - { - // Retrieve the set of offers. - any_left = - iter->next_n (offers_left, - CosTrading::OfferSeq_out (out_offers.out ()), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // If we've exhausted this iterator, destroy it. - if (any_left == CORBA::B_FALSE) - { - iter->destroy (env); - 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 (int j = out_offers->length () - 1; j >= 0; j--) - offers[j + offset] = out_offers[j]; - - offers_left -= out_offers->length (); - } - TAO_CATCHANY - { - } - TAO_ENDTRY; - } - - // Determine if we have anything left to offer. - if (this->iters_.is_empty ()) - return_value = CORBA::B_FALSE; - - return return_value; -} - -void -TAO_Offer_Iterator_Collection::destroy (CORBA::Environment& _env) - TAO_THROW_SPEC ((CORBA::SystemException)) -{ - // 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 (_env); - } - - // Remove self from POA - // - // Note that there is no real error checking here as we can't do - // much about errors here anyway - // - - TAO_TRY - { - PortableServer::POA_var poa = this->_default_POA (TAO_TRY_ENV); - TAO_CHECK_ENV; - PortableServer::ObjectId_var id = - poa->servant_to_id (this, TAO_TRY_ENV); - TAO_CHECK_ENV; - - poa->deactivate_object (id.in (), TAO_TRY_ENV); - } - TAO_CATCHANY - { - } - TAO_ENDTRY; - - delete this; -} - -CORBA::ULong -TAO_Offer_Iterator_Collection::max_left (CORBA::Environment &_env) - TAO_THROW_SPEC ((CORBA::SystemException, - CosTrading::UnknownMaxLeft)) -{ - TAO_THROW_RETURN (CosTrading::UnknownMaxLeft, 0); -} - - // ************************************************************* - // TAO_Offer_Id_Iterator - // ************************************************************* - - -TAO_Offer_Id_Iterator::TAO_Offer_Id_Iterator (void) -{ -} - -TAO_Offer_Id_Iterator::~TAO_Offer_Id_Iterator (void) -{ - int return_value = 0; - - do - { - CosTrading::OfferId offer_id = 0; - - return_value = this->ids_.dequeue_head (offer_id); - if (return_value == 0) - CORBA::string_free (offer_id); - } - while (return_value == 0); -} - -CORBA::ULong -TAO_Offer_Id_Iterator::max_left (CORBA::Environment& env) - TAO_THROW_SPEC ((CORBA::SystemException, - CosTrading::UnknownMaxLeft)) -{ - return this->ids_.size (); -} - -void -TAO_Offer_Id_Iterator::destroy (CORBA::Environment& _env) - TAO_THROW_SPEC ((CORBA::SystemException)) -{ - // Remove self from POA - // - // Note that there is no real error checking here as we can't do - // much about errors here anyway - // - - TAO_TRY - { - PortableServer::POA_var poa = this->_default_POA (TAO_TRY_ENV); - TAO_CHECK_ENV; - - PortableServer::ObjectId_var id = poa->servant_to_id (this, TAO_TRY_ENV); - TAO_CHECK_ENV; - - poa->deactivate_object (id.in (), TAO_TRY_ENV); - } - TAO_CATCHANY - { - } - TAO_ENDTRY; - - delete this; -} - -CORBA::Boolean -TAO_Offer_Id_Iterator::next_n (CORBA::ULong n, - CosTrading::OfferIdSeq_out _ids, - CORBA::Environment& _env) - TAO_THROW_SPEC ((CORBA::SystemException)) -{ - // Calculate the number of Ids to be returned in this. - int items_left = this->ids_.size(), - difference = items_left - n, - returnable_items = (difference >= 0) ? n : items_left; - CORBA::Boolean return_value = (CORBA::Boolean) (difference > 0); - - if (returnable_items == 0) - { - ACE_NEW_RETURN (_ids, CosTrading::OfferIdSeq, return_value); - } - else - { - // Allocate space for the returned OfferIds. - CosTrading::OfferId* id_buf = - CosTrading::OfferIdSeq::allocbuf (returnable_items); - - if (id_buf != 0) - { - // Copy in those ids! - for (int i = 0; i < returnable_items; i++) - { - CosTrading::OfferId offer_id = 0; - - this->ids_.dequeue_head (offer_id); - id_buf[i] = offer_id; - } - - // Place them into an OfferIdSeq. - ACE_NEW_RETURN (_ids, - CosTrading::OfferIdSeq (returnable_items, - returnable_items, - id_buf, - 1), - return_value); - } - else - ACE_NEW_RETURN (_ids, CosTrading::OfferIdSeq, return_value); - } - - // Return true only if there are items left to be returned in - // subsequent calls. - return return_value; -} - -void -TAO_Offer_Id_Iterator::insert_id (CosTrading::OfferId new_id) -{ - this->ids_.enqueue_tail (new_id); -} - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_Node <CosTrading::Offer*>; -template class ACE_Unbounded_Queue <CosTrading::Offer*>; -template class ACE_Unbounded_Queue_Iterator <CosTrading::Offer*>; -template class ACE_Node <CosTrading::OfferIterator*>; -template class ACE_Unbounded_Queue <CosTrading::OfferIterator*>; -template class ACE_Unbounded_Queue_Iterator <CosTrading::OfferIterator*>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_Node <CosTrading::Offer*> -#pragma instantiate ACE_Unbounded_Queue <CosTrading::Offer*> -#pragma instantiate ACE_Unbounded_Queue_Iterator <CosTrading::Offer*> -#pragma instantiate ACE_Node <CosTrading::OfferIterator*> -#pragma instantiate ACE_Unbounded_Queue <CosTrading::OfferIterator*> -#pragma instantiate ACE_Unbounded_Queue_Iterator <CosTrading::OfferIterator*> -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |