ACE_RMCast::Acknowledge Class Reference

#include <Acknowledge.h>

Inheritance diagram for ACE_RMCast::Acknowledge:

Collaboration diagram for ACE_RMCast::Acknowledge:

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_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
Protected Attributes inherited from ACE_RMCast::In_Element
In_Element *	in_
Protected Attributes inherited from ACE_RMCast::Out_Element
Out_Element *	out_

Member Typedef Documentation

Map

typedef ACE_Hash_Map_Manager_Ex<Address, Queue, AddressHasher, ACE_Equal_To<Address>, ACE_Null_Mutex> ACE_RMCast::Acknowledge::Map

private

Constructor & Destructor Documentation

Acknowledge()

ACE_RMCast::Acknowledge::Acknowledge

(

Parameters const &

params

)

Member Function Documentation

collapse()

void ACE_RMCast::Acknowledge::collapse ( Queue & q )

private

create_nrtm()

Profile_ptr ACE_RMCast::Acknowledge::create_nrtm ( u32 max_elem )

private

in_start()

void ACE_RMCast::Acknowledge::in_start ( In_Element * in )

virtual

Reimplemented from ACE_RMCast::In_Element.

out_start()

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

virtual

Reimplemented from ACE_RMCast::Out_Element.

out_stop()

void ACE_RMCast::Acknowledge::out_stop ( )

virtual

Reimplemented from ACE_RMCast::Out_Element.

recv()

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

virtual

Reimplemented from ACE_RMCast::In_Element.

send()

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

virtual

Reimplemented from ACE_RMCast::Out_Element.

track()

void ACE_RMCast::Acknowledge::track ( )

private

track_queue()

void ACE_RMCast::Acknowledge::track_queue ( Address const & addr, Queue & q, Messages & msgs )

private

track_thunk()

ACE_THR_FUNC_RETURN ACE_RMCast::Acknowledge::track_thunk ( void * obj )

staticprivate

Member Data Documentation

cond_

Condition ACE_RMCast::Acknowledge::cond_

private

hold_

Map ACE_RMCast::Acknowledge::hold_

private

mutex_

Mutex ACE_RMCast::Acknowledge::mutex_

private

nrtm_timer_

unsigned long ACE_RMCast::Acknowledge::nrtm_timer_

private

params_

Parameters const& ACE_RMCast::Acknowledge::params_

private

stop_

bool ACE_RMCast::Acknowledge::stop_

private

tracker_mgr_

ACE_Thread_Manager ACE_RMCast::Acknowledge::tracker_mgr_

private

---

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

• Acknowledge.h
• Acknowledge.cpp