1 files changed, 97 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators_T.cpp b/TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators_T.cpp
new file mode 100644
index 00000000000..f8ad8bd3a6f
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators_T.cpp
@@ -0,0 +1,97 @@
+// $Id$
+
+#ifndef TAO_OFFER_ITERATORS_T_CPP
+#define TAO_OFFER_ITERATORS_T_CPP
+
+#include "orbsvcs/Trader/Offer_Iterators_T.h"
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+template <class MAP_LOCK_TYPE>
+TAO_Register_Offer_Iterator<MAP_LOCK_TYPE>::
+TAO_Register_Offer_Iterator (TAO_Offer_Database<MAP_LOCK_TYPE> &db,
+                             const TAO_Property_Filter& pfilter)
+  : TAO_Offer_Iterator (pfilter),
+    db_ (db)
+{
+}
+
+template <class MAP_LOCK_TYPE>
+TAO_Register_Offer_Iterator<MAP_LOCK_TYPE>::
+~TAO_Register_Offer_Iterator (void)
+{
+  while (! this->offer_ids_.is_empty ())
+    {
+      CosTrading::OfferId offer_id = 0;
+      this->offer_ids_.dequeue_head (offer_id);
+
+      CORBA::string_free (offer_id);
+    }
+}
+
+template <class MAP_LOCK_TYPE> void
+TAO_Register_Offer_Iterator<MAP_LOCK_TYPE>::
+add_offer (CosTrading::OfferId id,
+           const CosTrading::Offer* /* offer */)
+{
+  this->offer_ids_.enqueue_tail (id);
+}
+
+template <class MAP_LOCK_TYPE> CORBA::ULong
+TAO_Register_Offer_Iterator<MAP_LOCK_TYPE>::
+max_left (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException,
+                  CosTrading::UnknownMaxLeft))
+{
+  return static_cast<CORBA::ULong> (this->offer_ids_.size ());
+}
+
+template <class MAP_LOCK_TYPE> CORBA::Boolean
+TAO_Register_Offer_Iterator<MAP_LOCK_TYPE>::
+next_n (CORBA::ULong n,
+        CosTrading::OfferSeq_out offers
+        ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  CORBA::ULong ret_offers = 0;
+
+  CORBA::ULong max_possible_offers_in_sequence =
+    (n <  this->offer_ids_.size ()) ? n :
+       static_cast<CORBA::ULong> (this->offer_ids_.size ());
+
+  ACE_NEW_THROW_EX (offers,
+                    CosTrading::OfferSeq,
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK_RETURN (0);
+
+  offers->length (max_possible_offers_in_sequence);
+
+  // While there are entries left and we haven't filled <offers>
+  // with requested number.
+  while (! this->offer_ids_.is_empty ()
+         && n > ret_offers)
+    {
+      // If offer is found, put it into the sequence.
+      // remove this id irrespective of whether the offer is found
+      // or not.
+      CosTrading::OfferId id = 0;
+      this->offer_ids_.dequeue_head (id);
+
+      CosTrading::OfferId_var offerid_var (id);
+      CosTrading::Offer* offer = this->db_.lookup_offer (id ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (0);
+
+      if (offer != 0)
+        this->pfilter_.filter_offer (offer,
+                                     offers[ret_offers++]);
+    }
+
+  // Reset the length to the correct value
+  offers->length (ret_offers);
+
+  return static_cast<CORBA::Boolean> (ret_offers != 0);
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#endif /* TAO_REGISTER_OFFER_ITERATOR_CPP */