// @(#)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