/usr/include/root/TPacketizerUnit.h is in libroot-proof-proofplayer-dev 5.34.30-0ubuntu8.
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 76 77 78 79 80 81 82 83 84 85 | // @(#)root/proofplayer:$Id$
// Author: Long Tran-Thanh 22/07/07
// Revised: G. Ganis, May 2011
/*************************************************************************
* 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_TPacketizerUnit
#define ROOT_TPacketizerUnit
//////////////////////////////////////////////////////////////////////////
// //
// TPacketizerUnit //
// //
// This packetizer generates packets of generic units, representing the //
// number of times an operation cycle has to be repeated by the worker //
// node, e.g. the number of Monte carlo events to be generated. //
// Packets sizes are generated taking into account the performance of //
// worker nodes, based on the time needed to process previous packets, //
// with the goal of having all workers ending at the same time. //
// //
//////////////////////////////////////////////////////////////////////////
#ifndef ROOT_TVirtualPacketizer
#include "TVirtualPacketizer.h"
#endif
#ifndef ROOT_TMap
#include "TMap.h"
#endif
class TMessage;
class TTimer;
class TTree;
class TProofStats;
class TStopwatch;
class TPacketizerUnit : public TVirtualPacketizer {
public: // public because of Sun CC bug
class TSlaveStat;
private:
TList *fPackets; // All processed packets
TMap *fWrkStats; // Worker status, keyed by correspondig TSlave
TList *fWrkExcluded; // List of nodes excluded from distribution
// (submasters with no active workers)
TStopwatch *fStopwatch; // For measuring the start time of each packet
Long64_t fProcessing; // Event being processed
Long64_t fAssigned; // Entries processed or being processed.
Double_t fCalibFrac; // Size of the calibrating packet as fraction of Ntot/Nwrk
Long64_t fNumPerWorker; // Number of cycles per worker, if this option
// is chosen
Bool_t fFixedNum; // Whether we must assign a fixed number of cycles per worker
Long64_t fPacketSeq; // Sequential number of the last packet assigned
TPacketizerUnit();
TPacketizerUnit(const TPacketizerUnit&); // no implementation, will generate
void operator=(const TPacketizerUnit&); // error on accidental usage
public:
TPacketizerUnit(TList *slaves, Long64_t num, TList *input, TProofProgressStatus *st = 0);
virtual ~TPacketizerUnit();
Int_t AssignWork(TDSet * /*dset*/, Long64_t /*first*/, Long64_t num);
TDSetElement *GetNextPacket(TSlave *sl, TMessage *r);
Double_t GetCurrentTime();
Float_t GetCurrentRate(Bool_t &all);
Int_t GetActiveWorkers() { return fWrkStats->GetSize(); }
Int_t AddWorkers(TList *workers);
ClassDef(TPacketizerUnit,0) //Generate work packets for parallel processing
};
#endif
|