summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Trader/Offer_Iterators_T.h
blob: e2f21ef876f5d234e7fa7d7a32d0c7081e8ff07f (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
/* -*- C++ -*- */
// $Id$

// ========================================================================
//
// = LIBRARY
//    orbsvcs
//
// = FILENAME
//    Offer_Iterators_T.h
//
// = AUTHOR
//    Marina Spivak <marina@cs.wustl.edu>
//    Seth Widoff <sbw1@cs.wustl.edu>
//
// ========================================================================

#ifndef TAO_REGISTER_OFFER_ITERATOR_H
#define TAO_REGISTER_OFFER_ITERATOR_H

#include "Offer_Iterators.h"
#include "Offer_Database.h"

template <class MAP_LOCK_TYPE>
class TAO_Register_Offer_Iterator : public TAO_Offer_Iterator
{
  // = TITLE
  //     An implementation of CosTrading::OfferIterator IDL interface
  //     appropriate when trader has Register functionality.
  //
  // = DESCRIPTION
  //     Stores ids of offers to be iterated over.  Before returning
  //     an offer, checks if the offer is still there (since it may
  //     have been removed by the Register).
public:

  // = Initialization and termination methods.

  TAO_Register_Offer_Iterator (TAO_Offer_Database<MAP_LOCK_TYPE> &db,
                               const TAO_Property_Filter& pfilter);
  // Takes service type and trader reference in order to
  // later locate offers using their ids.

  virtual ~TAO_Register_Offer_Iterator (void);
  // destructor.

  virtual CORBA::Boolean next_n (CORBA::ULong n,
                                 CosTrading::OfferSeq_out offers,
                                 CORBA::Environment &)
    ACE_THROW_SPEC ((CORBA::SystemException));
  // Deposit at maximum n offers into the return sequence and return 1,
  // or return 0 if the iterator is done and no offers are returned.

  virtual CORBA::ULong max_left (CORBA::Environment &)
    ACE_THROW_SPEC ((CORBA::SystemException,
                    CosTrading::UnknownMaxLeft));
  // Throws CosTrading::UnknownMaxLeft since with the presence of
  // "Register" functionality, the iterator cannot guarantee that
  // the trader will have all the offers it has now when the time
  // to return them comes.

  void add_offer (CosTrading::OfferId id,
                  const CosTrading::Offer *);
  // Add an offer the iterator should iterate over.

private:

  TAO_Offer_Database<MAP_LOCK_TYPE> &db_;
  // A reference to the trader is needed for access to the map of offers.

  TAO_String_Queue offer_ids_;
  // Offer ids of offers to iterate over.
};


#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
#include "Offer_Iterators_T.cpp"
#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */

#endif /* TAO_REGISTER_OFFER_ITERATOR_H */