ACE_RMCast 8.0.5
Loading...
Searching...
No Matches
ACE_RMCast::Socket_Impl Class Reference
Inheritance diagram for ACE_RMCast::Socket_Impl:
Collaboration diagram for ACE_RMCast::Socket_Impl:

Public Member Functions

 ~Socket_Impl ()
 Socket_Impl (Address const &a, bool loop, Parameters const &params)
void send_ (void const *buf, size_t s)
ssize_t recv_ (void *buf, size_t s, ACE_Time_Value const *timeout, ACE_INET_Addr *from)
ssize_t size_ (ACE_Time_Value const *timeout)
ACE_HANDLE get_handle_ ()

Private Member Functions

virtual void recv (Message_ptr m)

Private Attributes

bool loop_
Parameters const params_
Mutex mutex_
Condition cond_
ACE_Unbounded_Queue< Message_ptrqueue_
ACE_Pipe signal_pipe_
std::unique_ptr< Fragmentfragment_
std::unique_ptr< Reassemblereassemble_
std::unique_ptr< Acknowledgeacknowledge_
std::unique_ptr< Retransmitretransmit_
std::unique_ptr< Flowflow_
std::unique_ptr< Linklink_

Additional Inherited Members

Protected Member Functions inherited from ACE_RMCast::In_Element
virtual ~In_Element ()
 In_Element ()
virtual void in_stop ()
virtual void in_start (In_Element *in)
Protected Member Functions inherited from ACE_RMCast::Out_Element
virtual ~Out_Element ()
 Out_Element ()
virtual void out_stop ()
virtual void out_start (Out_Element *out)
virtual void send (Message_ptr m)
Protected Attributes inherited from ACE_RMCast::In_Element
In_Elementin_
Protected Attributes inherited from ACE_RMCast::Out_Element
Out_Elementout_

Constructor & Destructor Documentation

◆ ~Socket_Impl()

ACE_RMCast::Socket_Impl::~Socket_Impl ( )

◆ Socket_Impl()

ACE_RMCast::Socket_Impl::Socket_Impl ( Address const & a,
bool loop,
Parameters const & params )

Member Function Documentation

◆ get_handle_()

ACE_HANDLE ACE_RMCast::Socket_Impl::get_handle_ ( )

◆ recv()

void ACE_RMCast::Socket_Impl::recv ( Message_ptr m)
privatevirtual

Reimplemented from ACE_RMCast::In_Element.

◆ recv_()

ssize_t ACE_RMCast::Socket_Impl::recv_ ( void * buf,
size_t s,
ACE_Time_Value const * timeout,
ACE_INET_Addr * from )

◆ send_()

void ACE_RMCast::Socket_Impl::send_ ( void const * buf,
size_t s )

◆ size_()

ssize_t ACE_RMCast::Socket_Impl::size_ ( ACE_Time_Value const * timeout)

Member Data Documentation

◆ acknowledge_

std::unique_ptr<Acknowledge> ACE_RMCast::Socket_Impl::acknowledge_
private

◆ cond_

Condition ACE_RMCast::Socket_Impl::cond_
private

◆ flow_

std::unique_ptr<Flow> ACE_RMCast::Socket_Impl::flow_
private

◆ fragment_

std::unique_ptr<Fragment> ACE_RMCast::Socket_Impl::fragment_
private

◆ link_

std::unique_ptr<Link> ACE_RMCast::Socket_Impl::link_
private

◆ loop_

bool ACE_RMCast::Socket_Impl::loop_
private

◆ mutex_

Mutex ACE_RMCast::Socket_Impl::mutex_
private

◆ params_

Parameters const ACE_RMCast::Socket_Impl::params_
private

◆ queue_

ACE_Unbounded_Queue<Message_ptr> ACE_RMCast::Socket_Impl::queue_
private

◆ reassemble_

std::unique_ptr<Reassemble> ACE_RMCast::Socket_Impl::reassemble_
private

◆ retransmit_

std::unique_ptr<Retransmit> ACE_RMCast::Socket_Impl::retransmit_
private

◆ signal_pipe_

ACE_Pipe ACE_RMCast::Socket_Impl::signal_pipe_
private

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