+
+//______________________________________________________________________________
+void AliAnalysisManager::RegisterExtraFile(const char *fname)
+{
+// This method is used externally to register output files which are not
+// connected to any output container, so that the manager can properly register,
+// retrieve or merge them when running in distributed mode. The file names are
+// separated by blancs. The method has to be called in MyAnalysisTask::LocalInit().
+ if (fExtraFiles.Length()) fExtraFiles += " ";
+ fExtraFiles += fname;
+}
+
+//______________________________________________________________________________
+Bool_t AliAnalysisManager::GetFileFromWrapper(const char *filename, TList *source)
+{
+// Copy a file from the location specified ina the wrapper with the same name from the source list.
+ char full_path[512];
+ char ch_url[512];
+ TObject *pof = source->FindObject(filename);
+ if (!pof || !pof->InheritsFrom("TProofOutputFile")) {
+ Error("GetFileFromWrapper", "TProofOutputFile object not found in output list for file %s", filename);
+ return kFALSE;
+ }
+ gROOT->ProcessLine(Form("sprintf((char*)0x%lx, \"%%s\", ((TProofOutputFile*)0x%lx)->GetOutputFileName();)", full_path, pof));
+ gROOT->ProcessLine(Form("sprintf((char*)0x%lx, \"%%s\", gProof->GetUrl();)", ch_url));
+ TString clientUrl(ch_url);
+ TString full_path_str(full_path);
+ if (clientUrl.Contains("localhost")){
+ TObjArray* array = full_path_str.Tokenize ( "//" );
+ TObjString *strobj = ( TObjString *)array->At(1);
+ TObjArray* arrayPort = strobj->GetString().Tokenize ( ":" );
+ TObjString *strobjPort = ( TObjString *) arrayPort->At(1);
+ full_path_str.ReplaceAll(strobj->GetString().Data(),"localhost:PORT");
+ full_path_str.ReplaceAll(":PORT",Form(":%s",strobjPort->GetString().Data()));
+ if (fDebug > 1) Info("GetFileFromWrapper","Using tunnel from %s to %s",full_path_str.Data(),filename);
+ delete arrayPort;
+ delete array;
+ }
+ if (fDebug > 1)
+ Info("GetFileFromWrapper","Copying file %s from PROOF scratch space", full_path_str.Data());
+ Bool_t gotit = TFile::Cp(full_path_str.Data(), filename);
+ if (!gotit)
+ Error("GetFileFromWrapper", "Could not get file %s from proof scratch space", filename);
+ return gotit;
+}
+
+//______________________________________________________________________________
+void AliAnalysisManager::GetAnalysisTypeString(TString &type) const
+{
+// Fill analysis type in the provided string.
+ switch (fMode) {
+ case kLocalAnalysis:
+ type = "local";
+ return;
+ case kProofAnalysis:
+ type = "proof";
+ return;
+ case kGridAnalysis:
+ type = "grid";
+ return;
+ case kMixingAnalysis:
+ type = "mix";
+ }
+}
+
+//______________________________________________________________________________
+Bool_t AliAnalysisManager::ValidateOutputFiles() const
+{
+// Validate all output files.
+ TIter next(fOutputs);
+ AliAnalysisDataContainer *output;
+ TDirectory *cdir = gDirectory;
+ TString openedFiles;
+ while ((output=(AliAnalysisDataContainer*)next())) {
+ if (output->IsRegisterDataset()) continue;
+ TString filename = output->GetFileName();
+ if (filename == "default") {
+ if (!fOutputEventHandler) continue;
+ filename = fOutputEventHandler->GetOutputFileName();
+ }
+ // Check if the file is closed
+ if (openedFiles.Contains(filename)) continue;;
+ TFile *file = (TFile*)gROOT->GetListOfFiles()->FindObject(filename);
+ if (file) {
+ Warning("ValidateOutputs", "File %s was not closed. Closing.", filename.Data());
+ file->Close();
+ }
+ file = TFile::Open(filename);
+ if (!file || file->IsZombie() || file->TestBit(TFile::kRecovered)) {
+ Error("ValidateOutputs", "Output file <%s> was not created or invalid", filename.Data());
+ cdir->cd();
+ return kFALSE;
+ }
+ file->Close();
+ openedFiles += filename;
+ openedFiles += " ";
+ }
+ cdir->cd();
+ return kTRUE;
+}