athenaEF_tdaq_infra Namespace Reference

Classes
class	Infrastructure

Functions
	parse_args ()
	setup_tdaq_and_reexec (args)
	main ()

Variables
	stream
	stdout
	level
	format
	log = logging.getLogger('athenaEF_infra')
str	CM_SETUP = '/cvmfs/atlas.cern.ch/repo/sw/tdaq/tools/cmake_tdaq/bin/cm_setup.sh'
str	DEFAULT_TDAQ_RELEASE = 'tdaq-14-00-00'
str	STAGE2_ENV = 'ATHENAEF_INFRA_STAGE2'
str	READY_MARKER = 'ATHENAEF_INFRA_READY'

Function Documentation

main()

main

(

)

Definition at line 264 of file athenaEF_tdaq_infra.py.

def main():
    args = parse_args()
 
    if STAGE2_ENV not in os.environ:
        setup_tdaq_and_reexec(args)   # does not return
 
    os.makedirs(args.log_dir, exist_ok=True)
 
    infra = Infrastructure(args)
    infra.start()
    print(READY_MARKER, flush=True)
 
    while infra.check_alive():
        time.sleep(2)
 
    infra.stop()
    return 1
 
 

parse_args()

parse_args

(

)

Definition at line 60 of file athenaEF_tdaq_infra.py.

def parse_args():
    parser = argparse.ArgumentParser(
        description='Start a private TDAQ infrastructure (IPC/IS/webproxy) for athenaEF online-monitoring tests')
    parser.add_argument('--partition', metavar='NAME', required=True,
                        help='partition name (TDAQ_PARTITION)')
    parser.add_argument('--webdaq-port', metavar='PORT', type=int, required=True,
                        help='port the webproxy listens on')
    parser.add_argument('--oh-server', metavar='NAME', required=True,
                        help='name of the OH IS server (TDAQ_OH_SERVER)')
    parser.add_argument('--run-number', metavar='N', type=int, required=True,
                        help='run number, used to name the output file')
    parser.add_argument('--schema', metavar='FILE', action='append', default=[],
                        help='IS schema file (absolute path) to load into the ISRepository, '
                             'repeatable. If none is given rdb_server is not started')
    parser.add_argument('--log-dir', metavar='DIR', default='.',
                        help='directory for infrastructure log files (default: cwd)')
    parser.add_argument('--tdaq-release', metavar='REL', default=DEFAULT_TDAQ_RELEASE,
                        help='TDAQ release to source via cm_setup.sh (default: %(default)s)')
    return parser.parse_args()
 
 

setup_tdaq_and_reexec()

setup_tdaq_and_reexec

(

args

)

re-exec this script through bash after sourcing the TDAQ release.

Definition at line 81 of file athenaEF_tdaq_infra.py.

def setup_tdaq_and_reexec(args):
    """re-exec this script through bash after sourcing the TDAQ release."""
    if not os.path.exists(CM_SETUP):
        log.error('TDAQ release setup not found at %s', CM_SETUP)
        sys.exit(1)
 
    log.info('Sourcing TDAQ release %s via %s', args.tdaq_release, CM_SETUP)
    os.environ[STAGE2_ENV] = '1'
    script = os.path.abspath(__file__)
    cmd = (f'source {CM_SETUP} {args.tdaq_release} || exit 66; '
           f'exec python3 "{script}" "$@"')
    os.execv('/bin/bash', ['/bin/bash', '-c', cmd, script] + sys.argv[1:])
 
 

Variable Documentation

CM_SETUP

str athenaEF_tdaq_infra.CM_SETUP = '/cvmfs/atlas.cern.ch/repo/sw/tdaq/tools/cmake_tdaq/bin/cm_setup.sh'

Definition at line 50 of file athenaEF_tdaq_infra.py.

DEFAULT_TDAQ_RELEASE

str athenaEF_tdaq_infra.DEFAULT_TDAQ_RELEASE = 'tdaq-14-00-00'

Definition at line 51 of file athenaEF_tdaq_infra.py.

format

athenaEF_tdaq_infra.format

Definition at line 46 of file athenaEF_tdaq_infra.py.

level

athenaEF_tdaq_infra.level

Definition at line 45 of file athenaEF_tdaq_infra.py.

log

athenaEF_tdaq_infra.log = logging.getLogger('athenaEF_infra')

Definition at line 47 of file athenaEF_tdaq_infra.py.

READY_MARKER

str athenaEF_tdaq_infra.READY_MARKER = 'ATHENAEF_INFRA_READY'

Definition at line 57 of file athenaEF_tdaq_infra.py.

STAGE2_ENV

str athenaEF_tdaq_infra.STAGE2_ENV = 'ATHENAEF_INFRA_STAGE2'

Definition at line 54 of file athenaEF_tdaq_infra.py.

stdout

athenaEF_tdaq_infra.stdout

Definition at line 45 of file athenaEF_tdaq_infra.py.

stream

athenaEF_tdaq_infra.stream

Definition at line 45 of file athenaEF_tdaq_infra.py.