TPacketizerFile.h

Go to the documentation of this file.

// @(#)root/proofplayer:$Id$
// Author: G. Ganis 2009
 
/*************************************************************************
 * Copyright (C) 1995-2002, Rene Brun and Fons Rademakers.               *
 * All rights reserved.                                                  *
 *                                                                       *
 * For the licensing terms see $ROOTSYS/LICENSE.                         *
 * For the list of contributors see $ROOTSYS/README/CREDITS.             *
 *************************************************************************/
 
#ifndef ROOT_TPacketizerFile
#define ROOT_TPacketizerFile
 
//////////////////////////////////////////////////////////////////////////
//                                                                      //
// TPacketizerFile                                                      //
//                                                                      //
// This packetizer generates packets which conatin a single file path   //
// to be used in process. Used for tasks generating files, like in      //
// PROOF bench.                                                         //
//                                                                      //
//////////////////////////////////////////////////////////////////////////
 
#include "TVirtualPacketizer.h"
#include "TMap.h"
 
 
class TMessage;
class TList;
class TStopwatch;
 
class TPacketizerFile : public TVirtualPacketizer {
 
public:              // This is always needed
   class TSlaveStat;
   class TIterObj;
 
private:
   TMap       *fFiles;           // Files to be produced/processed per node
   TList      *fNotAssigned;     // List of files not assigned to a specific node
   TList      *fIters;           // Iterators on the file lists per node
   Long64_t    fAssigned;        // No.files processed or being processed.
   Bool_t      fProcNotAssigned; // Whether to process files not asdigned to a worker
   Bool_t      fAddFileInfo;     // Whether to add the TFileInfo object in the packet
 
   TStopwatch *fStopwatch;       // For measuring the start time of each packet
 
   TPacketizerFile();
   // : fFiles(0), fNotAssigned(0), fIters(0), fAssigned(0),
   //                    fProcNotAssigned(kTRUE), fAddFileInfo(kFALSE), fStopwatch(0) { }
   TPacketizerFile(const TPacketizerFile&);     // no implementation, will generate
   void operator=(const TPacketizerFile&);  // error on accidental usage
 
public:
   TPacketizerFile(TList *workers, Long64_t, TList *input, TProofProgressStatus *st = 0);
   ~TPacketizerFile() override;
 
   TDSetElement *GetNextPacket(TSlave *wrk, TMessage *r) override;
 
   Double_t      GetCurrentTime();
 
   Float_t       GetCurrentRate(Bool_t &all) override;
   Int_t         GetActiveWorkers() override { return -1; }
 
   ClassDefOverride(TPacketizerFile,0)  //Generate work packets for parallel processing
};
 
//-------------------------------------------------------------------------------
 
#endif