Public Types | |
typedef ACE_Hash_Map_Manager < u64, Descr, ACE_Null_Mutex > | Base |
Public Member Functions | |
Queue () | |
Queue (u64 sn) | |
Queue (Queue const &q) | |
int | bind (u64 sn, Descr const &d) |
int | rebind (u64 sn, Descr const &d) |
int | unbind (u64 sn) |
u64 | sn () const |
void | sn (u64 sn) |
u64 | max_sn () const |
Private Attributes | |
u64 | sn_ |
u64 | max_sn_ |
Definition at line 123 of file Acknowledge.h.
Definition at line 125 of file Acknowledge.h.
ACE_RMCast::Acknowledge::Queue::Queue | ( | ) | [inline] |
Definition at line 129 of file Acknowledge.h.
: Base (ACE_RMCAST_DEFAULT_MAP_SIZE), sn_ (0), max_sn_ (0) { }
ACE_RMCast::Acknowledge::Queue::Queue | ( | u64 | sn | ) | [inline] |
Definition at line 134 of file Acknowledge.h.
ACE_RMCast::Acknowledge::Queue::Queue | ( | Queue const & | q | ) | [inline] |
Definition at line 139 of file Acknowledge.h.
: Base (ACE_RMCAST_DEFAULT_MAP_SIZE), sn_ (q.sn_), max_sn_ (sn_) { for (Queue::const_iterator i (q), e (q, 1); i != e; ++i) { bind ((*i).ext_id_, (*i).int_id_); } }
Definition at line 150 of file Acknowledge.h.
{ int r (Base::bind (sn, d)); if (r == 0 && sn > max_sn_) max_sn_ = sn; return r; }
u64 ACE_RMCast::Acknowledge::Queue::max_sn | ( | ) | const [inline] |
Definition at line 199 of file Acknowledge.h.
{ if (current_size () == 0) return sn_; return max_sn_; }
Definition at line 160 of file Acknowledge.h.
{ int r (Base::rebind (sn, d)); if (r == 0 && sn > max_sn_) max_sn_ = sn; return r; }
u64 ACE_RMCast::Acknowledge::Queue::sn | ( | ) | const [inline] |
Definition at line 187 of file Acknowledge.h.
{ return sn_; }
void ACE_RMCast::Acknowledge::Queue::sn | ( | u64 | sn | ) | [inline] |
Definition at line 193 of file Acknowledge.h.
{ sn_ = sn; }
int ACE_RMCast::Acknowledge::Queue::unbind | ( | u64 | sn | ) | [inline] |
u64 ACE_RMCast::Acknowledge::Queue::max_sn_ [private] |
Definition at line 207 of file Acknowledge.h.
u64 ACE_RMCast::Acknowledge::Queue::sn_ [private] |
Definition at line 207 of file Acknowledge.h.