|
| ~LogThread () override |
|
| Thread () |
|
| Thread (SocketServer *ss) |
|
| Thread (std::unique_ptr< SocketServer > ss) |
|
| ~Thread () override |
|
bool | IsCurrent () const |
|
const std::string & | name () const |
|
bool | SetName (const std::string &name, const void *obj) |
|
bool | Start (Runnable *runnable=nullptr) |
|
virtual void | Stop () |
|
virtual void | Send (const Location &posted_from, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr) |
|
template<class ReturnT , class FunctorT > |
ReturnT | Invoke (const Location &posted_from, const FunctorT &functor) |
|
void | Clear (MessageHandler *phandler, uint32_t id=MQID_ANY, MessageList *removed=nullptr) override |
|
void | ReceiveSends () override |
|
bool | ProcessMessages (int cms) |
|
bool | IsOwned () |
|
bool | RunningForTest () |
|
bool | SetAllowBlockingCalls (bool allow) |
|
bool | WrapCurrent () |
|
void | UnwrapCurrent () |
|
| Thread () |
|
| Thread (SocketServer *ss) |
|
| Thread (std::unique_ptr< SocketServer > ss) |
|
| ~Thread () override |
|
bool | IsCurrent () const |
|
const std::string & | name () const |
|
bool | SetName (const std::string &name, const void *obj) |
|
bool | Start (Runnable *runnable=nullptr) |
|
virtual void | Stop () |
|
virtual void | Send (const Location &posted_from, MessageHandler *phandler, uint32_t id=0, MessageData *pdata=nullptr) |
|
template<class ReturnT , class FunctorT > |
ReturnT | Invoke (const Location &posted_from, const FunctorT &functor) |
|
void | Clear (MessageHandler *phandler, uint32_t id=MQID_ANY, MessageList *removed=nullptr) override |
|
void | ReceiveSends () override |
|
bool | ProcessMessages (int cms) |
|
bool | IsOwned () |
|
bool | RunningForTest () |
|
bool | SetAllowBlockingCalls (bool allow) |
|
bool | WrapCurrent () |
|
void | UnwrapCurrent () |
|
| 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 | Dispatch (Message *pmsg) |
|
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 | Dispatch (Message *pmsg) |
|
virtual int | GetDelay () |
|
bool | empty () const |
|
size_t | size () const |
|
template<class T > |
void | Dispose (T *doomed) |
|