WriteAthenaPool.py

Go to the documentation of this file.

# Copyright (C) 2002-2020 CERN for the benefit of the ATLAS collaboration
 

 

from OutputStreamAthenaPool.CreateOutputStreams import AthenaPoolOutputStream
 

__all__ = [ 'AthenaPoolOutputStream' ]
 
def _configureWriteAthenaPool():
    """ Helper method to configure Athena to write out POOL files """
 
    from AthenaCommon.Logging import logging
    msg = logging.getLogger( 'configureWriteAthenaPool' )
    msg.debug( "Configuring Athena for writing POOL files..." )
 
    # Load the basic services
    import AthenaPoolCnvSvc.AthenaPool  # noqa: F401
 
    from AthenaCommon.AppMgr  import ServiceMgr as svcMgr
    # Switch off splitting by setting default SplitLevel to 0
    svcMgr.AthenaPoolCnvSvc.PoolAttributes += [ "DEFAULT_SPLITLEVEL ='0'" ]
 
    # Set as default the member-wise streaming, ROOT default
    svcMgr.AthenaPoolCnvSvc.PoolAttributes += [ "STREAM_MEMBER_WISE = '1'" ]
 
    # Increase default BasketSize to 32K, ROOT default (but overwritten by POOL)
    svcMgr.AthenaPoolCnvSvc.PoolAttributes += [ "DEFAULT_BUFFERSIZE = '32000'" ]
 
    # Set POOLContainerForm(DataHeaderForm) split level to 0
    svcMgr.AthenaPoolCnvSvc.PoolAttributes += [ "ContainerName = 'TTree=POOLContainerForm(DataHeaderForm)'; CONTAINER_SPLITLEVEL = '0'" ]
 
    svcMgr.AthenaPoolCnvSvc.TopLevelContainerName = ""
    svcMgr.AthenaPoolCnvSvc.SubLevelBranchName = "<type>/<key>"
 
    msg.debug( "Configuring Athena for writing POOL files... [DONE]" )
    return
 

_configureWriteAthenaPool()
 

del _configureWriteAthenaPool