personalPlayback.Playback Class Reference

Inheritance diagram for personalPlayback.Playback:

Public Member Functions
def	discover_files
def	do_create_lumi
def	do_exec
def	do_init
Public Member Functions inherited from personalPlayback.Applet
def	__init__
def	do_exec
def	do_init
def	log
def	write

Public Attributes
	global_file
	input
	lumi_backlog
	lumi_backlog_size
	lumi_found
	lumi_order
	next_lumi_index
	output
	ramdisk
	run
Public Attributes inherited from personalPlayback.Applet
	control_fp
	kwargs
	name
	opts

Static Public Attributes
tuple	re_pattern = re.compile(r'run([0-9]+)_ls([0-9]+)_stream([A-Za-z0-9]+)_([A-Za-z0-9_-]+)\.jsn')

Additional Inherited Members
Static Public Member Functions inherited from personalPlayback.Applet
def	read

Detailed Description

Definition at line 63 of file personalPlayback.py.

Member Function Documentation

def personalPlayback.Playback.discover_files

(

self

)

Definition at line 66 of file personalPlayback.py.

    def discover_files(self):
        self.lumi_found = {}

        files_found = set()
        streams_found = set()
        run_found = None
        for f in os.listdir(self.input):
            r = self.re_pattern.match(f)
            if r:
                run, lumi, stream, stream_source = r.groups()
                run, lumi = int(run), int(lumi)

                if run_found is None:
                    run_found = run
                elif run_found != run:
                    raise Exception("Files from multiple runs are not (yet) supported for as playback input.")

                lumi_dct = self.lumi_found.setdefault(lumi, { 'streams': {} })
                lumi_dct["streams"][stream] = (f, stream_source)
                files_found.add(f)
                streams_found.add(stream)

        if run_found is None:
            raise Exception("Playback files not found.")

        if self.run < 0:
            self.run = run_found

        self.log.info("Found run %s, will map output to run %s", run_found, self.run)
        self.log.info("Found %d lumisections with %d files", len(self.lumi_found), len(files_found))
        self.log.info("Found %d streams: %s", len(streams_found), list(streams_found))

        self.lumi_order = list(self.lumi_found.keys())
        self.lumi_order.sort()
        self.log.info("Lumi order: %s", str(self.lumi_order))