webkit  2cdf99a9e3038c7e01b3c37e8ad903ecbe5eecf1
https://github.com/WebKit/webkit
Public Member Functions | List of all members
OwnerThread Class Reference
Inheritance diagram for OwnerThread:
rtc::Thread sigslot::has_slots<> rtc::MessageQueue rtc::MessageQueue sigslot::has_slots_interface sigslot::has_slots_interface

Public Member Functions

 OwnerThread (SignalThreadTest *harness)
 
virtual ~OwnerThread ()
 
virtual void Run ()
 
bool has_run ()
 
void OnWorkDone (SignalThread *signal_thread)
 
- Public Member Functions inherited from rtc::Thread
 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 ()
 
- Public Member Functions inherited from rtc::MessageQueue
 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)
 
- Public Member Functions inherited from sigslot::has_slots<>
 has_slots ()
 
 has_slots ()
 
 ~has_slots ()
 
 ~has_slots ()
 
- Public Member Functions inherited from sigslot::has_slots_interface
void signal_connect (_signal_base_interface *sender)
 
void signal_disconnect (_signal_base_interface *sender)
 
void disconnect_all ()
 
void signal_connect (_signal_base_interface *sender)
 
void signal_disconnect (_signal_base_interface *sender)
 
void disconnect_all ()
 

Additional Inherited Members

- Static Public Member Functions inherited from rtc::Thread
static std::unique_ptr< Thread > CreateWithSocketServer ()
 
static std::unique_ptr< Thread > Create ()
 
static Thread * Current ()
 
static bool SleepMs (int millis)
 
static std::unique_ptr< Thread > CreateWithSocketServer ()
 
static std::unique_ptr< Thread > Create ()
 
static Thread * Current ()
 
static bool SleepMs (int millis)
 
- Public Attributes inherited from rtc::MessageQueue
sigslot::signal0 SignalQueueDestroyed
 
- Static Public Attributes inherited from rtc::MessageQueue
static const int kForever = -1
 
- Protected Member Functions inherited from rtc::Thread
void SafeWrapCurrent ()
 
void Join ()
 
void SafeWrapCurrent ()
 
void Join ()
 
- Protected Member Functions inherited from rtc::MessageQueue
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 Member Functions inherited from sigslot::has_slots_interface
 has_slots_interface (signal_connect_t conn, signal_disconnect_t disc, disconnect_all_t disc_all)
 
virtual ~has_slots_interface ()
 
 has_slots_interface (signal_connect_t conn, signal_disconnect_t disc, disconnect_all_t disc_all)
 
virtual ~has_slots_interface ()
 
- Static Protected Member Functions inherited from rtc::Thread
static void AssertBlockingIsAllowedOnCurrentThread ()
 
static void AssertBlockingIsAllowedOnCurrentThread ()
 
- Protected Attributes inherited from rtc::MessageQueue
bool fPeekKeep_
 
Message msgPeek_
 
CriticalSection crit_
 
bool fInitialized_
 
bool fDestroyed_
 

Constructor & Destructor Documentation

◆ OwnerThread()

OwnerThread::OwnerThread ( SignalThreadTest *  harness)
inlineexplicit

◆ ~OwnerThread()

virtual OwnerThread::~OwnerThread ( )
inlinevirtual

Member Function Documentation

◆ has_run()

bool OwnerThread::has_run ( )
inline

◆ OnWorkDone()

void OwnerThread::OnWorkDone ( SignalThread *  signal_thread)
inline

◆ Run()

virtual void OwnerThread::Run ( )
inlinevirtual

Reimplemented from rtc::Thread.

The documentation for this class was generated from the following file:
Generated by   doxygen 1.8.13