webkit  2cdf99a9e3038c7e01b3c37e8ad903ecbe5eecf1
https://github.com/WebKit/webkit
Classes | Public Member Functions | Public Attributes | Static Public Attributes | Protected Member Functions | Protected Attributes | List of all members
rtc::MessageQueue Class Reference

#include <messagequeue.h>

Inheritance diagram for rtc::MessageQueue:
MessageQueueTest rtc::Thread rtc::Thread CustomThread OwnerThread rtc::AutoThread rtc::AutoThread rtc::LogThread SignalWhenDestroyedThread CustomThread OwnerThread rtc::AutoThread rtc::AutoThread rtc::LogThread SignalWhenDestroyedThread

Classes

class  PriorityQueue
 

Public Member Functions

 MessageQueue (SocketServer *ss, bool init_queue)
 
 MessageQueue (std::unique_ptr< SocketServer > ss, bool init_queue)
 
virtual ~MessageQueue ()
 
SocketServer * socketserver ()
 
void set_socketserver (SocketServer *ss)
 
virtual void Quit ()
 
virtual bool IsQuitting ()
 
virtual void Restart ()
 
virtual bool IsProcessingMessages ()
 
virtual bool Get (Message *pmsg, int cmsWait=kForever, bool process_io=true)
 
virtual bool Peek (Message *pmsg, int cmsWait=0)
 
virtual void Post (const Location &posted_from, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr, bool time_sensitive=false)
 
virtual void PostDelayed (const Location &posted_from, int cmsDelay, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr)
 
virtual void PostAt (const Location &posted_from, int64_t tstamp, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr)
 
virtual void PostAt (const Location &posted_from, uint32_t tstamp, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr)
 
virtual void Clear (MessageHandler *phandler, uint32_t id=MQID_ANY, MessageList *removed=nullptr)
 
virtual void Dispatch (Message *pmsg)
 
virtual void ReceiveSends ()
 
virtual int GetDelay ()
 
bool empty () const
 
size_t size () const
 
template<class T >
void Dispose (T *doomed)
 
 MessageQueue (SocketServer *ss, bool init_queue)
 
 MessageQueue (std::unique_ptr< SocketServer > ss, bool init_queue)
 
virtual ~MessageQueue ()
 
SocketServer * socketserver ()
 
void set_socketserver (SocketServer *ss)
 
virtual void Quit ()
 
virtual bool IsQuitting ()
 
virtual void Restart ()
 
virtual bool IsProcessingMessages ()
 
virtual bool Get (Message *pmsg, int cmsWait=kForever, bool process_io=true)
 
virtual bool Peek (Message *pmsg, int cmsWait=0)
 
virtual void Post (const Location &posted_from, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr, bool time_sensitive=false)
 
virtual void PostDelayed (const Location &posted_from, int cmsDelay, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr)
 
virtual void PostAt (const Location &posted_from, int64_t tstamp, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr)
 
virtual void PostAt (const Location &posted_from, uint32_t tstamp, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr)
 
virtual void Clear (MessageHandler *phandler, uint32_t id=MQID_ANY, MessageList *removed=nullptr)
 
virtual void Dispatch (Message *pmsg)
 
virtual void ReceiveSends ()
 
virtual int GetDelay ()
 
bool empty () const
 
size_t size () const
 
template<class T >
void Dispose (T *doomed)
 

Public Attributes

sigslot::signal0 SignalQueueDestroyed
 

Static Public Attributes

static const int kForever = -1
 

Protected Member Functions

void DoDelayPost (const Location &posted_from, int64_t cmsDelay, int64_t tstamp, MessageHandler *phandler, uint32_t id, MessageData *pdata)
 
void DoInit ()
 
void DoDestroy ()
 
void WakeUpSocketServer ()
 
MessageList msgq_ GUARDED_BY (crit_)
 
PriorityQueue dmsgq_ GUARDED_BY (crit_)
 
uint32_t dmsgq_next_num_ GUARDED_BY (crit_)
 
void DoDelayPost (const Location &posted_from, int64_t cmsDelay, int64_t tstamp, MessageHandler *phandler, uint32_t id, MessageData *pdata)
 
void DoInit ()
 
void DoDestroy ()
 
void WakeUpSocketServer ()
 
MessageList msgq_ GUARDED_BY (crit_)
 
PriorityQueue dmsgq_ GUARDED_BY (crit_)
 
uint32_t dmsgq_next_num_ GUARDED_BY (crit_)
 

Protected Attributes

bool fPeekKeep_
 
Message msgPeek_
 
