44 const
char *confdir,
Int_t loglevel,
46 : fCondor(0), fTimer(0)
54 fUrl =
TUrl(masterurl);
56 if (!conffile || !conffile[0]) {
58 }
else if (!strncasecmp(conffile,
"condor:", 7)) {
62 if (!confdir || !confdir[0]) {
66 Init(masterurl, conffile, confdir, loglevel);
88 Error(
"StartSlaves",
"Empty Condor image found for system %s",
97 TIter nextclaim(condorclaims);
98 while (
TObject *o = nextclaim()) claims.
Add(o);
107 if (workerList->GetSize() == 0) {
120 while ((to =
next())) {
144 m <<
TString(
"Creating COD Claim") << workerList->GetSize()
145 << nSlavesDone << (csl != 0);
160 int nClaims = claims.
GetSize();
187 if (trial < ntries) {
188 if (slave && slave->
IsValid()) {
202 m <<
TString(
"Opening connections to workers") << nClaims
203 << nClaimsDone <<
kTRUE;
210 claims.
AddAt(p, idx);
213 if (p && p->
Value()) {
221 Warning(
"StartSlaves",
"could not create TSlave object!");
227 if (p && p->
Value()) {
235 m <<
TString(
"Opening connections to workers") << nClaims
236 << nClaimsDone << slave->
IsValid();
239 Warning(
"StartSlaves",
"could not create TSlave object!");
254 while ((sl = (
TSlave *) nxsl())) {
271 m <<
TString(
"Setting up worker servers") << nSlavesTotal
272 << nSlavesDone << wrkvalid;
288 PDB(kCondor,1)
Info(
"SetActive",
"-- Condor Resume --");
297 PDB(kCondor,1)
Info(
"SetActive",
"-- Delayed Condor Suspend (%d msec / to %lld) --",
312 ad =
"JobUniverse = 5\n";
315 ad +=
"In = \"/dev/null\"\n";
virtual void AddAt(TObject *obj, Int_t idx)
Insert object at position idx in the list.
ClassImp(TProofCondor) TProofCondor
Start proof using condor.
TSocket * GetSocket() const
void Reset()
Reset the timer.
ClassImp(TSeqCollection) Int_t TSeqCollection TIter next(this)
Return index of object in collection.
virtual Int_t Send(const TMessage &mess)
Send a TMessage object.
This class represents a WWW compatible URL.
virtual void Info(const char *method, const char *msgfmt,...) const
Issue info message.
virtual void Add(TSocket *sock, Int_t interest=kRead)
Add socket to the monitor's active list.
virtual const char * TempDirectory() const
Return a user configured or systemwide directory to create temporary files in.
virtual TObject * At(Int_t idx) const
Returns the object at position idx. Returns 0 if idx is out of range.
virtual TObject * RemoveAt(Int_t idx)
const char * Data() const
TList * GetWorkers()
Get the list of worker nodes.
virtual void Sleep(UInt_t milliSec)
Sleep milliSec milli seconds.
TSlave * CreateSlave(const char *url, const char *ord, Int_t perf, const char *image, const char *workdir)
Create a new TSlave of type TSlave::kSlave.
Bool_t StartSlaves(Bool_t)
Setup Condor workers using dynamic information.
virtual void Start(Long_t milliSec=-1, Bool_t singleShot=kFALSE)
Starts the timer with a milliSec timeout.
void Init(TClassEdit::TInterpreterLookupHelper *helper)
TList * Claim(Int_t n, const char *cmd)
Claim n virtual machines This function figures out the image and performance index before returning t...
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
const char *const kPROOF_ConfFile
const char Int_t const char TProof Int_t const char * workdir
Bool_t Connect(const char *signal, const char *receiver_class, void *receiver, const char *slot)
Non-static method is used to connect from the signal of this object to the receiver slot...
TSocket * GetSocket() const
const TString & GetWorkDir() const
virtual TTime Now()
Get current time in milliseconds since 0:00 Jan 1 1995.
R__EXTERN TSystem * gSystem
Int_t GetLogLevel() const
virtual TObject * Remove(TObject *obj)
Remove object from the list.
const char *const kPROOF_ConfDir
char * Form(const char *fmt,...)
virtual ~TProofCondor()
Clean up Condor PROOF environment.
Handles synchronous and a-synchronous timer events.
TString GetJobAd()
Get job Ad.
Class used by TMap to store (key,value) pairs.
virtual Int_t GetSize() const
TString GetFileName() const
virtual const char * HostName()
Return the system's host name.
const char * GetOrdinal() const
TString GetImage(const char *host) const
Get image of the worker.
Mother of all ROOT objects.
R__EXTERN TProofServ * gProofServ
virtual void Add(TObject *obj)
const char * GetConfDir() const
const TString & GetNodeName() const
virtual Bool_t ExpandPathName(TString &path)
Expand a pathname getting rid of special shell characters like ~.
virtual Bool_t IsValid() const
Int_t GetPerfIndex() const
const TString & GetImage() const
Bool_t Resume()
Resume worker.
virtual Int_t SetupServ(Int_t stype, const char *conffile)
Init a PROOF slave object.
const char Int_t const char * image
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.