Functions
def	makeJobBlock (mylist, evtn)

Variables
	args

	block

string	comma = ","

string	commandline = " ".join(copyargs)

string	commax = ","

	comment1RE = re.compile (r'^#.+$')

list	commentLines = []

	copyargs = sys.argv[:]

	default

	dest

list	eventsFiles = []

	evtPerJob = int(math.ceil(float(ntotal)/NBLOCKS))

	fileLineRE = re.compile (r'^.\'(.)\'.+# (\d).$')

	fin = open(INFILE, "r")

	fout = open(OUTFILE, mode="w")

	help

	INFILE = sys.argv[2]

list	jobsBlocks = []

	lines = fin.readlines()

	match = comment1RE.match(line)

	NBLOCKS = int(sys.argv[1])

	nn

int	ntotal = 0

	options

	OUTFILE = sys.argv[3]

	parser = optparse.OptionParser(usage)
	To parse commandline args. More...

	prog = sys.argv[0]

	reverse

list	temp = eventsFiles

int	tt = 0

	type

string	usage = './%(prog)s NBLOCKS INFILE OUTFILE [options]\n'+\

Function Documentation

◆ makeJobBlock()

def groupFilesInBlocks.makeJobBlock	(	mylist,
		evtn
	)

Definition at line 46 of file groupFilesInBlocks.py.

References print(), and FastTimerService_cff.range.

 def makeJobBlock(mylist, evtn):
     n = mylist[0][0]
     block = [mylist[0]]
     choosen = [0]
     while n<evtn:
     #print "n,evtn=",n,evtn
     # find the biggest unused #evt that would give n<evtn
         for i in range(len(mylist)):
             # get last not choosen i
             last_i=len(mylist)-1
             while last_i in choosen: last_i += -1
             if i==last_i:
         #print i,"last element reached"
                 n += mylist[i][0]
                 #print "   new last append: ",i, mylist[i][0], n
                 block.append(mylist[i])
                 choosen.append(i)
                 break
             if i in choosen:
                 #print i,"  in choosen, continue..."
                 continue
             if n+mylist[i][0]<evtn:
                 n += mylist[i][0]
                 #print "   new append: ",i, mylist[i][0], n
                 block.append(mylist[i])
                 choosen.append(i)
                 break
         if len(choosen)==len(mylist):
             #print " got everything"
             break
     # pick up unused elements
     newlist = []
     for i in range(len(mylist)):
         if not i in choosen:
             newlist.append(mylist[i])
     print("done makeJobBlock n =",n," len =",len(block))
     return block, newlist, n
 
 
 

Variable Documentation

◆ args

groupFilesInBlocks.args

Definition at line 35 of file groupFilesInBlocks.py.

◆ block

groupFilesInBlocks.block

Definition at line 150 of file groupFilesInBlocks.py.

◆ comma

string groupFilesInBlocks.comma = ","

Definition at line 175 of file groupFilesInBlocks.py.

◆ commandline

string groupFilesInBlocks.commandline = " ".join(copyargs)

Definition at line 14 of file groupFilesInBlocks.py.

◆ commax

string groupFilesInBlocks.commax = ","

Definition at line 172 of file groupFilesInBlocks.py.

◆ comment1RE

groupFilesInBlocks.comment1RE = re.compile (r'^#.+$')

Definition at line 86 of file groupFilesInBlocks.py.

◆ commentLines

list groupFilesInBlocks.commentLines = []

Definition at line 101 of file groupFilesInBlocks.py.

◆ copyargs

groupFilesInBlocks.copyargs = sys.argv[:]

Definition at line 8 of file groupFilesInBlocks.py.

◆ default

groupFilesInBlocks.default

Definition at line 32 of file groupFilesInBlocks.py.

◆ dest

groupFilesInBlocks.dest

Definition at line 33 of file groupFilesInBlocks.py.

◆ eventsFiles

list groupFilesInBlocks.eventsFiles = []

