Public Member Functions | |
| CAConditionVariable () | |
| ~CAConditionVariable () | |
| SINT32 | wait () |
| Waits for a signal or for a timeout. More... | |
| SINT32 | wait (CAMutex &oMutex) |
| Very ugly shortly to be deleted, uncommented function! More... | |
| SINT32 | wait (CAMutex *pMutex) |
| Very ugly shortly to be deleted, uncommented function! More... | |
| SINT32 | wait (UINT32 msTimeout) |
| Waits for a signal or for a timeout. More... | |
| SINT32 | signal () |
| Signals this object. More... | |
| SINT32 | broadcast () |
| Signals this object. More... | |
 Public Member Functions inherited from CAMutex | |
| CAMutex () | |
| virtual | ~CAMutex () |
| SINT32 | lock () |
| SINT32 | unlock () |
Private Attributes | |
| CAMutex * | m_pMutex |
| CASemaphore * | m_pSemaphore |
| UINT32 | m_iSleepers |
Additional Inherited Members | |
| Protected Attributes inherited from CAMutex | |
| CASemaphore * | m_pMutex |
Constructor & Destructor Documentation
◆ CAConditionVariable()
| CAConditionVariable::CAConditionVariable | ( | ) |
References CAMutex::CAMutex(), m_iSleepers, m_pMutex, and m_pSemaphore.
◆ ~CAConditionVariable()
| CAConditionVariable::~CAConditionVariable | ( | ) |
References m_pMutex, and m_pSemaphore.
Member Function Documentation
◆ broadcast()
| SINT32 CAConditionVariable::broadcast | ( | ) |
Signals this object.
All threads waiting on this object will awake. Note: lock() must be called before broadcast() and unlock() must be called if proccessing ends.
References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_iSleepers, m_pMutex, m_pSemaphore, and CAMutex::unlock().
Referenced by CAThreadPool::addRequest(), CAThreadPool::destroy(), and CAAccountingDBInterface::releaseConnection().
◆ signal()
| SINT32 CAConditionVariable::signal | ( | ) |
Signals this object.
One of the threads waiting on this object will awake. Note: lock() must be called before signal() and unlock() must be called if proccessing ends.
References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_iSleepers, m_pMutex, m_pSemaphore, and CAMutex::unlock().
Referenced by CAAccountingInstance::__newSettlementTransaction(), CAQueue::add(), CAQueue::close(), CAFirstMixChannelList::remove(), CAAccountingSettleThread::settle(), CAAccountingInstance::settlementTransaction(), CAInfoService::signal(), CAInfoService::stop(), and CALockAble::unlock().
◆ wait() [1/4]
| SINT32 CAConditionVariable::wait | ( | ) |
Waits for a signal or for a timeout.
Note: lock() must be called before wait() and unlock() must be called if proccessing ends.
- Return values
-
E_SUCCESS if signaled E_UNKNOWN if an error occured
References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_iSleepers, m_pMutex, m_pSemaphore, and CAMutex::unlock().
Referenced by CAAccountingInstance::__newSettlementTransaction(), CAThreadPool::addRequest(), CAThreadPool::destroy(), CAAccountingDBInterface::getConnection(), CAQueue::getOrWait(), CAAccountingInstance::handleChallengeResponse_internal(), CAInfoService::InfoLoop(), CAAccountingSettleThread::mainLoop(), CAAccountingInstance::settlementTransaction(), wait(), and CALockAble::waitForDestroy().
◆ wait() [2/4]
Very ugly shortly to be deleted, uncommented function!
References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_iSleepers, m_pMutex, CAMutex::m_pMutex, m_pSemaphore, and CAMutex::unlock().
◆ wait() [3/4]
Very ugly shortly to be deleted, uncommented function!
References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_iSleepers, m_pMutex, CAMutex::m_pMutex, m_pSemaphore, and CAMutex::unlock().
◆ wait() [4/4]
Waits for a signal or for a timeout.
Note: lock() must be called before wait() and unlock() must be called if proccessing ends.
- Parameters
-
msTimeout timout value in millis seconds
- Return values
-
E_SUCCESS if signaled E_TIMEDOUT if timout was reached E_UNKNOWN if an error occured
- Todo:
- add something better here....
References E_SUCCESS, E_TIMEDOUT, E_UNKNOWN, getcurrentTime(), m_pMutex, and wait().
Member Data Documentation
◆ m_iSleepers
|
private |
Referenced by broadcast(), CAConditionVariable(), signal(), and wait().
◆ m_pMutex
|
private |
Referenced by broadcast(), CAConditionVariable(), signal(), wait(), and ~CAConditionVariable().
◆ m_pSemaphore
|
private |
Referenced by broadcast(), CAConditionVariable(), signal(), wait(), and ~CAConditionVariable().
