/usr/include/root/TPacketizerFile.h is in libroot-proof-proofplayer-dev 5.34.14-1build1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 | // @(#)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. //
// //
//////////////////////////////////////////////////////////////////////////
#ifndef ROOT_TVirtualPacketizer
#include "TVirtualPacketizer.h"
#endif
#ifndef ROOT_TMap
#include "TMap.h"
#endif
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);
virtual ~TPacketizerFile();
TDSetElement *GetNextPacket(TSlave *wrk, TMessage *r);
Double_t GetCurrentTime();
Float_t GetCurrentRate(Bool_t &all);
Int_t GetActiveWorkers() { return -1; }
ClassDef(TPacketizerFile,0) //Generate work packets for parallel processing
};
//-------------------------------------------------------------------------------
#endif
|