

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.
1.7.0