CAConditionVariable Class Reference

Inheritance diagram for CAConditionVariable:

List of all members.

Public Member Functions
	CAConditionVariable ()
	~CAConditionVariable ()
SINT32	wait ()
	Waits for a signal or for a timeout.
SINT32	wait (CAMutex &oMutex)
	Very ugly shortly to be deleted, uncommented function!
SINT32	wait (CAMutex *pMutex)
	Very ugly shortly to be deleted, uncommented function!
SINT32	wait (UINT32 msTimeout)
	Waits for a signal or for a timeout.
SINT32	signal ()
	Signals this object.
SINT32	broadcast ()
	Signals this object.
Private Attributes
CAMutex *	m_pMutex
CASemaphore *	m_pSemaphore
UINT32	m_iSleepers

---

Constructor & Destructor Documentation

CAConditionVariable::CAConditionVariable

(

)

References CAMutex::CAMutex(), m_iSleepers, m_pMutex, and m_pSemaphore.

CAConditionVariable::~CAConditionVariable

(

)

References m_pMutex, and m_pSemaphore.

---

Member Function Documentation

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(), CAAccountingDBInterface::releaseConnection(), and worker_thread_main_loop().

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(), CAFirstMixChannelList::remove(), CAAccountingSettleThread::settle(), CAAccountingInstance::settlementTransaction(), CAInfoService::signal(), CAInfoService::stop(), CALockAble::unlock(), and worker_thread_main_loop().

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(), CALockAble::waitForDestroy(), and worker_thread_main_loop().

SINT32 CAConditionVariable::wait

(

CAMutex &

oMutex

)

Very ugly shortly to be deleted, uncommented function!

References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_iSleepers, CAMutex::m_pMutex, m_pMutex, m_pSemaphore, and CAMutex::unlock().

SINT32 CAConditionVariable::wait

(

CAMutex *

pMutex

)

Very ugly shortly to be deleted, uncommented function!

References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_iSleepers, CAMutex::m_pMutex, m_pMutex, m_pSemaphore, and CAMutex::unlock().

SINT32 CAConditionVariable::wait

(

UINT32

msTimeout

)

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

UINT32 CAConditionVariable::m_iSleepers [private]

Referenced by broadcast(), CAConditionVariable(), signal(), and wait().

CAMutex* CAConditionVariable::m_pMutex [private]

Reimplemented from CAMutex.

Referenced by broadcast(), CAConditionVariable(), signal(), wait(), and ~CAConditionVariable().

CASemaphore* CAConditionVariable::m_pSemaphore [private]

Referenced by broadcast(), CAConditionVariable(), signal(), wait(), and ~CAConditionVariable().