reSIProcate
SIP stack, Dialog Usage Manager and related libraries
Loading...
Searching...
No Matches
resip::ProtonThreadBase Class Reference

#include <ProtonThreadBase.hxx>

Inheritance diagram for resip::ProtonThreadBase:
[legend]

Classes

class  ProtonReceiverBase
 
class  ProtonSenderBase
 

Public Member Functions

 ProtonThreadBase (std::chrono::duration< long int > mRetryDelay=std::chrono::seconds(2))
 
virtual ~ProtonThreadBase ()
 
void addReceiver (std::shared_ptr< ProtonReceiverBase > rx)
 
void addSender (std::shared_ptr< ProtonSenderBase > tx)
 
std::shared_ptr< ProtonSenderBase > getSenderForReply (const std::string &replyTo)
 
void on_container_start (proton::container &c) override
 
void on_connection_open (proton::connection &conn) override
 
void on_receiver_open (proton::receiver &) override
 
void on_receiver_close (proton::receiver &) override
 
void on_sender_open (proton::sender &) override
 
void on_sender_close (proton::sender &) override
 
void on_transport_error (proton::transport &t) override
 
void on_message (proton::delivery &d, proton::message &m) override
 
void on_sendable (proton::sender &s) override
 
void on_tracker_accept (proton::tracker &t) override
 
virtual void thread () override
 
virtual void shutdown () override
 
- Public Member Functions inherited from resip::ThreadIf
 ThreadIf ()
 
virtual ~ThreadIf ()
 
virtual void run ()
 
void join ()
 
void detach ()
 
virtual bool waitForShutdown (int ms) const
 
bool isShutdown () const
 

Additional Inherited Members

- Public Types inherited from resip::ThreadIf
typedef std::thread::id Id
 
typedef pthread_key_t TlsKey
 
typedef void TlsDestructor(void *)
 
- Static Public Member Functions inherited from resip::ThreadIf
static Id selfId ()
 
static int tlsKeyCreate (TlsKey &key, TlsDestructor *destructor)
 This function follows pthread_key_create() signature.
 
static int tlsKeyDelete (TlsKey key)
 This function follows pthread_key_delete() signature.
 
static int tlsSetValue (TlsKey key, const void *val)
 This function follows pthread_setspecific() signature.
 
static void * tlsGetValue (TlsKey key)
 This function follows pthread_getspecific() signature.
 
- Protected Attributes inherited from resip::ThreadIf
std::shared_ptr< std::thread > mThreadObj
 
Id mId
 
bool mShutdown
 
Mutex mShutdownMutex
 
Condition mShutdownCondition
 

Detailed Description

Definition at line 22 of file ProtonThreadBase.hxx.

Constructor & Destructor Documentation

◆ ProtonThreadBase()

ProtonThreadBase::ProtonThreadBase ( std::chrono::duration< long int >  mRetryDelay = std::chrono::seconds(2))

Definition at line 107 of file ProtonThreadBase.cxx.

◆ ~ProtonThreadBase()

ProtonThreadBase::~ProtonThreadBase ( )
virtual

Definition at line 113 of file ProtonThreadBase.cxx.

Member Function Documentation

◆ addReceiver()

void ProtonThreadBase::addReceiver ( std::shared_ptr< ProtonReceiverBase >  rx)

Definition at line 157 of file ProtonThreadBase.cxx.

◆ addSender()

void ProtonThreadBase::addSender ( std::shared_ptr< ProtonSenderBase >  tx)

Definition at line 167 of file ProtonThreadBase.cxx.

◆ getSenderForReply()

std::shared_ptr< ProtonThreadBase::ProtonSenderBase > ProtonThreadBase::getSenderForReply ( const std::string &  replyTo)

Definition at line 177 of file ProtonThreadBase.cxx.

◆ on_connection_open()

void ProtonThreadBase::on_connection_open ( proton::connection &  conn)
override

Definition at line 199 of file ProtonThreadBase.cxx.

◆ on_container_start()

void ProtonThreadBase::on_container_start ( proton::container &  c)
override

Definition at line 185 of file ProtonThreadBase.cxx.

◆ on_message()

void ProtonThreadBase::on_message ( proton::delivery &  d,
proton::message &  m 
)
override

Definition at line 256 of file ProtonThreadBase.cxx.

◆ on_receiver_close()

void ProtonThreadBase::on_receiver_close ( proton::receiver &  r)
override

Definition at line 222 of file ProtonThreadBase.cxx.

◆ on_receiver_open()

void ProtonThreadBase::on_receiver_open ( proton::receiver &  r)
override

Definition at line 207 of file ProtonThreadBase.cxx.

◆ on_sendable()

void ProtonThreadBase::on_sendable ( proton::sender &  s)
override

Definition at line 323 of file ProtonThreadBase.cxx.

◆ on_sender_close()

void ProtonThreadBase::on_sender_close ( proton::sender &  r)
override

Definition at line 244 of file ProtonThreadBase.cxx.

◆ on_sender_open()

void ProtonThreadBase::on_sender_open ( proton::sender &  s)
override

Definition at line 228 of file ProtonThreadBase.cxx.

◆ on_tracker_accept()

void ProtonThreadBase::on_tracker_accept ( proton::tracker &  t)
override

Definition at line 356 of file ProtonThreadBase.cxx.

◆ on_transport_error()

void ProtonThreadBase::on_transport_error ( proton::transport &  t)
override

Definition at line 250 of file ProtonThreadBase.cxx.

◆ shutdown()

void ProtonThreadBase::shutdown ( )
overridevirtual

Reimplemented from resip::ThreadIf.

Definition at line 398 of file ProtonThreadBase.cxx.

◆ thread()

void ProtonThreadBase::thread ( )
overridevirtual

Implements resip::ThreadIf.

Definition at line 374 of file ProtonThreadBase.cxx.


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