#include <TXProofServ.h>
Inheritance diagram for TXProofServ:
Public Member Functions | |
| TXProofServ (Int_t *argc, char **argv, FILE *flog=0) | |
| virtual | ~TXProofServ () |
| Int_t | CreateServer () |
| void | DisableTimeout () |
| void | EnableTimeout () |
| EQueryAction | GetWorkers (TList *workers, Int_t &prioritychange, Bool_t resume=kFALSE) |
| Bool_t | HandleError (const void *in=0) |
| Bool_t | HandleInput (const void *in=0) |
| void | HandleUrgentData () |
| void | HandleSigPipe () |
| void | HandleTermination () |
| void | ReleaseWorker (const char *ord) |
| void | Terminate (Int_t status) |
Private Member Functions | |
| Int_t | LockSession (const char *sessiontag, TProofLockPath **lck) |
| Int_t | Setup () |
Private Attributes | |
| TXProofServInterruptHandler * | fInterruptHandler |
| TXSocketHandler * | fInputHandler |
| TString | fSockPath |
| Bool_t | fTerminated |
Definition at line 34 of file TXProofServ.h.
| TXProofServ::TXProofServ | ( | Int_t * | argc, | |
| char ** | argv, | |||
| FILE * | flog = 0 | |||
| ) |
Definition at line 149 of file TXProofServ.cxx.
References fInputHandler, fInterruptHandler, fTerminated, and kFALSE.
| TXProofServ::~TXProofServ | ( | ) | [virtual] |
| Int_t TXProofServ::LockSession | ( | const char * | sessiontag, | |
| TProofLockPath ** | lck | |||
| ) | [private] |
Definition at line 1074 of file TXProofServ.cxx.
References TSystem::AccessPathName(), TProofServ::fQueryLock, TProofServ::fSessionDir, TProofServ::fTopSessionTag, TNamed::GetName(), gSystem, TString::Index(), TObject::Info(), kNPOS, TString::Remove(), TString::ReplaceAll(), and SafeDelete.
| Int_t TXProofServ::Setup | ( | ) | [private, virtual] |
Reimplemented from TProofServ.
Definition at line 614 of file TXProofServ.cxx.
References TSystem::AddSignalHandler(), TString::Contains(), TString::CountChar(), TString::Data(), TString::EndsWith(), TObject::Error(), TSystem::ExpandPathName(), TProofServ::fConfFile, Form(), TProofServ::fProtocol, TProofServ::fSessionDir, TProofServ::fSessionTag, TProofServ::fSocket, TProofServ::fTopSessionTag, UserGroup_t::fUser, TProofServ::fUser, TProofServ::fWorkDir, gEnv, TSystem::GetPid(), TSystem::GetUserInfo(), TEnv::GetValue(), gProofDebugLevel, gSystem, TSystem::HostName(), TString::Index(), TObject::Info(), TProofServ::IsMaster(), kKeepAlive, kNoDelay, kNPOS, kPROOF_WorkDir, TString::Length(), TString::Remove(), TSocket::Send(), TSocket::SetOption(), TProofServ::SetupCommon(), sprintf(), str, TObject::Warning(), and workdir.
Referenced by CreateServer().
| Int_t TXProofServ::CreateServer | ( | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 170 of file TXProofServ.cxx.
References TSystem::AddFileHandler(), TApplication::Argc(), TApplication::Argv(), TProofServ::CatMotd(), TString::Data(), EnvPutInt, TObject::Error(), TProofServ::fCompressMsg, TProofServ::fConfDir, TProofServ::fConfFile, TProofServ::fEndMaster, TProofServ::fIdleTOTimer, TPluginManager::FindHandler(), fInputHandler, TProofServ::fLogFile, TProofServ::fLogFileDes, TProofServ::fLogLevel, TProofServ::FlushLogFile(), TProofServ::fMasterServ, TProofServ::fOrdinal, TString::Form(), Form(), TProofServ::fProof, TProofServ::fProtocol, TProofServ::fService, TProofServ::fShutdownTimer, TProofServ::fSocket, fSockPath, TProofServ::fTopSessionTag, TProofServ::fUser, gEnv, TSocket::GetDescriptor(), TSystem::Getenv(), TROOT::GetMacroPath(), TROOT::GetPluginManager(), TXSocketHandler::GetSocketHandler(), TEnv::GetValue(), gInterpreter, gProofDebugLevel, gProofServDebug, gROOT, gSystem, h, TObject::Info(), TString::Insert(), TProof::IsEndMaster(), TProofServ::IsMaster(), TProof::IsValid(), TSocket::IsValid(), kFALSE, kNPOS, kPROOF_Protocol, kReadPermission, kTRUE, TString::Last(), TString::Length(), TProofServ::LogToMaster(), lseek, NAME_DEBUG, TApplication::NoLogOpt(), XrdMonCtrCollector::port, TApplication::ProcessFile(), TApplication::ProcessLine(), TProofServ::RedirectOutput(), TString::Remove(), TProof::SaveWorkerInfo(), SEEK_END, TProofServ::SendAsynMessage(), TProofServ::SendLogFile(), TSocket::SetCompressionLevel(), TXSocket::SetLocation(), TNamed::SetTitle(), Setup(), TEnv::SetValue(), TTimer::Start(), strtol(), Terminate(), TSystem::Which(), and write.
| void TXProofServ::DisableTimeout | ( | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 972 of file TXProofServ.cxx.
References TProofServ::fSocket.
| void TXProofServ::EnableTimeout | ( | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 981 of file TXProofServ.cxx.
References TProofServ::fSocket.
| TProofServ::EQueryAction TXProofServ::GetWorkers | ( | TList * | workers, | |
| Int_t & | prioritychange, | |||
| Bool_t | resume = kFALSE | |||
| ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 725 of file TXProofServ.cxx.
References TList::Add(), TString::Data(), TObject::Error(), TProofServ::fImage, TList::FindObject(), TList::First(), TString::Form(), TProofServ::fSocket, TProofServ::fWaitingQueries, gDebug, gEnv, TSystem::Getenv(), TObjString::GetName(), TProofNodeInfo::GetNodeName(), TEnv::GetValue(), TProofServ::GetWorkers(), gSystem, TObject::Info(), TCollection::IsEmpty(), TString::IsNull(), kFALSE, kGetWorkers, TProofServ::kQueryEnqueued, TProofServ::kQueryOK, TProofServ::kQueryStop, kTRUE, TList::Last(), p, s, SafeDelete, TProofServ::SendAsynMessage(), TCollection::SetOwner(), XPD_GW_QueryEnqueued, and XPD_GW_Static.
| Bool_t TXProofServ::HandleError | ( | const void * | in = 0 |
) | [virtual] |
Reimplemented from TXHandler.
Definition at line 855 of file TXProofServ.cxx.
References TProof::Close(), TProofServ::FlushLogFile(), TProofServ::fProof, TProofServ::fSocket, gDebug, TObject::Info(), TProofServ::IsMaster(), TSocket::IsValid(), kFALSE, kTRUE, Printf(), TSocket::Reconnect(), and Terminate().
| Bool_t TXProofServ::HandleInput | ( | const void * | in = 0 |
) | [virtual] |
Reimplemented from TXHandler.
Definition at line 890 of file TXProofServ.cxx.
References TProof::BroadcastGroupPriority(), TProofServ::fActSessions, TProofServ::fEffSessions, fflush(), TProofServ::fGroup, TProofServ::fGroupPriority, TProofServ::fInflateFactor, XHandleIn_t::fInt1, XHandleIn_t::fInt2, XHandleIn_t::fInt3, XHandleIn_t::fInt4, TProofServ::fPlayer, TProofServ::fProof, TProofServ::fSocket, TProofServ::fTotSessions, gDebug, TProofServ::HandleSocketInput(), HandleUrgentData(), if(), TObject::Info(), kFALSE, TXSocket::kStopProcess, kTRUE, kXPD_clusterinfo, kXPD_flush, kXPD_inflate, kXPD_interrupt, kXPD_msg, kXPD_ping, kXPD_priority, kXPD_urgent, Printf(), TVirtualProofPlayer::StopProcess(), TProof::StopProcess(), and type.
| void TXProofServ::HandleUrgentData | ( | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 457 of file TXProofServ.cxx.
References TString::Data(), TString::EndsWith(), TObject::Error(), TProof::fActiveSlaves, TProofServ::fAdminPath, TProofServ::fLogFile, TProofServ::fProof, TProofServ::fRealTimeLog, TProofServ::fSocket, gEnv, TCollection::GetSize(), TEnv::GetValue(), HandleTermination(), TObject::Info(), TProofServ::Interrupt(), TProof::Interrupt(), TProofServ::IsMaster(), TString::IsNull(), kFALSE, TProof::kHardInterrupt, TProof::kPing, TProof::kShutdownInterrupt, TProof::kSoftInterrupt, PDB, TProof::Ping(), TProofServ::SendLogFile(), TProof::SetActive(), and TProofServ::UpdateSessionStatus().
Referenced by HandleInput().
| void TXProofServ::HandleSigPipe | ( | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 570 of file TXProofServ.cxx.
References TObject::Info().
Referenced by TXProofServSigPipeHandler::Notify().
| void TXProofServ::HandleTermination | ( | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 580 of file TXProofServ.cxx.
References TProof::Close(), TProof::Collect(), TList::Delete(), TProofServ::fIdle, TProofServ::fProof, TProofServ::fWaitingQueries, gEnv, TEnv::GetValue(), TProof::InterruptCurrentMonitor(), TProofServ::IsMaster(), TProof::kActive, kTRUE, TProof::StopProcess(), Terminate(), and TObject::Warning().
Referenced by HandleUrgentData(), TXProofServSegViolationHandler::Notify(), and TXProofServTerminationHandler::Notify().
| void TXProofServ::ReleaseWorker | ( | const char * | ord | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 1132 of file TXProofServ.cxx.
References TProofServ::fSocket, TObject::Info(), and kReleaseWorker.
| void TXProofServ::Terminate | ( | Int_t | status | ) | [virtual] |
Reimplemented from TProofServ.
Definition at line 990 of file TXProofServ.cxx.
References TSystem::AccessPathName(), TSystem::ChangeDirectory(), TString::Data(), TSystem::Exec(), TSystem::ExitLoop(), TProofServ::fCpuTime, TProofServ::fDataDir, TProofServ::fgLogToSysLog, TXSocket::fgPipe, TProofServ::fgResMemMax, TProofServ::fgSysLogEntity, TProofServ::fgVirtMemMax, TProofServ::fIdle, fInputHandler, Form(), TProofServ::fPlayer, TProofServ::fProof, TProofServ::fQMgr, TProofServ::fQueryDir, TProofServ::fQueryLock, TProofServ::fRealTime, TProofServ::fSessionDir, TProofServ::fSocket, fTerminated, TNamed::GetName(), TSystem::GetProcInfo(), TCollection::GetSize(), gSystem, TObject::Info(), TProofServ::IsMaster(), TString::IsNull(), kFALSE, kLogNotice, kRM, kTRUE, kWritePermission, TSystem::MakeDirectory(), pi, TXSockPipe::Post(), Printf(), TQueryResultManager::Queries(), TSystem::RemoveFileHandler(), s, TProof::SetMonitor(), TSystem::Sleep(), TVirtualProofPlayer::StopProcess(), TSystem::Syslog(), TSystem::Unlink(), and TProofServ::UnlinkDataDir().
Referenced by CreateServer(), HandleError(), and HandleTermination().
TXProofServInterruptHandler* TXProofServ::fInterruptHandler [private] |
TXSocketHandler* TXProofServ::fInputHandler [private] |
Reimplemented from TProofServ.
Definition at line 38 of file TXProofServ.h.
Referenced by CreateServer(), Terminate(), and TXProofServ().
TString TXProofServ::fSockPath [private] |
Bool_t TXProofServ::fTerminated [private] |
1.5.1