Definition at line 99 of file groupFilesInBlocks.py.

◆ evtPerJob

groupFilesInBlocks.evtPerJob = int(math.ceil(float(ntotal)/NBLOCKS))

Definition at line 134 of file groupFilesInBlocks.py.

◆ fileLineRE

groupFilesInBlocks.fileLineRE = re.compile (r'^.*\'(.*)\'.+# (\d*).*$')

Definition at line 87 of file groupFilesInBlocks.py.

◆ fin

groupFilesInBlocks.fin = open(INFILE, "r")

Definition at line 94 of file groupFilesInBlocks.py.

Referenced by addFile(), HIPplots.CheckFileExistence(), convertFile(), dumpFiles(), popcon::EcalLaser_weekly_Linearization_Check.getNewObjects(), ElectronEnergyCalibrator.init(), dqmservices::DQMProtobufReader.load(), main(), MuonGeometryArrange.MuonGeometryArrange(), ALIFileIn.openNewFile(), RPCPatternsParser.parse(), CommandLine.parse_file(), pos::PixelFEDTestDAC.PixelFEDTestDAC(), CSCChamberTimeCorrectionsValues.prefill(), CSCChipSpeedCorrectionDBConditions.prefillDBChipSpeedCorrection(), CSCGasGainCorrectionDBConditions.prefillDBGasGainCorrection(), AsciiNeutronReader.read_nhits(), CSCGasCollisions.readCollisionTable(), ErrorCorrelationMgr.readFromReportFile(), AsciiNeutronReader.readNextEvent(), trklet::TripletEngine.readTables(), trklet::TrackletEngineDisplaced.readTables(), AsciiNeutronReader.resetStreampos(), SiPixelEDAClient.SiPixelEDAClient(), TPNCor.TPNCor(), TrackerGeometryCompare.TrackerGeometryCompare(), and TrackingAnalyser.TrackingAnalyser().

◆ fout

groupFilesInBlocks.fout = open(OUTFILE, mode="w")

Definition at line 162 of file groupFilesInBlocks.py.

Referenced by SiStripDetVOffPrinter.analyze(), BeamSpotRcdPrinter.analyze(), FastSiPixelFEDChannelContainerFromQuality.analyze(), trklet::TrackletCalculatorBase.barrelSeeding(), CMSG4CheckOverlap.CMSG4CheckOverlap(), PrepareDMRTrends.compileDMRTrends(), trklet::TrackletCalculatorDisplaced.DDLSeeding(), trklet::TrackletCalculatorBase.diskSeeding(), ALIUtils.dumpDimensions(), FittedEntriesManager.dumpEntriesSubstraction(), PrintGeomInfoAction.dumpInFile(), DTTrigGeom.dumpLUT(), DTConfigManager.dumpLUTParam(), RunManagerMTWorker.DumpMagneticField(), EcalTPGLinearizationConstXMLTranslator.dumpXML(), trklet::MatchEngine.execute(), trklet::TripletEngine.execute(), trklet::TrackletEngineDisplaced.execute(), trklet::PurgeDuplicate.execute(), trklet::FitTrack.execute(), HIPplots.extractAlignableChiSquare(), HIPplots.extractAlignParams(), HIPplots.extractAlignShifts(), HIPplots.extractSurveyResiduals(), popcon::EcalSRPHandler.getNewObjects(), trklet::TrackletCalculatorDisplaced.LLDSeeding(), trklet::TrackletCalculatorDisplaced.LLLSeeding(), FittedEntriesManager.MakeHistos(), PlotCompareUtility.makeHTML(), CMSG4CheckOverlap.makeReportForGeometry(), CMSG4CheckOverlap.makeReportForMaterials(), CMSG4CheckOverlap.makeReportForOverlaps(), PreparePVTrends.multiRunPVValidation(), MatrixMeschach.ostrDump(), trklet::TrackletCalculatorBase.overlapSeeding(), EcalTPGTowerStatusXMLTranslator.plot(), EcalDAQTowerStatusXMLTranslator.plot(), EcalDCSTowerStatusXMLTranslator.plot(), popcon::EcalSRPHandler.PrintPayload(), ZeeCalibration.printStatistics(), popcon::EcalPedestalsHandler.readPedestalMC(), popcon::EcalPedestalsHandler.readPedestalTimestamp(), popcon::EcalPedestalsHandler.readPedestalTree(), CMSG4RegionReporter.ReportRegions(), TestHistoMgr.save(), cond::persistency::Logger.saveOnFile(), JME::JetResolutionObject.saveToFile(), and trklet::TripletEngine.writeTables().

