ACE_RMCast  6.4.2
Classes | Public Member Functions | Private Types | Private Member Functions | Static Private Member Functions | Private Attributes | List of all members
ACE_RMCast::Acknowledge Class Reference

#include <Acknowledge.h>

Inheritance diagram for ACE_RMCast::Acknowledge:
Inheritance graph
[legend]
Collaboration diagram for ACE_RMCast::Acknowledge:
Collaboration graph
[legend]

Classes

struct  Descr
 
struct  Queue
 

Public Member Functions

 Acknowledge (Parameters const &params)
 
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)
 
- Public Member Functions inherited from ACE_RMCast::In_Element
virtual ~In_Element ()
 
 In_Element ()
 
virtual void in_stop ()
 
- Public Member Functions inherited from ACE_RMCast::Out_Element
virtual ~Out_Element ()
 
 Out_Element ()
 

Private Types

typedef ACE_Hash_Map_Manager_Ex< Address, Queue, AddressHasher, ACE_Equal_To< Address >, ACE_Null_MutexMap
 

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

- Protected Attributes inherited from ACE_RMCast::In_Element
In_Elementin_
 
- Protected Attributes inherited from ACE_RMCast::Out_Element
Out_Elementout_
 

Member Typedef Documentation

Constructor & Destructor Documentation

ACE_RMCast::Acknowledge::Acknowledge ( Parameters const &  params)

Member Function Documentation

void ACE_RMCast::Acknowledge::collapse ( Queue q)
private
Profile_ptr ACE_RMCast::Acknowledge::create_nrtm ( u32  max_elem)
private
void ACE_RMCast::Acknowledge::in_start ( In_Element in)
virtual

Reimplemented from ACE_RMCast::In_Element.

void ACE_RMCast::Acknowledge::out_start ( Out_Element out)
virtual

Reimplemented from ACE_RMCast::Out_Element.

void ACE_RMCast::Acknowledge::out_stop ( )
virtual

Reimplemented from ACE_RMCast::Out_Element.

void ACE_RMCast::Acknowledge::recv ( Message_ptr  m)
virtual

Reimplemented from ACE_RMCast::In_Element.

void ACE_RMCast::Acknowledge::send ( Message_ptr  m)
virtual

Reimplemented from ACE_RMCast::Out_Element.

void ACE_RMCast::Acknowledge::track ( )
private
void ACE_RMCast::Acknowledge::track_queue ( Address const &  addr,
Queue q,
Messages msgs 
)
private
ACE_THR_FUNC_RETURN ACE_RMCast::Acknowledge::track_thunk ( void *  obj)
staticprivate

Member Data Documentation

Condition ACE_RMCast::Acknowledge::cond_
private
Map ACE_RMCast::Acknowledge::hold_
private
Mutex ACE_RMCast::Acknowledge::mutex_
private
unsigned long ACE_RMCast::Acknowledge::nrtm_timer_
private
Parameters const& ACE_RMCast::Acknowledge::params_
private
bool ACE_RMCast::Acknowledge::stop_
private
ACE_Thread_Manager ACE_RMCast::Acknowledge::tracker_mgr_
private

The documentation for this class was generated from the following files: