galleryUtils Namespace Reference

Classes
class	HandleMaker
	gallery More...
class	EventIterator
class	ConfigurationHelper
class	ConfigurationString
class	ConfigurationClass
class	ServiceRegistryClass
class	startMessageFacility
class	TemporaryFile

Functions
def	makeFileList
def	makeEvent
def	forEach
def	eventLoop
def	findFHiCL
	Infrastructure. More...
def	getTableIfPresent
def	loadConfiguration

Variables
string	__doc__
list	__all__
	SourceCode = cppUtils.SourceCode
	Pass-through. More...
	readHeader = cppUtils.readHeader
tuple	make_getValidHandle = HandleMaker()

Function Documentation

def galleryUtils.eventLoop	(		inputFiles,
			process,
			options = {}
	)

Applies the `process` function to each and every event from the specified
input files, in sequence.

The `inputFiles` list may be a single file, or a list (or any iterable object)
of files, or a `std::vector<std::string>` object.

The `process` callable is executed with two arguments: the number of argument
in the loop, and the event itself. No information on which file the event is
taken from is provided. If a call returns exactly `False`, it is considered
to have failed and an error counter is incremented. Exceptions raised in
`process` are not handled.

The error counter is returned at the end of the execution.

Options:
- 'nEvents': number of events to be processed (does not include skipped ones)
- 'nSkip': number of events from the beginning of the sample to be skipped

Definition at line 233 of file icarusalg/icarusalg/gallery/helpers/python/galleryUtils.py.

 ):
  """
  Applies the `process` function to each and every event from the specified
  input files, in sequence.
  
  The `inputFiles` list may be a single file, or a list (or any iterable object)
  of files, or a `std::vector<std::string>` object.
  
  The `process` callable is executed with two arguments: the number of argument
  in the loop, and the event itself. No information on which file the event is
  taken from is provided. If a call returns exactly `False`, it is considered
  to have failed and an error counter is incremented. Exceptions raised in
  `process` are not handled.
  
  The error counter is returned at the end of the execution.
  
  Options:
  - 'nEvents': number of events to be processed (does not include skipped ones)
  - 'nSkip': number of events from the beginning of the sample to be skipped
  """
  
  # option reading
  nSkip = options.get('nSkip', 0)
  nEvents = options.get('nEvents', None)
  
  # make sure the input file list is in the right format
  if not isinstance(inputFiles, ROOT.vector(ROOT.string)):
    if isinstance(inputFiles, str): inputFiles = [ inputFiles, ]
    inputFiles = makeFileList(*inputFiles)
  # if
  
  event = ROOT.gallery.Event(inputFiles)
  
  # ROOT.gStyle.SetOptStat(0)
  
  iEvent = 0
  nProcessedEvents = 0
  nErrors = 0
  
  iFile = None
  for iEvent, event in enumerate(forEach(event)):
    
    if iFile != event.fileEntry():
      iFile = event.fileEntry()
      print("Opening: '%s'" % inputFiles[iFile])
    # if new file
    
    # event flow control
    if iEvent < nSkip: continue
    if (nEvents is not None) and (nProcessedEvents >= nEvents): break
    nProcessedEvents += 1
    
    ###
    ###
    ###
    res = process(event, iEvent)
    if isinstance(res, bool) and not res: nErrors += 1
    
    ###
    ### all done
    ###
    
  # for
  if nErrors > 0:
    print("Encountered %d/%d errors." % (nErrors, nProcessedEvents),file=sys.stderr)
  return nErrors
# eventLoop()



# this does not really work...
# ROOT.gallery.Event.__iter__ = lambda self: EventIterator(self)