VAFRailway.C

Go to the documentation of this file.

#ifndef VAFHELPER_C
#define VAFHELPER_C
#include "ProofRailway.C"
#ifndef __CINT__
# include <TUrl.h>
# include <TString.h>
# include <TProof.h>
# include <TSystem.h>
#else
class TUrl;
#endif

// ===================================================================
struct VAFRailway : public ProofRailway
{
  VAFRailway(const TUrl& url, Int_t verbose)
    : ProofRailway(url, verbose)
  {
    fOptions.Add("nocache", "Disable tree cache");
    fOptions.Add("pattern","SEARCH","Search pattern", "");
    fOptions.Add("alien","Enable ALIEN file access",true); //MUST be true
  }
  virtual ~VAFRailway() {}
  virtual Bool_t LoadAliROOT()
  {
    Bool_t enabPhys = true;
    TString aliVer  = gSystem->Getenv("VafAliRootVersion");
    TString aliPhys = gSystem->Getenv("VafAliPhysicsVersion");
    if (!aliVer.IsNull()) {
      Info("VAFRailway::LoadAliROOT", "Using AliROOT=%s", aliVer.Data());
      if (!aliPhys.IsNull()) {
  Warning("VAFRailway::LoadAliROOT",
    "AliPhysics not loaded, even though version %s was requested",
    aliPhys.Data());
      }
      enabPhys = false;
    }
    else if (aliPhys.IsNull()) {
      Error("VAFRailway::LoadAliROOT", "Neither AliROOT nor AliPhysics "
      "versions specified, giving up");
      return false;
    }
    else
      Info("VAFRailway::LoadAliROOT", "Using AliPhysics=%s", aliPhys.Data());

    fOptions.Set("alien");
    return ProofRailway::LoadAliROOT();
  }        
  virtual const char* AliPhysicsParName() const { return 0; }
  virtual Bool_t CreateAliPhysicsPar() { return true; }
  virtual Bool_t EnableAliPhysics() { return true; }
  virtual const char* AliROOTParName() const
  {
    return "/afs/cern.ch/alice/offline/vaf/AliceVaf.par";
  }
  virtual Bool_t CreateAliROOTPar()
  {
    return true;
  }
  virtual Bool_t PreSetup() 
  {
    if (!gSystem->Getenv("VafPodRemoteEnv")) {
      Printf("\n"
       "=== ERROR:\n"
       "Are you sure you're on alivaf-XXX and did 'vaf-enter'? "
       "'cause I'm not so I have to give up!\n");
      return false;
    }

    fBasePars = false;

    if (!ProofRailway::PreSetup()) return false;

    if (fOptions.Has("nocache")) 
      gProof->SetParameter("PROOF_UseTreeCache", 0);
    return true;
  }
  virtual void GetDataSet(TString& dsName)
  {
    dsName = "Find;";
    dsName.Append(Form("BasePath=%s;", fUrl.GetFile()));
    TString pat = fOptions.Get("pattern");
    Int_t   idx = pat.Index("@");
    if (idx != kNPOS) {
      TString fn = pat(0,idx);
      TString an = pat(idx+1,pat.Length()-idx-1);
      dsName.Append(Form("FileName=%s;",fn.Data()));
      dsName.Append(Form("Anchor=%s;", an.Data()));
    }
    else
      dsName.Append(Form("FileName=%s;",pat.Data()));
    dsName.Append(Form("Tree=/%s;", fUrl.GetAnchor()));
    dsName.Append("Mode=remote;");
      
  }
  virtual Bool_t Connect(const TUrl& url, const TString& opt)
  {
    TUrl tmp(url);
    tmp.SetProtocol("pod");
    return ProofRailway::Connect(tmp, opt);
  }
  virtual const Char_t* UrlHelp() const 
  {
    return "proof://alivaf/<datadir>?[&<options>][#<treename>]";
  }
  virtual const char* Desc() const { return "VAF"; }
};
#endif
//
// EOF
//