ACE_RMCast
6.1.8
|
#include <Acknowledge.h>
Classes | |
struct | Descr |
struct | Queue |
Public Member Functions | |
Acknowledge (Parameters const ¶ms) | |
virtual void | in_start (In_Element *in) |
virtual void | out_start (Out_Element *out) |
virtual void | out_stop () |
virtual void | recv (Message_ptr m) |
virtual void | send (Message_ptr m) |
Private Types | |
typedef ACE_Hash_Map_Manager_Ex < Address, Queue, AddressHasher, ACE_Equal_To < Address >, ACE_Null_Mutex > | Map |
Private Member Functions | |
void | collapse (Queue &q) |
void | track () |
void | track_queue (Address const &addr, Queue &q, Messages &msgs) |
Profile_ptr | create_nrtm (u32 max_elem) |
Static Private Member Functions | |
static ACE_THR_FUNC_RETURN | track_thunk (void *obj) |
Private Attributes | |
Parameters const & | params_ |
Map | hold_ |
Mutex | mutex_ |
Condition | cond_ |
unsigned long | nrtm_timer_ |
bool | stop_ |
ACE_Thread_Manager | tracker_mgr_ |
Additional Inherited Members | |
![]() | |
In_Element * | in_ |
![]() | |
Out_Element * | out_ |
|
private |
ACE_RMCast::Acknowledge::Acknowledge | ( | Parameters const & | params | ) |
|
private |
|
private |
|
virtual |
Reimplemented from ACE_RMCast::In_Element.
|
virtual |
Reimplemented from ACE_RMCast::Out_Element.
|
virtual |
Reimplemented from ACE_RMCast::Out_Element.
|
virtual |
Reimplemented from ACE_RMCast::In_Element.
|
virtual |
Reimplemented from ACE_RMCast::Out_Element.
|
private |
|
private |
|
staticprivate |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |