#include <XrdProofdProofServ.h>
Public Member Functions | |
XrdProofdProofServ () | |
~XrdProofdProofServ () | |
void | AddWorker (const char *o, XrdProofWorker *w) |
const char * | AdminPath () const |
const char * | Alias () const |
void | Broadcast (const char *msg, int type=kXPD_srvmsg) |
int | BroadcastPriority (int priority) |
const char * | Client () const |
int | CheckSession (bool oldvers, bool isrec, int shutopt, int shutdel, bool changeown, int &nc) |
XrdProofQuery * | CurrentQuery () |
void | DeleteStartMsg () |
int | DisconnectTime () |
void | DumpQueries () |
int | Enqueue (XrdProofQuery *q) |
void | ExportBuf (XrdOucString &buf) |
void | ExportWorkers (XrdOucString &wrks) |
const char * | Fileout () const |
int | FreeClientID (int pid) |
XrdClientID * | GetClientID (int cid) |
int | GetNClients (bool check) |
XrdProofQuery * | GetQuery (const char *tag) |
const char * | Group () const |
int | IdleTime () |
short int | ID () const |
bool | IsShutdown () const |
bool | IsValid () const |
bool | Match (short int id) const |
const char * | Ordinal () const |
XrdClientID * | Parent () const |
void | PingSem () const |
XrdProofdProtocol * | Protocol () const |
std::list< XrdProofQuery * > * | Queries () const |
void | RemoveQuery (const char *tag) |
void | RemoveWorker (const char *o) |
void | Reset () |
int | Reset (const char *msg, int type) |
int | Resume () |
XrdROOT * | ROOT () const |
XrdProofdResponse * | Response () const |
int | SendData (int cid, void *buff, int len) |
int | SendDataN (void *buff, int len) |
void | SendClusterInfo (int nsess, int nacti) |
int | SetAdminPath (const char *a, bool assert) |
void | SetAlias (const char *a) |
void | SetClient (const char *c) |
void | SetConnection (XrdProofdResponse *r) |
void | SetFileout (const char *f) |
void | SetGroup (const char *g) |
void | SetIdle () |
void | SetID (short int id) |
void | SetOrdinal (const char *o) |
void | SetParent (XrdClientID *cid) |
void | SetProtocol (XrdProofdProtocol *p) |
void | SetProtVer (int pv) |
void | SetROOT (XrdROOT *r) |
void | SetRunning () |
void | SetShutdown () |
void | SetSkipCheck () |
void | SetSrvPID (int pid) |
void | SetSrvType (int id) |
void | SetStartMsg (XrdSrvBuffer *sm) |
void | SetStatus (int st) |
void | SetTag (const char *t) |
void | SetUNIXSockPath (const char *s) |
void | SetUserEnvs (const char *t) |
void | SetValid (bool valid=1) |
bool | SkipCheck () |
int | SrvPID () const |
int | SrvType () const |
XrdSrvBuffer * | StartMsg () const |
int | Status () const |
const char * | Tag () const |
int | TerminateProofServ (bool changeown) |
const char * | UserEnvs () const |
int | VerifyProofServ (bool fw) |
XrdOucHash< XrdProofWorker > * | Workers () const |
int | CreateUNIXSock (XrdSysError *edest) |
void | DeleteUNIXSock () |
XrdNet * | UNIXSock () const |
const char * | UNIXSockPath () const |
Private Member Functions | |
void | ClearWorkers () |
void | CreatePingSem () |
void | DeletePingSem () |
Private Attributes | |
XrdSysRecMutex * | fMutex |
XrdProofdProtocol * | fProtocol |
XrdProofdResponse * | fResponse |
XrdClientID * | fParent |
int | fNClients |
std::vector< XrdClientID * > | fClients |
XrdOucHash< XrdProofWorker > | fWorkers |
XrdSysSemWait * | fPingSem |
XrdSrvBuffer * | fStartMsg |
time_t | fDisconnectTime |
time_t | fSetIdleTime |
int | fStatus |
int | fSrvPID |
int | fSrvType |
short int | fID |
char | fProtVer |
XrdOucString | fFileout |
XrdNet * | fUNIXSock |
XrdOucString | fUNIXSockPath |
bool | fIsShutdown |
bool | fIsValid |
bool | fSkipCheck |
XrdOucString | fAlias |
XrdOucString | fClient |
XrdOucString | fTag |
XrdOucString | fOrdinal |
XrdOucString | fUserEnvs |
XrdOucString | fAdminPath |
XrdROOT * | fROOT |
XrdOucString | fGroup |
std::list< XrdProofQuery * > | fQueries |
Definition at line 114 of file XrdProofdProofServ.h.
XrdProofdProofServ::XrdProofdProofServ | ( | ) |
Definition at line 32 of file XrdProofdProofServ.cxx.
References fAdminPath, fAlias, fClient, fClients, fDisconnectTime, fFileout, fGroup, fID, fIsShutdown, fIsValid, fMutex, fNClients, fOrdinal, fParent, fPingSem, fProtocol, fProtVer, fQueries, fResponse, fROOT, fSetIdleTime, fSkipCheck, fSrvPID, fSrvType, fStartMsg, fStatus, fTag, fUNIXSock, fUNIXSockPath, fUserEnvs, kXPD_AnyServer, and kXPD_idle.
XrdProofdProofServ::~XrdProofdProofServ | ( | ) |
Definition at line 70 of file XrdProofdProofServ.cxx.
References XrdOucString::c_str(), ClearWorkers(), fClients, fMutex, fPingSem, fQueries, fStartMsg, fUNIXSockPath, i, SafeDelete, and unlink.
void XrdProofdProofServ::AddWorker | ( | const char * | o, | |
XrdProofWorker * | w | |||
) |
Definition at line 143 of file XrdProofdProofServ.cxx.
References XrdOucHash< T >::Add(), fMutex, fWorkers, Hash_keepdata, and w.
Referenced by XrdProofdManager::GetWorkers().
const char* XrdProofdProofServ::AdminPath | ( | ) | const [inline] |
Definition at line 122 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fAdminPath, and fMutex.
Referenced by XrdProofdProofServMgr::Accept(), XrdProofdProtocol::Ping(), XrdProofdProofServMgr::Recover(), XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdClient::VerifySession().
const char* XrdProofdProofServ::Alias | ( | ) | const [inline] |
Definition at line 123 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fAlias, and fMutex.
void XrdProofdProofServ::Broadcast | ( | const char * | msg, | |
int | type = kXPD_srvmsg | |||
) |
Definition at line 438 of file XrdProofdProofServ.cxx.
References fClients, fMutex, int, kXPD_wrkmortem, kXR_attn, len, m, nc, p, XrdProofdResponse::Send(), TRACE, TRACING, XPD_CLNT_VERSION_OK, XPDFORM, XPDLOC, and XPDPRT.
Referenced by Reset().
int XrdProofdProofServ::BroadcastPriority | ( | int | priority | ) |
Definition at line 550 of file XrdProofdProofServ.cxx.
References buf, fMutex, fResponse, kXPD_priority, kXR_attn, len, XrdProofdResponse::Send(), TRACE, and XPDLOC.
Referenced by BroadcastPriority().
const char* XrdProofdProofServ::Client | ( | ) | const [inline] |
Definition at line 126 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fClient, and fMutex.
Referenced by BroadcastPriority(), and XrdProofdProofServMgr::CleanupProofServ().
int XrdProofdProofServ::CheckSession | ( | bool | oldvers, | |
bool | isrec, | |||
int | shutopt, | |||
int | shutdel, | |||
bool | changeown, | |||
int & | nc | |||
) |
Definition at line 999 of file XrdProofdProofServ.cxx.
References XrdOucString::c_str(), emsg(), fClient, fClients, fDisconnectTime, fIsShutdown, fMutex, fSetIdleTime, fSkipCheck, fSrvPID, fSrvType, fStatus, XrdProofdAux::GetUserInfo(), i, XrdProofdAux::KillProcess(), kXPD_idle, kXPD_TopMaster, TRACE, XPDFORM, and XPDLOC.
Referenced by XrdProofdProofServMgr::CheckActiveSessions().
XrdProofQuery* XrdProofdProofServ::CurrentQuery | ( | ) | [inline] |
Definition at line 129 of file XrdProofdProofServ.h.
References fMutex, and fQueries.
Referenced by XrdProofSched::GetWorkers().
void XrdProofdProofServ::DeleteStartMsg | ( | ) | [inline] |
Definition at line 130 of file XrdProofdProofServ.h.
References fMutex, and fStartMsg.
Referenced by XrdProofdProtocol::SendMsg().
int XrdProofdProofServ::DisconnectTime | ( | ) |
void XrdProofdProofServ::DumpQueries | ( | ) |
Definition at line 872 of file XrdProofdProofServ.cxx.
References fClient, fMutex, fQueries, fSrvPID, i, TRACE, and XPDLOC.
Referenced by XrdProofSched::GetWorkers().
int XrdProofdProofServ::Enqueue | ( | XrdProofQuery * | q | ) | [inline] |
Definition at line 134 of file XrdProofdProofServ.h.
References fMutex, and fQueries.
Referenced by XrdProofSched::Enqueue().
void XrdProofdProofServ::ExportBuf | ( | XrdOucString & | buf | ) |
void XrdProofdProofServ::ExportWorkers | ( | XrdOucString & | wrks | ) |
Definition at line 862 of file XrdProofdProofServ.cxx.
References XrdOucHash< T >::Apply(), ExportWorkerDescription(), fMutex, and fWorkers.
Referenced by XrdProofdManager::GetWorkers().
const char* XrdProofdProofServ::Fileout | ( | ) | const [inline] |
Definition at line 138 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fFileout, and fMutex.
Referenced by XrdProofdProofServMgr::Create().
int XrdProofdProofServ::FreeClientID | ( | int | pid | ) |
Definition at line 323 of file XrdProofdProofServ.cxx.
References fClients, fDisconnectTime, fMutex, fNClients, fSrvPID, fStatus, i, IsValid(), SrvPID(), TRACE, TRACING, and XPDLOC.
Referenced by XrdProofdProofServMgr::Detach(), and FreeClientID().
XrdClientID * XrdProofdProofServ::GetClientID | ( | int | cid | ) |
Definition at line 270 of file XrdProofdProofServ.cxx.
References fClients, fMutex, fNClients, int, XrdClientID::Reset(), TRACE, TRACING, XPDFORM, and XPDLOC.
Referenced by XrdProofdProofServMgr::Attach(), and XrdProofdProofServMgr::Create().
int XrdProofdProofServ::GetNClients | ( | bool | check | ) |
Definition at line 365 of file XrdProofdProofServ.cxx.
References fClients, fMutex, fNClients, and i.
Referenced by XrdProofdProofServMgr::Create().
XrdProofQuery * XrdProofdProofServ::GetQuery | ( | const char * | tag | ) |
Definition at line 893 of file XrdProofdProofServ.cxx.
References fMutex, and fQueries.
Referenced by XrdProofSched::GetWorkers().
const char* XrdProofdProofServ::Group | ( | ) | const [inline] |
Definition at line 143 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fGroup, and fMutex.
Referenced by BroadcastPriority(), and XrdProofSched::GetNumWorkers().
int XrdProofdProofServ::IdleTime | ( | ) |
Definition at line 400 of file XrdProofdProofServ.cxx.
References fMutex, fSetIdleTime, fStatus, and kXPD_idle.
short int XrdProofdProofServ::ID | ( | void | ) | const [inline] |
Definition at line 145 of file XrdProofdProofServ.h.
Referenced by XrdProofdProofServMgr::Create(), XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdProofServMgr::SetProofServEnvOld().
bool XrdProofdProofServ::IsShutdown | ( | ) | const [inline] |
bool XrdProofdProofServ::IsValid | ( | ) | const [inline] |
Definition at line 147 of file XrdProofdProofServ.h.
References fIsValid, and fMutex.
Referenced by XrdProofdProofServMgr::Attach(), BroadcastPriority(), XrdProofdProofServMgr::CheckActiveSessions(), XrdProofdProofServMgr::Create(), XrdProofdClient::ExportSessions(), XrdProofSched::FirstSession(), FreeClientID(), XrdProofdClient::GetTopServers(), XrdProofdProtocol::Ping(), XrdProofdClient::SkipSessionsCheck(), and XrdProofdClient::VerifySession().
bool XrdProofdProofServ::Match | ( | short int | id | ) | const [inline] |
Definition at line 148 of file XrdProofdProofServ.h.
Referenced by XrdProofdClient::EraseServer(), XrdProofdProtocol::Interrupt(), and XrdProofdProtocol::Urgent().
const char* XrdProofdProofServ::Ordinal | ( | ) | const [inline] |
Definition at line 149 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fMutex, and fOrdinal.
Referenced by XrdProofdProofServMgr::GetTagDirs(), XrdProofdClientMgr::MapClient(), XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdProofServMgr::SetProofServEnvOld().
XrdClientID* XrdProofdProofServ::Parent | ( | ) | const [inline] |
Definition at line 150 of file XrdProofdProofServ.h.
References fMutex, and fParent.
Referenced by XrdProofdProofServMgr::Attach(), and XrdProofdProofServMgr::Create().
void XrdProofdProofServ::PingSem | ( | ) | const [inline] |
Definition at line 151 of file XrdProofdProofServ.h.
References fMutex, fPingSem, and XrdSysSemWait::Post().
XrdProofdProtocol* XrdProofdProofServ::Protocol | ( | ) | const [inline] |
Definition at line 152 of file XrdProofdProofServ.h.
References fMutex, and fProtocol.
Referenced by XrdProofdProofServMgr::Recover().
std::list<XrdProofQuery *>* XrdProofdProofServ::Queries | ( | ) | const [inline] |
void XrdProofdProofServ::RemoveQuery | ( | const char * | tag | ) |
Definition at line 914 of file XrdProofdProofServ.cxx.
References fMutex, and fQueries.
Referenced by XrdProofSched::GetWorkers().
void XrdProofdProofServ::RemoveWorker | ( | const char * | o | ) |
Definition at line 155 of file XrdProofdProofServ.cxx.
References XrdOucHash< T >::Apply(), XrdOucHash< T >::Del(), DumpWorkerCounters(), XrdOucHash< T >::Find(), fMutex, fWorkers, TRACE, TRACING, w, and XPDLOC.
void XrdProofdProofServ::Reset | ( | ) |
Definition at line 207 of file XrdProofdProofServ.cxx.
References ClearWorkers(), DeleteUNIXSock(), fAdminPath, fAlias, fClient, fClients, fDisconnectTime, fFileout, fGroup, fID, fIsShutdown, fIsValid, fMutex, fNClients, fOrdinal, fParent, fPingSem, fProtocol, fProtVer, fQueries, fResponse, fROOT, fSetIdleTime, fSkipCheck, fSrvPID, fSrvType, fStartMsg, fStatus, fTag, fUserEnvs, kXPD_AnyServer, kXPD_idle, and SafeDelete.
Referenced by XrdProofdProofServMgr::Create(), XrdProofdProofServMgr::DeleteFromSessions(), XrdProofdClient::EraseServer(), Reset(), and XrdProofdProofServMgr::ResolveSession().
int XrdProofdProofServ::Reset | ( | const char * | msg, | |
int | type | |||
) |
Definition at line 173 of file XrdProofdProofServ.cxx.
References Broadcast(), XrdOucString::c_str(), fAdminPath, fclose(), fMutex, fopen, fSrvType, kXPD_TopMaster, Reset(), TRACE, XPDFORM, and XPDLOC.
int XrdProofdProofServ::Resume | ( | ) |
Definition at line 805 of file XrdProofdProofServ.cxx.
References fMutex, fOrdinal, fResponse, fSrvPID, kXPD_resume, kXR_attn, XrdProofdResponse::Send(), TRACE, and XPDLOC.
XrdROOT* XrdProofdProofServ::ROOT | ( | ) | const [inline] |
Definition at line 161 of file XrdProofdProofServ.h.
Referenced by XrdProofdProofServMgr::Attach(), XrdProofdProofServMgr::CheckActiveSessions(), XrdProofdProofServMgr::Create(), XrdProofdManager::GetWorkers(), XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdProofServMgr::SetProofServEnvOld().
XrdProofdResponse* XrdProofdProofServ::Response | ( | ) | const [inline] |
Definition at line 162 of file XrdProofdProofServ.h.
References fMutex, and fResponse.
Referenced by XrdProofdProtocol::Interrupt(), XrdProofdProtocol::SendData(), and XrdProofdProtocol::Urgent().
int XrdProofdProofServ::SendData | ( | int | cid, | |
void * | buff, | |||
int | len | |||
) |
Definition at line 576 of file XrdProofdProofServ.cxx.
References fClients, fMutex, kXPD_msg, kXR_attn, XrdClientID::R(), XrdProofdResponse::Send(), XrdClientID::Sid(), TRACE, XPDFORM, and XPDLOC.
Referenced by XrdProofdProtocol::SendData().
int XrdProofdProofServ::SendDataN | ( | void * | buff, | |
int | len | |||
) |
Definition at line 618 of file XrdProofdProofServ.cxx.
References fClients, fMutex, int, kXPD_msg, kXR_attn, XrdClientID::P(), XrdClientID::R(), TRACE, and XPDLOC.
Referenced by XrdProofdProtocol::SendDataN().
void XrdProofdProofServ::SendClusterInfo | ( | int | nsess, | |
int | nacti | |||
) |
Definition at line 957 of file XrdProofdProofServ.cxx.
References XrdOucHash< T >::Apply(), buf, CountEffectiveSessions(), fMutex, fResponse, fWorkers, kXPD_clusterinfo, kXR_attn, len, XrdOucHash< T >::Num(), XrdProofdResponse::Send(), TRACE, and XPDLOC.
int XrdProofdProofServ::SetAdminPath | ( | const char * | a, | |
bool | assert | |||
) |
Definition at line 742 of file XrdProofdProofServ.cxx.
References XrdOucString::c_str(), XrdProofdAux::ChangeOwn(), fAdminPath, fClient, fclose(), fMutex, fopen, fprintf(), fStatus, XrdProofdAux::GetUserInfo(), stat, TRACE, XPDFORM, and XPDLOC.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetAlias | ( | const char * | a | ) | [inline] |
void XrdProofdProofServ::SetClient | ( | const char * | c | ) | [inline] |
Definition at line 168 of file XrdProofdProofServ.h.
References fClient, and fMutex.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetConnection | ( | XrdProofdResponse * | r | ) | [inline] |
Definition at line 169 of file XrdProofdProofServ.h.
References fMutex, and fResponse.
Referenced by XrdProofdClientMgr::MapClient().
void XrdProofdProofServ::SetFileout | ( | const char * | f | ) | [inline] |
Definition at line 171 of file XrdProofdProofServ.h.
References fFileout, and fMutex.
Referenced by XrdProofdProofServMgr::Create(), XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdProofServMgr::SetProofServEnvOld().
void XrdProofdProofServ::SetGroup | ( | const char * | g | ) | [inline] |
Definition at line 172 of file XrdProofdProofServ.h.
References fGroup, and fMutex.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetIdle | ( | ) |
Definition at line 414 of file XrdProofdProofServ.cxx.
References fMutex, fSetIdleTime, fStatus, and kXPD_idle.
void XrdProofdProofServ::SetID | ( | short int | id | ) | [inline] |
Definition at line 174 of file XrdProofdProofServ.h.
Referenced by XrdProofdClient::GetFreeServObj(), and XrdProofdClient::GetServObj().
void XrdProofdProofServ::SetOrdinal | ( | const char * | o | ) | [inline] |
Definition at line 175 of file XrdProofdProofServ.h.
References fMutex, and fOrdinal.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetParent | ( | XrdClientID * | cid | ) | [inline] |
Definition at line 176 of file XrdProofdProofServ.h.
References fMutex, and fParent.
Referenced by XrdProofdProofServMgr::Attach(), and XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetProtocol | ( | XrdProofdProtocol * | p | ) | [inline] |
Definition at line 177 of file XrdProofdProofServ.h.
References fMutex, fProtocol, and p.
Referenced by XrdProofdProofServMgr::Accept().
void XrdProofdProofServ::SetProtVer | ( | int | pv | ) | [inline] |
Definition at line 178 of file XrdProofdProofServ.h.
References fMutex, and fProtVer.
Referenced by XrdProofdClientMgr::MapClient().
void XrdProofdProofServ::SetROOT | ( | XrdROOT * | r | ) | [inline] |
void XrdProofdProofServ::SetRunning | ( | ) |
Definition at line 426 of file XrdProofdProofServ.cxx.
References fMutex, fSetIdleTime, fStatus, and kXPD_running.
void XrdProofdProofServ::SetShutdown | ( | ) | [inline] |
void XrdProofdProofServ::SetSkipCheck | ( | ) | [inline] |
Definition at line 182 of file XrdProofdProofServ.h.
References fMutex, and fSkipCheck.
Referenced by XrdProofdClient::SkipSessionsCheck().
void XrdProofdProofServ::SetSrvPID | ( | int | pid | ) | [inline] |
Definition at line 183 of file XrdProofdProofServ.h.
References fMutex, and fSrvPID.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetSrvType | ( | int | id | ) | [inline] |
Definition at line 184 of file XrdProofdProofServ.h.
References fMutex, and fSrvType.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetStartMsg | ( | XrdSrvBuffer * | sm | ) | [inline] |
Definition at line 185 of file XrdProofdProofServ.h.
References fMutex, and fStartMsg.
Referenced by XrdProofdProtocol::SendMsg().
void XrdProofdProofServ::SetStatus | ( | int | st | ) | [inline] |
Definition at line 186 of file XrdProofdProofServ.h.
References fMutex, and fStatus.
Referenced by XrdProofdProtocol::SendMsg().
void XrdProofdProofServ::SetTag | ( | const char * | t | ) | [inline] |
Definition at line 187 of file XrdProofdProofServ.h.
Referenced by XrdProofdProofServMgr::Create(), and XrdProofdProofServMgr::GetTagDirs().
void XrdProofdProofServ::SetUNIXSockPath | ( | const char * | s | ) | [inline] |
Definition at line 188 of file XrdProofdProofServ.h.
References fMutex, and fUNIXSockPath.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetUserEnvs | ( | const char * | t | ) | [inline] |
Definition at line 189 of file XrdProofdProofServ.h.
References fMutex, and fUserEnvs.
Referenced by XrdProofdProofServMgr::Create().
void XrdProofdProofServ::SetValid | ( | bool | valid = 1 |
) | [inline] |
Definition at line 190 of file XrdProofdProofServ.h.
References fIsValid, and fMutex.
Referenced by XrdProofdClient::GetFreeServObj(), XrdProofdClient::GetServObj(), XrdProofdClientMgr::MapClient(), and XrdProofdProofServMgr::ResolveSession().
bool XrdProofdProofServ::SkipCheck | ( | ) |
int XrdProofdProofServ::SrvPID | ( | ) | const [inline] |
Definition at line 192 of file XrdProofdProofServ.h.
References fMutex, and fSrvPID.
Referenced by XrdProofdProofServMgr::Create(), XrdProofdProofServMgr::Destroy(), FreeClientID(), XrdProofdClient::GetServer(), XrdProofdClient::GetTopServers(), XrdProofSched::GetWorkers(), XrdProofdProtocol::Interrupt(), XrdProofdProtocol::Ping(), XrdProofdProtocol::PostSession(), XrdProofdProofServMgr::Recover(), XrdProofdClient::SkipSessionsCheck(), and XrdProofdClient::VerifySession().
int XrdProofdProofServ::SrvType | ( | ) | const [inline] |
Definition at line 193 of file XrdProofdProofServ.h.
References fMutex, and fSrvType.
Referenced by BroadcastPriority(), CountTopMasters(), XrdProofdProofServMgr::Create(), XrdProofdClient::GetTopServers(), XrdProofdProtocol::PostSession(), XrdProofdProtocol::SendMsg(), and XrdProofdClient::SkipSessionsCheck().
XrdSrvBuffer* XrdProofdProofServ::StartMsg | ( | ) | const [inline] |
Definition at line 194 of file XrdProofdProofServ.h.
References fMutex, and fStartMsg.
Referenced by XrdProofdProofServMgr::Attach().
int XrdProofdProofServ::Status | ( | ) | const [inline] |
Definition at line 195 of file XrdProofdProofServ.h.
References fMutex, and fStatus.
Referenced by XrdProofdProofServMgr::Attach(), BroadcastPriority(), XrdProofdProtocol::SendMsg(), and XrdProofdProtocol::Urgent().
const char* XrdProofdProofServ::Tag | ( | ) | const [inline] |
Definition at line 196 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fMutex, and fTag.
Referenced by XrdProofdProofServMgr::Create(), and XrdProofdProofServMgr::GetTagDirs().
int XrdProofdProofServ::TerminateProofServ | ( | bool | changeown | ) |
Definition at line 478 of file XrdProofdProofServ.cxx.
References XrdOucString::c_str(), fClient, fIsShutdown, fMutex, fOrdinal, fSrvPID, XrdProofdAux::GetUserInfo(), XrdProofdAux::KillProcess(), TRACE, and XPDLOC.
const char* XrdProofdProofServ::UserEnvs | ( | ) | const [inline] |
Definition at line 198 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), fMutex, and fUserEnvs.
Referenced by XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdProofServMgr::SetProofServEnvOld().
int XrdProofdProofServ::VerifyProofServ | ( | bool | fw | ) |
Definition at line 507 of file XrdProofdProofServ.cxx.
References buf, fMutex, fOrdinal, fResponse, fSrvPID, kXPD_ping, kXR_attn, len, XrdProofdResponse::Send(), TRACE, and XPDLOC.
Referenced by XrdProofdProofServMgr::CheckActiveSessions(), XrdProofdProtocol::Ping(), and XrdProofdClient::VerifySession().
XrdOucHash<XrdProofWorker>* XrdProofdProofServ::Workers | ( | ) | const [inline] |
Definition at line 200 of file XrdProofdProofServ.h.
References fMutex, and fWorkers.
Referenced by XrdProofSched::GetWorkers().
int XrdProofdProofServ::CreateUNIXSock | ( | XrdSysError * | edest | ) |
Definition at line 668 of file XrdProofdProofServ.cxx.
References XrdNet::Bind(), XrdOucString::c_str(), close, fAdminPath, fClient, fclose(), XrdProofUI::fGid, fopen, XrdProofUI::fUid, fUNIXSock, fUNIXSockPath, XrdProofdAux::GetUserInfo(), XrdOucString::length(), ok, open, stat, TRACE, unlink, XPDLOC, and XPDPRT.
Referenced by XrdProofdProofServMgr::Create(), and XrdProofdProofServMgr::ResolveSession().
void XrdProofdProofServ::DeleteUNIXSock | ( | ) |
Definition at line 248 of file XrdProofdProofServ.cxx.
References XrdOucString::c_str(), fUNIXSock, fUNIXSockPath, SafeDelete, and unlink.
Referenced by XrdProofdProofServMgr::Create(), and Reset().
XrdNet* XrdProofdProofServ::UNIXSock | ( | ) | const [inline] |
Definition at line 206 of file XrdProofdProofServ.h.
References fUNIXSock.
Referenced by XrdProofdProofServMgr::Accept(), and XrdProofdProofServMgr::Create().
const char* XrdProofdProofServ::UNIXSockPath | ( | ) | const [inline] |
Definition at line 207 of file XrdProofdProofServ.h.
References XrdOucString::c_str(), and fUNIXSockPath.
Referenced by XrdProofdProofServMgr::Accept(), XrdProofdProofServMgr::Create(), XrdProofdProofServMgr::ResolveSession(), XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdProofServMgr::SetProofServEnvOld().
void XrdProofdProofServ::ClearWorkers | ( | ) | [private] |
Definition at line 131 of file XrdProofdProofServ.cxx.
References XrdOucHash< T >::Apply(), DecreaseWorkerCounters(), fMutex, fWorkers, and XrdOucHash< T >::Purge().
Referenced by Reset(), and ~XrdProofdProofServ().
void XrdProofdProofServ::CreatePingSem | ( | ) | [inline, private] |
Definition at line 254 of file XrdProofdProofServ.h.
References fMutex, fPingSem, and XrdSysSemWait.
void XrdProofdProofServ::DeletePingSem | ( | ) | [inline, private] |
XrdSysRecMutex* XrdProofdProofServ::fMutex [private] |
Definition at line 211 of file XrdProofdProofServ.h.
Referenced by AddWorker(), AdminPath(), Alias(), Broadcast(), BroadcastPriority(), CheckSession(), ClearWorkers(), Client(), CreatePingSem(), CurrentQuery(), DeletePingSem(), DeleteStartMsg(), DisconnectTime(), DumpQueries(), Enqueue(), ExportBuf(), ExportWorkers(), Fileout(), FreeClientID(), GetClientID(), GetNClients(), GetQuery(), Group(), ID(), IdleTime(), IsShutdown(), IsValid(), Match(), Ordinal(), Parent(), PingSem(), Protocol(), RemoveQuery(), RemoveWorker(), Reset(), Response(), Resume(), ROOT(), SendClusterInfo(), SendData(), SendDataN(), SetAdminPath(), SetAlias(), SetClient(), SetConnection(), SetFileout(), SetGroup(), SetID(), SetIdle(), SetOrdinal(), SetParent(), SetProtocol(), SetProtVer(), SetROOT(), SetRunning(), SetShutdown(), SetSkipCheck(), SetSrvPID(), SetSrvType(), SetStartMsg(), SetStatus(), SetTag(), SetUNIXSockPath(), SetUserEnvs(), SetValid(), SkipCheck(), SrvPID(), SrvType(), StartMsg(), Status(), Tag(), TerminateProofServ(), UserEnvs(), VerifyProofServ(), Workers(), XrdProofdProofServ(), and ~XrdProofdProofServ().
XrdProofdProtocol* XrdProofdProofServ::fProtocol [private] |
Definition at line 212 of file XrdProofdProofServ.h.
Referenced by Protocol(), Reset(), SetProtocol(), and XrdProofdProofServ().
XrdProofdResponse* XrdProofdProofServ::fResponse [private] |
Definition at line 213 of file XrdProofdProofServ.h.
Referenced by BroadcastPriority(), Reset(), Response(), Resume(), SendClusterInfo(), SetConnection(), VerifyProofServ(), and XrdProofdProofServ().
XrdClientID* XrdProofdProofServ::fParent [private] |
Definition at line 215 of file XrdProofdProofServ.h.
Referenced by Parent(), Reset(), SetParent(), and XrdProofdProofServ().
int XrdProofdProofServ::fNClients [private] |
Definition at line 216 of file XrdProofdProofServ.h.
Referenced by ExportBuf(), FreeClientID(), GetClientID(), GetNClients(), Reset(), and XrdProofdProofServ().
std::vector<XrdClientID *> XrdProofdProofServ::fClients [private] |
Definition at line 217 of file XrdProofdProofServ.h.
Referenced by Broadcast(), CheckSession(), FreeClientID(), GetClientID(), GetNClients(), Reset(), SendData(), SendDataN(), XrdProofdProofServ(), and ~XrdProofdProofServ().
XrdOucHash<XrdProofWorker> XrdProofdProofServ::fWorkers [private] |
Definition at line 218 of file XrdProofdProofServ.h.
Referenced by AddWorker(), ClearWorkers(), ExportWorkers(), RemoveWorker(), SendClusterInfo(), and Workers().
XrdSysSemWait* XrdProofdProofServ::fPingSem [private] |
Definition at line 220 of file XrdProofdProofServ.h.
Referenced by CreatePingSem(), DeletePingSem(), PingSem(), Reset(), XrdProofdProofServ(), and ~XrdProofdProofServ().
XrdSrvBuffer* XrdProofdProofServ::fStartMsg [private] |
Definition at line 222 of file XrdProofdProofServ.h.
Referenced by DeleteStartMsg(), Reset(), SetStartMsg(), StartMsg(), XrdProofdProofServ(), and ~XrdProofdProofServ().
time_t XrdProofdProofServ::fDisconnectTime [private] |
Definition at line 224 of file XrdProofdProofServ.h.
Referenced by CheckSession(), DisconnectTime(), FreeClientID(), Reset(), and XrdProofdProofServ().
time_t XrdProofdProofServ::fSetIdleTime [private] |
Definition at line 225 of file XrdProofdProofServ.h.
Referenced by CheckSession(), IdleTime(), Reset(), SetIdle(), SetRunning(), and XrdProofdProofServ().
int XrdProofdProofServ::fStatus [private] |
Definition at line 227 of file XrdProofdProofServ.h.
Referenced by CheckSession(), ExportBuf(), FreeClientID(), IdleTime(), Reset(), SetAdminPath(), SetIdle(), SetRunning(), SetStatus(), Status(), and XrdProofdProofServ().
int XrdProofdProofServ::fSrvPID [private] |
Definition at line 228 of file XrdProofdProofServ.h.
Referenced by CheckSession(), DumpQueries(), FreeClientID(), Reset(), Resume(), SetSrvPID(), SrvPID(), TerminateProofServ(), VerifyProofServ(), and XrdProofdProofServ().
int XrdProofdProofServ::fSrvType [private] |
Definition at line 229 of file XrdProofdProofServ.h.
Referenced by CheckSession(), Reset(), SetSrvType(), SrvType(), and XrdProofdProofServ().
short int XrdProofdProofServ::fID [private] |
Definition at line 230 of file XrdProofdProofServ.h.
Referenced by ExportBuf(), ID(), Match(), Reset(), SetID(), and XrdProofdProofServ().
char XrdProofdProofServ::fProtVer [private] |
Definition at line 231 of file XrdProofdProofServ.h.
Referenced by Reset(), SetProtVer(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fFileout [private] |
Definition at line 232 of file XrdProofdProofServ.h.
Referenced by Fileout(), Reset(), SetFileout(), and XrdProofdProofServ().
XrdNet* XrdProofdProofServ::fUNIXSock [private] |
Definition at line 234 of file XrdProofdProofServ.h.
Referenced by CreateUNIXSock(), DeleteUNIXSock(), UNIXSock(), and XrdProofdProofServ().
Definition at line 235 of file XrdProofdProofServ.h.
Referenced by CreateUNIXSock(), DeleteUNIXSock(), SetUNIXSockPath(), UNIXSockPath(), XrdProofdProofServ(), and ~XrdProofdProofServ().
bool XrdProofdProofServ::fIsShutdown [private] |
Definition at line 237 of file XrdProofdProofServ.h.
Referenced by CheckSession(), IsShutdown(), Reset(), SetShutdown(), TerminateProofServ(), and XrdProofdProofServ().
bool XrdProofdProofServ::fIsValid [private] |
Definition at line 238 of file XrdProofdProofServ.h.
Referenced by IsValid(), Reset(), SetValid(), and XrdProofdProofServ().
bool XrdProofdProofServ::fSkipCheck [private] |
Definition at line 239 of file XrdProofdProofServ.h.
Referenced by CheckSession(), Reset(), SetSkipCheck(), SkipCheck(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fAlias [private] |
Definition at line 241 of file XrdProofdProofServ.h.
Referenced by Alias(), ExportBuf(), Reset(), SetAlias(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fClient [private] |
Definition at line 242 of file XrdProofdProofServ.h.
Referenced by CheckSession(), Client(), CreateUNIXSock(), DumpQueries(), Reset(), SetAdminPath(), SetClient(), TerminateProofServ(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fTag [private] |
Definition at line 243 of file XrdProofdProofServ.h.
Referenced by ExportBuf(), Reset(), SetTag(), Tag(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fOrdinal [private] |
Definition at line 244 of file XrdProofdProofServ.h.
Referenced by Ordinal(), Reset(), Resume(), SetOrdinal(), TerminateProofServ(), VerifyProofServ(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fUserEnvs [private] |
Definition at line 245 of file XrdProofdProofServ.h.
Referenced by Reset(), SetUserEnvs(), UserEnvs(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fAdminPath [private] |
Definition at line 246 of file XrdProofdProofServ.h.
Referenced by AdminPath(), CreateUNIXSock(), Reset(), SetAdminPath(), and XrdProofdProofServ().
XrdROOT* XrdProofdProofServ::fROOT [private] |
Definition at line 248 of file XrdProofdProofServ.h.
Referenced by Reset(), ROOT(), SetROOT(), and XrdProofdProofServ().
XrdOucString XrdProofdProofServ::fGroup [private] |
Definition at line 250 of file XrdProofdProofServ.h.
Referenced by Group(), Reset(), SetGroup(), and XrdProofdProofServ().
std::list<XrdProofQuery *> XrdProofdProofServ::fQueries [private] |
Definition at line 258 of file XrdProofdProofServ.h.
Referenced by CurrentQuery(), DumpQueries(), Enqueue(), GetQuery(), Queries(), RemoveQuery(), Reset(), XrdProofdProofServ(), and ~XrdProofdProofServ().