CriticalSection crit_
 
bool fInitialized_
 
bool fDestroyed_
 

Constructor & Destructor Documentation

◆ MessageQueue() [1/4]

rtc::MessageQueue::MessageQueue ( SocketServer *  ss,
bool  init_queue 
)

◆ MessageQueue() [2/4]

rtc::MessageQueue::MessageQueue ( std::unique_ptr< SocketServer >  ss,
bool  init_queue 
)

◆ ~MessageQueue() [1/2]

rtc::MessageQueue::~MessageQueue ( )
virtual

◆ MessageQueue() [3/4]

rtc::MessageQueue::MessageQueue ( SocketServer *  ss,
bool  init_queue 
)

◆ MessageQueue() [4/4]

rtc::MessageQueue::MessageQueue ( std::unique_ptr< SocketServer >  ss,
bool  init_queue 
)

◆ ~MessageQueue() [2/2]

virtual rtc::MessageQueue::~MessageQueue ( )
virtual

Member Function Documentation

◆ Clear() [1/2]

void rtc::MessageQueue::Clear ( MessageHandler *  phandler,
uint32_t  id = MQID_ANY,
MessageList *  removed = nullptr 
)
virtual

Reimplemented in rtc::Thread, and rtc::Thread.

◆ Clear() [2/2]

virtual void rtc::MessageQueue::Clear ( MessageHandler *  phandler,
uint32_t  id = MQID_ANY,
MessageList *  removed = nullptr 
)
virtual

Reimplemented in rtc::Thread, and rtc::Thread.

◆ Dispatch() [1/2]

virtual void rtc::MessageQueue::Dispatch ( Message *  pmsg)
virtual

◆ Dispatch() [2/2]

void rtc::MessageQueue::Dispatch ( Message *  pmsg)
virtual

◆ Dispose() [1/2]

template<class T >
void rtc::MessageQueue::Dispose ( T *  doomed)
inline

◆ Dispose() [2/2]

template<class T >
void rtc::MessageQueue::Dispose ( T *  doomed)
inline

◆ DoDelayPost() [1/2]

void rtc::MessageQueue::DoDelayPost ( const Location &  posted_from,
int64_t  cmsDelay,
int64_t  tstamp,
MessageHandler *  phandler,
uint32_t  id,
MessageData *  pdata 
)
protected

◆ DoDelayPost() [2/2]

void rtc::MessageQueue::DoDelayPost ( const Location &  posted_from,
int64_t  cmsDelay,
int64_t  tstamp,
MessageHandler *  phandler,
uint32_t  id,
MessageData *  pdata 
)
protected

◆ DoDestroy() [1/2]

void rtc::MessageQueue::DoDestroy ( )
protected

◆ DoDestroy() [2/2]

void rtc::MessageQueue::DoDestroy ( )
protected

◆ DoInit() [1/2]

void rtc::MessageQueue::DoInit ( )
protected

◆ DoInit() [2/2]

void rtc::MessageQueue::DoInit ( )
protected

◆ empty() [1/2]

bool rtc::MessageQueue::empty ( ) const
inline

◆ empty() [2/2]

bool rtc::MessageQueue::empty ( ) const
inline

◆ Get() [1/2]

virtual bool rtc::MessageQueue::Get ( Message *  pmsg,
int  cmsWait = kForever,
bool  process_io = true 
)
virtual

◆ Get() [2/2]

bool rtc::MessageQueue::Get ( Message *  pmsg,
int  cmsWait = kForever,
bool  process_io = true 
)
virtual

◆ GetDelay() [1/2]

int rtc::MessageQueue::GetDelay ( )
virtual

◆ GetDelay() [2/2]

virtual int rtc::MessageQueue::GetDelay ( )
virtual

◆ GUARDED_BY() [1/6]

MessageList msgq_ rtc::MessageQueue::GUARDED_BY ( crit_  )
protected

◆ GUARDED_BY() [2/6]

MessageList msgq_ rtc::MessageQueue::GUARDED_BY ( crit_  )
protected

◆ GUARDED_BY() [3/6]

PriorityQueue dmsgq_ rtc::MessageQueue::GUARDED_BY ( crit_  )
protected

◆ GUARDED_BY() [4/6]

PriorityQueue dmsgq_ rtc::MessageQueue::GUARDED_BY ( crit_  )
protected

◆ GUARDED_BY() [5/6]

uint32_t dmsgq_next_num_ rtc::MessageQueue::GUARDED_BY ( crit_  )
protected

◆ GUARDED_BY() [6/6]