◆ help

groupFilesInBlocks.help

Definition at line 30 of file groupFilesInBlocks.py.

◆ INFILE

groupFilesInBlocks.INFILE = sys.argv[2]

Definition at line 41 of file groupFilesInBlocks.py.

◆ jobsBlocks

list groupFilesInBlocks.jobsBlocks = []

Definition at line 141 of file groupFilesInBlocks.py.

◆ lines

groupFilesInBlocks.lines = fin.readlines()

Definition at line 95 of file groupFilesInBlocks.py.

Referenced by HcalChannelIterator.addListFromLmapAscii(), FWMuonDetailView.addSceneInfo(), RivetAnalyzer.beginRun(), HTXSRivetProducer.beginRun(), FWTrackResidualDetailView.build(), FWConversionProxyBuilder.buildViewType(), AlignmentPayloadInfo< PayloadType >.fill(), templateHelper::SiPixelTitles_Display< PayloadType, StoreType, TransientType >.fill(), lhef.fillLines(), DTTFFEDSim.fillRawData(), GenWeightsTableProducer.globalBeginRun(), DD4hep_ListGroups.overlayEtaReferences(), ListGroups.overlayEtaReferences(), DBoxMetadataHelper::DBMetaDataPlotDisplay.plotDiffWithMetadata(), DBoxMetadataHelper::DBMetaDataPlotDisplay.plotMetaDatas(), DTuROSRawToDigi.process(), DTTFFEDReader.process(), DTuROSDigiToRaw.process(), DD4hep_ListGroups.produceAndSaveSummaryPlot(), ListGroups.produceAndSaveSummaryPlot(), gen::Pythia6Service.Pythia6Service(), LMap::impl.read(), HcalEmap.read_map(), EMap.read_map(), DTuROSRawToDigi.readline(), L1TTwinMuxRawToDigi.readline(), fwlite::Scanner< Collection >.setMaxLinesToPrint(), gen::Pythia6Service.setSLHAFromHeader(), Trend.Trend(), L1GtVmeWriterCore.writeVME(), and Trend.~Trend().

◆ match

groupFilesInBlocks.match = comment1RE.match(line)

Definition at line 107 of file groupFilesInBlocks.py.

◆ NBLOCKS

groupFilesInBlocks.NBLOCKS = int(sys.argv[1])

Definition at line 40 of file groupFilesInBlocks.py.

◆ nn

groupFilesInBlocks.nn

◆ ntotal

int groupFilesInBlocks.ntotal = 0

Definition at line 100 of file groupFilesInBlocks.py.

Referenced by GenXSecAnalyzer.compute(), PrintMTDSens.dumpTouch(), lhef::LHERunInfo.statistics(), PrintMTDSens.update(), and lhef::LHERunInfo.xsec().

◆ options

groupFilesInBlocks.options

Definition at line 35 of file groupFilesInBlocks.py.

◆ OUTFILE

groupFilesInBlocks.OUTFILE = sys.argv[3]

Definition at line 42 of file groupFilesInBlocks.py.

◆ parser

groupFilesInBlocks.parser = optparse.OptionParser(usage)

To parse commandline args.

Definition at line 27 of file groupFilesInBlocks.py.

◆ prog

