diff options
Diffstat (limited to 'tools/lldb-mi/MIUtilThreadBaseStd.cpp')
| -rw-r--r-- | tools/lldb-mi/MIUtilThreadBaseStd.cpp | 441 |
1 files changed, 227 insertions, 214 deletions
diff --git a/tools/lldb-mi/MIUtilThreadBaseStd.cpp b/tools/lldb-mi/MIUtilThreadBaseStd.cpp index 38f3eb4fae3b2..1cf04fa5b2aec 100644 --- a/tools/lldb-mi/MIUtilThreadBaseStd.cpp +++ b/tools/lldb-mi/MIUtilThreadBaseStd.cpp @@ -8,17 +8,17 @@ //===----------------------------------------------------------------------===// //++ -// File: MIUtilThreadBaseStd.cpp +// File: MIUtilThreadBaseStd.cpp // -// Overview: CMIUtilThread implementation. -// CMIUtilThreadActiveObjBase implementation. -// CMIUtilThreadMutex implementation. +// Overview: CMIUtilThread implementation. +// CMIUtilThreadActiveObjBase implementation. +// CMIUtilThreadMutex implementation. // -// Environment: Compilers: Visual C++ 12. -// gcc (Ubuntu/Linaro 4.8.1-10ubuntu9) 4.8.1 -// Libraries: See MIReadmetxt. +// Environment: Compilers: Visual C++ 12. +// gcc (Ubuntu/Linaro 4.8.1-10ubuntu9) 4.8.1 +// Libraries: See MIReadmetxt. // -// Copyright: None. +// Copyright: None. //-- // Third Party Headers: @@ -29,271 +29,282 @@ #include "MICmnThreadMgrStd.h" //++ ------------------------------------------------------------------------------------ -// Details: Constructor. -// Type: None. -// Args: None. -// Return: None. -// Throws: None. +// Details: Constructor. +// Type: None. +// Args: None. +// Return: None. +// Throws: None. //-- -CMIUtilThreadActiveObjBase::CMIUtilThreadActiveObjBase( void ) -: m_references( 0 ) -, m_bHasBeenKilled( false ) +CMIUtilThreadActiveObjBase::CMIUtilThreadActiveObjBase(void) + : m_references(0) + , m_bHasBeenKilled(false) { } //++ ------------------------------------------------------------------------------------ -// Details: Destructor. -// Type: None. -// Args: None. -// Return: None. -// Throws: None. +// Details: Destructor. +// Type: None. +// Args: None. +// Return: None. +// Throws: None. //-- -CMIUtilThreadActiveObjBase::~CMIUtilThreadActiveObjBase( void ) +CMIUtilThreadActiveObjBase::~CMIUtilThreadActiveObjBase(void) { - // Make sure our thread is not alive before we die - m_thread.Join(); + // Make sure our thread is not alive before we die + m_thread.Join(); } //++ ------------------------------------------------------------------------------------ -// Details: Check if an object is already running. -// Type: Method. -// Args: None. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Details: Check if an object is already running. +// Type: Method. +// Args: None. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThreadActiveObjBase::ThreadIsActive( void ) +bool +CMIUtilThreadActiveObjBase::ThreadIsActive(void) { - // Create a new thread to occupy this threads Run() function - return m_thread.IsActive(); + // Create a new thread to occupy this threads Run() function + return m_thread.IsActive(); } //++ ------------------------------------------------------------------------------------ -// Details: Set up *this thread. -// Type: Mrthod. -// Args: None. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Details: Set up *this thread. +// Type: Mrthod. +// Args: None. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThreadActiveObjBase::ThreadExecute( void ) +bool +CMIUtilThreadActiveObjBase::ThreadExecute(void) { - // Create a new thread to occupy this threads Run() function - return m_thread.Start( ThreadEntry, this ); + // Create a new thread to occupy this threads Run() function + return m_thread.Start(ThreadEntry, this); } //++ ------------------------------------------------------------------------------------ -// Details: Aquire a reference to CMIUtilThreadActiveObjBase. -// Type: Method. -// Args: None. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Details: Aquire a reference to CMIUtilThreadActiveObjBase. +// Type: Method. +// Args: None. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThreadActiveObjBase::Acquire( void ) +bool +CMIUtilThreadActiveObjBase::Acquire(void) { - // Access to this function is serial - CMIUtilThreadLock serial( m_mutex ); + // Access to this function is serial + CMIUtilThreadLock serial(m_mutex); - // >0 == *this thread is alive - m_references++; + // >0 == *this thread is alive + m_references++; - return MIstatus::success; + return MIstatus::success; } //++ ------------------------------------------------------------------------------------ -// Details: Release a reference to CMIUtilThreadActiveObjBase. -// Type: Method. -// Args: None. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Details: Release a reference to CMIUtilThreadActiveObjBase. +// Type: Method. +// Args: None. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThreadActiveObjBase::Release( void ) +bool +CMIUtilThreadActiveObjBase::Release(void) { - // Access to this function is serial - CMIUtilThreadLock serial( m_mutex ); - - // 0 == kill off *this thread - m_references--; + // Access to this function is serial + CMIUtilThreadLock serial(m_mutex); - return MIstatus::success; + // 0 == kill off *this thread + m_references--; + + return MIstatus::success; } //++ ------------------------------------------------------------------------------------ -// Details: Force this thread to stop, regardless of references -// Type: Method. -// Args: None. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Details: Force this thread to stop, regardless of references +// Type: Method. +// Args: None. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThreadActiveObjBase::ThreadKill( void ) +bool +CMIUtilThreadActiveObjBase::ThreadKill(void) { - // Access to this function is serial - CMIUtilThreadLock serial( m_mutex ); + // Access to this function is serial + CMIUtilThreadLock serial(m_mutex); - // Set this thread to killed status - m_bHasBeenKilled = true; + // Set this thread to killed status + m_bHasBeenKilled = true; - return MIstatus::success; + return MIstatus::success; } //++ ------------------------------------------------------------------------------------ // Details: Proxy to thread join. -// Type: Method. -// Args: None. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Type: Method. +// Args: None. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThreadActiveObjBase::ThreadJoin( void ) +bool +CMIUtilThreadActiveObjBase::ThreadJoin(void) { - return m_thread.Join(); + return m_thread.Join(); } //++ ------------------------------------------------------------------------------------ -// Details: This function is the entry point of this object thread. -// It is a trampoline to an instances operation manager. -// Type: Static method. -// Args: vpThisClass - (R) From the system (our CMIUtilThreadActiveObjBase from the ctor). -// Return: MIuint - 0 = success. -// Throws: None. +// Details: This function is the entry point of this object thread. +// It is a trampoline to an instances operation manager. +// Type: Static method. +// Args: vpThisClass - (R) From the system (our CMIUtilThreadActiveObjBase from the ctor). +// Return: MIuint - 0 = success. +// Throws: None. //-- -MIuint CMIUtilThreadActiveObjBase::ThreadEntry( void * vpThisClass ) +MIuint +CMIUtilThreadActiveObjBase::ThreadEntry(void *vpThisClass) { - // The argument is a pointer to a CMIUtilThreadActiveObjBase class - // as passed from the initialize function, so we can safely cast it. - assert( vpThisClass != nullptr ); - CMIUtilThreadActiveObjBase * pActive = reinterpret_cast< CMIUtilThreadActiveObjBase * >( vpThisClass ); + // The argument is a pointer to a CMIUtilThreadActiveObjBase class + // as passed from the initialize function, so we can safely cast it. + assert(vpThisClass != nullptr); + CMIUtilThreadActiveObjBase *pActive = reinterpret_cast<CMIUtilThreadActiveObjBase *>(vpThisClass); - // Start the management routine of this object - pActive->ThreadManage(); + // Start the management routine of this object + pActive->ThreadManage(); - // Thread death + // Thread death return 0; } //++ ------------------------------------------------------------------------------------ -// Details: This function forms a small management routine, to handle the thread's running. -// Type: Method. -// Args: None. -// Return: None. -// Throws: None. +// Details: This function forms a small management routine, to handle the thread's running. +// Type: Method. +// Args: None. +// Return: None. +// Throws: None. //-- -void CMIUtilThreadActiveObjBase::ThreadManage( void ) +void +CMIUtilThreadActiveObjBase::ThreadManage(void) { - bool bAlive = true; - - // Infinite loop - while( bAlive ) - { - // Scope the lock while we access m_isDying - { - // Lock down access to the interface - CMIUtilThreadLock serial( m_mutex ); - - // Quit the run loop if we are dying - if( m_references == 0 ) - break; - } - // Execute the run routine - if( !ThreadRun( bAlive ) ) - // Thread's run function failed (MIstatus::failure) - break; - - // We will die if we have been signaled to die - bAlive &= !m_bHasBeenKilled; - } - - // Execute the finish routine just before we die - // to give the object a chance to clean up - ThreadFinish(); + bool bAlive = true; + + // Infinite loop + while (bAlive) + { + // Scope the lock while we access m_isDying + { + // Lock down access to the interface + CMIUtilThreadLock serial(m_mutex); + + // Quit the run loop if we are dying + if (m_references == 0) + break; + } + // Execute the run routine + if (!ThreadRun(bAlive)) + // Thread's run function failed (MIstatus::failure) + break; + + // We will die if we have been signaled to die + bAlive &= !m_bHasBeenKilled; + } + + // Execute the finish routine just before we die + // to give the object a chance to clean up + ThreadFinish(); } //--------------------------------------------------------------------------------------- //--------------------------------------------------------------------------------------- //--------------------------------------------------------------------------------------- -// -CMIUtilThread::CMIUtilThread( void ) -: m_pThread( nullptr ) +// +CMIUtilThread::CMIUtilThread(void) + : m_pThread(nullptr) { } //++ ------------------------------------------------------------------------------------ -// Details: CMIUtilThread destructor. -// Type: Method. -// Args: None. -// Return: None. -// Throws: None. +// Details: CMIUtilThread destructor. +// Type: Method. +// Args: None. +// Return: None. +// Throws: None. //-- -CMIUtilThread::~CMIUtilThread( void ) +CMIUtilThread::~CMIUtilThread(void) { - Join(); + Join(); } //++ ------------------------------------------------------------------------------------ -// Details: Wait for thread to stop. -// Type: Method. -// Args: None. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Details: Wait for thread to stop. +// Type: Method. +// Args: None. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThread::Join( void ) +bool +CMIUtilThread::Join(void) { - if( m_pThread != nullptr ) - { - // Wait for this thread to die - m_pThread->join(); - - // Scope the thread lock while we modify the pointer - { - CMIUtilThreadLock _lock( m_mutex ); - delete m_pThread; - m_pThread = nullptr; - } - } - - return MIstatus::success; + if (m_pThread != nullptr) + { + // Wait for this thread to die + m_pThread->join(); + + // Scope the thread lock while we modify the pointer + { + CMIUtilThreadLock _lock(m_mutex); + delete m_pThread; + m_pThread = nullptr; + } + } + + return MIstatus::success; } //++ ------------------------------------------------------------------------------------ -// Details: Is the thread doing work. -// Type: Method. -// Args: None. -// Return: bool - True = Yes active, false = not active. -// Throws: None. +// Details: Is the thread doing work. +// Type: Method. +// Args: None. +// Return: bool - True = Yes active, false = not active. +// Throws: None. //-- -bool CMIUtilThread::IsActive( void ) +bool +CMIUtilThread::IsActive(void) { - // Lock while we access the thread pointer - CMIUtilThreadLock _lock( m_mutex ); - if( m_pThread == nullptr ) - return false; - else - return true; + // Lock while we access the thread pointer + CMIUtilThreadLock _lock(m_mutex); + if (m_pThread == nullptr) + return false; + else + return true; } //++ ------------------------------------------------------------------------------------ -// Details: Set up *this thread. -// Type: Method. -// Args: vpFn (R) - Function pointer to thread's main function. -// vpArg (R) - Pointer arguments to pass to the thread. -// Return: MIstatus::success - Functional succeeded. -// MIstatus::failure - Functional failed. -// Throws: None. +// Details: Set up *this thread. +// Type: Method. +// Args: vpFn (R) - Function pointer to thread's main function. +// vpArg (R) - Pointer arguments to pass to the thread. +// Return: MIstatus::success - Functional succeeded. +// MIstatus::failure - Functional failed. +// Throws: None. //-- -bool CMIUtilThread::Start( FnThreadProc vpFn, void * vpArg ) +bool +CMIUtilThread::Start(FnThreadProc vpFn, void *vpArg) { - // Create the std thread, which starts immediately - m_pThread = new std::thread( vpFn, vpArg ); - - // We expect to always be able to create one - assert( m_pThread != nullptr ); - - return MIstatus::success; + // Create the std thread, which starts immediately + m_pThread = new std::thread(vpFn, vpArg); + + // We expect to always be able to create one + assert(m_pThread != nullptr); + + return MIstatus::success; } //--------------------------------------------------------------------------------------- @@ -301,39 +312,41 @@ bool CMIUtilThread::Start( FnThreadProc vpFn, void * vpArg ) //--------------------------------------------------------------------------------------- //++ ------------------------------------------------------------------------------------ -// Details: Take resource. -// Type: Method. -// Args: None. -// Return: None. -// Throws: None. +// Details: Take resource. +// Type: Method. +// Args: None. +// Return: None. +// Throws: None. //-- -void CMIUtilThreadMutex::Lock( void ) +void +CMIUtilThreadMutex::Lock(void) { - m_mutex.lock(); + m_mutex.lock(); } - + //++ ------------------------------------------------------------------------------------ -// Details: Release resource. -// Type: Method. -// Args: None. -// Return: None. -// Throws: None. +// Details: Release resource. +// Type: Method. +// Args: None. +// Return: None. +// Throws: None. //-- -void CMIUtilThreadMutex::Unlock( void ) +void +CMIUtilThreadMutex::Unlock(void) { - m_mutex.unlock(); + m_mutex.unlock(); } //++ ------------------------------------------------------------------------------------ -// Details: Take resource if available. Immediately return in either case. -// Type: Method. -// Args: None. -// Return: True - mutex has been locked. -// False - mutex could not be locked. -// Throws: None. +// Details: Take resource if available. Immediately return in either case. +// Type: Method. +// Args: None. +// Return: True - mutex has been locked. +// False - mutex could not be locked. +// Throws: None. //-- -bool CMIUtilThreadMutex::TryLock( void ) +bool +CMIUtilThreadMutex::TryLock(void) { - return m_mutex.try_lock(); + return m_mutex.try_lock(); } - |