uint32_t dmsgq_next_num_ rtc::MessageQueue::GUARDED_BY ( crit_  )
protected

◆ IsProcessingMessages() [1/2]

virtual bool rtc::MessageQueue::IsProcessingMessages ( )
virtual

◆ IsProcessingMessages() [2/2]

bool rtc::MessageQueue::IsProcessingMessages ( )
virtual

◆ IsQuitting() [1/2]

bool rtc::MessageQueue::IsQuitting ( )
virtual

◆ IsQuitting() [2/2]

virtual bool rtc::MessageQueue::IsQuitting ( )
virtual

◆ Peek() [1/2]

bool rtc::MessageQueue::Peek ( Message *  pmsg,
int  cmsWait = 0 
)
virtual

◆ Peek() [2/2]

virtual bool rtc::MessageQueue::Peek ( Message *  pmsg,
int  cmsWait = 0 
)
virtual

◆ Post() [1/2]

virtual void rtc::MessageQueue::Post ( const Location &  posted_from,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr,
bool  time_sensitive = false 
)
virtual

◆ Post() [2/2]

void rtc::MessageQueue::Post ( const Location &  posted_from,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr,
bool  time_sensitive = false 
)
virtual

◆ PostAt() [1/4]

virtual void rtc::MessageQueue::PostAt ( const Location &  posted_from,
int64_t  tstamp,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr 
)
virtual

◆ PostAt() [2/4]

void rtc::MessageQueue::PostAt ( const Location &  posted_from,
int64_t  tstamp,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr 
)
virtual

◆ PostAt() [3/4]

virtual void rtc::MessageQueue::PostAt ( const Location &  posted_from,
uint32_t  tstamp,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr 
)
virtual

◆ PostAt() [4/4]

void rtc::MessageQueue::PostAt ( const Location &  posted_from,
uint32_t  tstamp,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr 
)
virtual

◆ PostDelayed() [1/2]

virtual void rtc::MessageQueue::PostDelayed ( const Location &  posted_from,
int  cmsDelay,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr 
)
virtual

◆ PostDelayed() [2/2]

void rtc::MessageQueue::PostDelayed ( const Location &  posted_from,
int  cmsDelay,
MessageHandler *  phandler,
uint32_t  id = 0,
MessageData *  pdata = nullptr 
)
virtual

◆ Quit() [1/2]

void rtc::MessageQueue::Quit ( )
virtual

◆ Quit() [2/2]

virtual void rtc::MessageQueue::Quit ( )
virtual

◆ ReceiveSends() [1/2]

void rtc::MessageQueue::ReceiveSends ( )
virtual

Reimplemented in rtc::Thread, and rtc::Thread.

◆ ReceiveSends() [2/2]

virtual void rtc::MessageQueue::ReceiveSends ( )
virtual

Reimplemented in rtc::Thread, and rtc::Thread.

◆ Restart() [1/2]

void rtc::MessageQueue::Restart ( )
virtual

◆ Restart() [2/2]

virtual void rtc::MessageQueue::Restart ( )
virtual

◆ set_socketserver() [1/2]

void rtc::MessageQueue::set_socketserver ( SocketServer *  ss)

◆ set_socketserver() [2/2]

void rtc::MessageQueue::set_socketserver ( SocketServer *  ss)

◆ size() [1/2]

size_t rtc::MessageQueue::size ( ) const
inline

◆ size() [2/2]

size_t rtc::MessageQueue::size ( ) const
inline

◆ socketserver() [1/2]

SocketServer * rtc::MessageQueue::socketserver ( )

◆ socketserver() [2/2]

SocketServer* rtc::MessageQueue::socketserver ( )

◆ WakeUpSocketServer() [1/2]

void rtc::MessageQueue::WakeUpSocketServer ( )
protected

◆ WakeUpSocketServer() [2/2]

void rtc::MessageQueue::WakeUpSocketServer ( )
protected

Member Data Documentation

◆ crit_

CriticalSection rtc::MessageQueue::crit_
protected

◆ fDestroyed_

bool rtc::MessageQueue::fDestroyed_
protected

◆ fInitialized_

bool rtc::MessageQueue::fInitialized_
protected

◆ fPeekKeep_

bool rtc::MessageQueue::fPeekKeep_
protected

◆ kForever

static const int rtc::MessageQueue::kForever = -1
static

◆ msgPeek_

Message rtc::MessageQueue::msgPeek_
protected

◆ SignalQueueDestroyed

sigslot::signal0 rtc::MessageQueue::SignalQueueDestroyed
The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.13