11 filename):
12 '''Common config fragment for setting up
13 ByteStream for DRAW formats'''
14 if os.access(filename,os.F_OK):
15 msg=logging.getLogger('DRAWByteStreamCfg')
16 msg.warning(f"Deleting pre-existing DRAW file {filename}")
17 os.remove(filename)
18
19
20
21 outCA = ComponentAccumulator(
22 CompFactory.AthSequencer(
23 name='AthOutSeq',
24 StopOverride=True))
25
26 bsesoSvc = CompFactory.ByteStreamEventStorageOutputSvc(
27 name="BSEventStorageOutputSvc"+formatName,
28 MaxFileMB=15000,
29 MaxFileNE=15000000,
30 OutputDirectory='./',
31 StreamType='',
32 StreamName='Stream'+formatName,
33 SimpleFileName=filename)
34 outCA.addService(bsesoSvc)
35
36 bsIS = CompFactory.ByteStreamEventStorageInputSvc('ByteStreamInputSvc')
37 outCA.addService(bsIS)
38
39 bsCopyTool = CompFactory.ByteStreamOutputStreamCopyTool(
40 ByteStreamOutputSvc=bsesoSvc,
41 ByteStreamInputSvc=bsIS)
42
43 bsCnvSvc = CompFactory.ByteStreamCnvSvc(
44 ByteStreamOutputSvcList=[bsesoSvc.getName()])
45 outCA.addService(bsCnvSvc)
46
47 outCA.addEventAlgo(CompFactory.AthenaOutputStream(
48 name='BSOutputStreamAlg'+formatName,
49 WritingTool=bsCopyTool,
50 EvtConversionSvc=bsCnvSvc.name,
51 RequireAlgs=[formatName+'Kernel'],
52 ExtraInputs={('xAOD::EventInfo', 'StoreGateSvc+EventInfo')}),
53 domain='IO', primary=True)
54
55 from AthenaServices.MetaDataSvcConfig import MetaDataSvcCfg
56 from IOVDbSvc.IOVDbSvcConfig import IOVDbSvcCfg
57 outCA.merge(IOVDbSvcCfg(flags))
58 outCA.merge(MetaDataSvcCfg(flags,
59 ["IOVDbMetaDataTool", "ByteStreamMetadataTool"]))
60
61 return outCA
1.14.0