|
| | ~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) |
| |