#include <XrdSysPthread.hh>
Public Member Functions | |
| void | Lock () |
| void | Signal () |
| void | Broadcast () |
| void | UnLock () |
| int | Wait () |
| int | Wait (int sec) |
| int | WaitMS (int msec) |
| XrdSysCondVar (int relm=1, const char *cid=0) | |
| ~XrdSysCondVar () | |
Private Attributes | |
| pthread_cond_t | cvar |
| pthread_mutex_t | cmut |
| int | relMutex |
| const char * | condID |
| XrdSysCondVar::XrdSysCondVar | ( | int | relm = 1, |
|
| const char * | cid = 0 | |||
| ) | [inline] |
| void XrdSysCondVar::Broadcast | ( | ) | [inline] |
| void XrdSysCondVar::Lock | ( | ) | [inline] |
References cmut.
Referenced by XrdOfsHanXpr::add2Q(), XrdOdcMsg::Alloc(), XrdCmsClientMsg::Alloc(), XrdClientConn::CheckREQConnectWaitState(), XrdClientConn::CheckREQPauseState(), XrdSysSemWait::CondWait(), XrdClientConnectionMgr::Connect(), XrdOfsHanXpr::Deref(), XrdOfsHanXpr::Get(), XrdClient::IsOpen_inprogress(), XrdClient::IsOpen_wait(), XrdSysCondVarHelper::Lock(), XrdOdcMsg::Lock(), XrdCmsClientMsg::Lock(), XrdBuffManager::Obtain(), XrdSysSemWait::Post(), XrdClientConn::ProcessAsynResp(), XrdClient::Read(), XrdBuffManager::Release(), XrdOdcMsg::RemFromWaitQ(), XrdCmsClientMsg::RemFromWaitQ(), XrdBuffManager::Reshape(), XrdOfsHanXpr::Set(), XrdBuffManager::Set(), XrdClientConn::SetREQDelayedConnectState(), XrdClientConn::SetREQPauseState(), XrdBuffManager::Stats(), XrdLink::Terminate(), XrdClient::TerminateOpenAttempt(), XrdSysSemWait::Wait(), Wait(), WaitMS(), XrdClientConn::WaitResp(), XrdSysCondVarHelper::XrdSysCondVarHelper(), and XrdClient::~XrdClient().
| void XrdSysCondVar::Signal | ( | ) | [inline] |
References cmut, cvar, and relMutex.
Referenced by XrdOfsHanXpr::add2Q(), XrdLink::Close(), XrdCpMthrQueue::GetBuffer(), XrdBuffManager::Obtain(), XrdSysSemWait::Post(), XrdClientConn::ProcessAsynResp(), XrdMonCtrBuffer::push_back(), XrdOdcMsg::Reply(), XrdCmsClientMsg::Reply(), and XrdScheduler::Schedule().
| void XrdSysCondVar::UnLock | ( | ) | [inline] |
References cmut.
Referenced by XrdOfsHanXpr::add2Q(), XrdClientConn::CheckREQConnectWaitState(), XrdClientConn::CheckREQPauseState(), XrdLink::Close(), XrdSysSemWait::CondWait(), XrdClientConnectionMgr::Connect(), XrdOfsHanXpr::Deref(), XrdOfsHanXpr::Get(), XrdClient::IsOpen_inprogress(), XrdClient::IsOpen_wait(), XrdSysCondVarHelper::Lock(), XrdBuffManager::Obtain(), XrdSysSemWait::Post(), XrdClientConn::ProcessAsynResp(), XrdClient::Read(), XrdOdcMsg::Recycle(), XrdCmsClientMsg::Recycle(), XrdBuffManager::Release(), XrdOdcMsg::RemFromWaitQ(), XrdCmsClientMsg::RemFromWaitQ(), XrdOdcMsg::Reply(), XrdCmsClientMsg::Reply(), XrdBuffManager::Reshape(), XrdOfsHanXpr::Set(), XrdBuffManager::Set(), XrdClientConn::SetREQDelayedConnectState(), XrdClientConn::SetREQPauseState(), XrdBuffManager::Stats(), XrdLink::Terminate(), XrdClient::TerminateOpenAttempt(), XrdSysCondVarHelper::UnLock(), XrdOdcMsg::UnLock(), XrdCmsClientMsg::UnLock(), XrdSysSemWait::Wait(), Wait(), WaitMS(), XrdClientConn::WaitResp(), and XrdClient::~XrdClient().
| int XrdSysCondVar::Wait | ( | ) |
References cmut, cvar, Lock(), relMutex, and UnLock().
Referenced by XrdClientConn::CheckREQConnectWaitState(), XrdClientConn::CheckREQPauseState(), XrdClientConnectionMgr::Connect(), XrdClientConn::DoWriteHardCheckPoint(), XrdOfsHanXpr::Get(), XrdClient::IsOpen_wait(), XrdMonCtrBuffer::pop_front(), XrdCpMthrQueue::PutBuffer(), XrdClient::Read(), XrdBuffManager::Reshape(), XrdLink::Terminate(), XrdScheduler::TimeSched(), XrdSysSemWait::Wait(), XrdOdcMsg::Wait4Reply(), XrdCmsClientMsg::Wait4Reply(), XrdClient::WaitForNewAsyncData(), and XrdClientConn::WaitResp().
| int XrdSysCondVar::Wait | ( | int | sec | ) |
| int XrdSysCondVar::WaitMS | ( | int | msec | ) |
pthread_mutex_t XrdSysCondVar::cmut [private] |
Referenced by Broadcast(), Lock(), Signal(), UnLock(), Wait(), WaitMS(), XrdSysCondVar(), and ~XrdSysCondVar().
const char* XrdSysCondVar::condID [private] |
Referenced by XrdSysCondVar().
pthread_cond_t XrdSysCondVar::cvar [private] |
Referenced by Broadcast(), Signal(), Wait(), WaitMS(), XrdSysCondVar(), and ~XrdSysCondVar().
int XrdSysCondVar::relMutex [private] |
Referenced by Broadcast(), Signal(), Wait(), WaitMS(), and XrdSysCondVar().
1.7.1