groupFilesInBlocks.prog = sys.argv[0]

Definition at line 16 of file groupFilesInBlocks.py.

◆ reverse

groupFilesInBlocks.reverse

Definition at line 131 of file groupFilesInBlocks.py.

Referenced by DTMeantimerPatternReco.addHits(), TTUTrackingAlg.alignTracks(), L1RCTTestAnalyzer.analyze(), SegmentToTrackAssociator.associate(), DTTracoChip.bestCand(), SiStripBaseCondObjDQM.bookSummaryProfileMEs(), GlobalTrajectoryBuilderBase.build(), CSCSegAlgoTC.buildSegments(), CSCSegAlgoDF.buildSegments(), CSCSegAlgoSK.buildSegments(), CSCSegAlgoRU.buildSegments(), DirectMuonNavigation.compatibleEndcapLayers(), DirectTrackerNavigation.compatibleLayers(), DirectMuonNavigation.compatibleLayers(), MuonForwardNavigableLayer.compatibleLayers(), MuonBarrelNavigableLayer.compatibleLayers(), APVShot.computeShot(), CosmicMuonTrajectoryBuilder.estimateDirection(), StandAloneMuonFilter.findBestMeasurements(), CosmicMuonTrajectoryBuilder.flipTrajectory(), TrackTransformerForCosmicMuons.getTransientRecHits(), trklet.hexFormat(), JetPartonMatching.matchingPtOrderedMinDist(), TrackMerger.merge(), l1ct::L2EgSorterEmulator.merge_boards(), l1ct::PFTkEGSorterBarrelEmulator.merge_regions(), PatternGenerator.modifyClassProb(), MuonForwardNavigableLayer.nextLayers(), MuonBarrelNavigableLayer.nextLayers(), edm::SubProcess.processAsync(), edm::EventProcessor.processEventAsyncImpl(), edm::GlobalSchedule.processOneGlobalAsync(), TSGForOIDNN.produce(), TrackExtenderWithMTDT< TrackCollection >.produce(), reco::modules::TrackerTrackHitFilter.produceFromTrajectory(), DualBzeroTrajectoryFactory.referenceStateAndRecHits(), DualTrajectoryFactory.referenceStateAndRecHits(), EcalBaseNumber.reverse(), edm::OwnVector< TrackingRegion >.reverse(), Trajectory.reverse(), l1ct::PFTkEGSorterEmulator.run(), NuclearInteractionFinder.run(), CRackTrajectoryBuilder.run(), GlobalMuonRefitter.selectMuonHits(), l1tp2::CaloCrystalCluster.setCrystalPtInfo(), CSCSegAlgoShowering.showerSeg(), StandAloneMuonRefitter.singleRefit(), EmbeddingHepMCFilter.sort_by_convention(), GlobalCosmicMuonTrajectoryBuilder.sortHits(), CosmicMuonSmoother.sortHitsAlongMom(), MTDDetLayerGeometry.sortLayers(), MuonDetLayerGeometry.sortLayers(), tmtt::KalmanState.stubs(), CosmicMuonTrajectoryBuilder.trajectories(), GlobalCosmicMuonTrajectoryBuilder.trajectories(), TrackTransformerForCosmicMuons.transform(), TrackTransformer.transform(), GlobalMuonRefitter.transform(), and TrackExtenderWithMTDT< TrackCollection >.tryETLLayers().

◆ temp

groupFilesInBlocks.temp = eventsFiles

Definition at line 142 of file groupFilesInBlocks.py.

◆ tt

int groupFilesInBlocks.tt = 0

Definition at line 144 of file groupFilesInBlocks.py.

◆ type

groupFilesInBlocks.type

Definition at line 31 of file groupFilesInBlocks.py.

◆ usage

string groupFilesInBlocks.usage = './%(prog)s NBLOCKS INFILE OUTFILE [options]\n'+\

Definition at line 18 of file groupFilesInBlocks.py.

Functions

Variables