Skip to content
Snippets Groups Projects
Commit 1509682a authored by Vakhtang Tsulaia's avatar Vakhtang Tsulaia Committed by Graeme Stewart
Browse files

Introducing EventOrders configuration flags (AthenaMP-01-04-04-01)

parent a2087954
No related branches found
No related tags found
No related merge requests found
......@@ -109,6 +109,20 @@ class UseTokenExtractor(JobProperty):
allowedTypes = ['bool']
StoredValue = False
class ReadEventOrders(JobProperty):
""" Flag for reading event orders (Shared Queue) from an ASCII file for reproducibility
"""
statusOn = True
allowedTypes = ['bool']
StoredValue = False
class EventOrdersFile(JobProperty):
""" Name of the file for storing/reading event orders (Shared Queue)
"""
statusOn = True
allowedTypes = ['str']
StoredValue = 'athenamp_eventorders.txt'
# Defines the container for the performance monitoring flags
class AthenaMPFlags(JobPropertyContainer):
""" The global AthenaMP job property container.
......@@ -134,6 +148,8 @@ list_jobproperties = [
EvtRangeScattererCaching,
ChunkSize,
UseTokenExtractor,
ReadEventOrders,
EventOrdersFile,
]
for i in list_jobproperties:
......
......@@ -71,17 +71,19 @@ class MpEvtLoopMgr(AthMpEvtLoopMgr):
if (self.nThreads >= 1):
from AthenaMPTools.AthenaMPToolsConf import SharedHiveEvtQueueConsumer
self.Tools += [ SharedHiveEvtQueueConsumer(UseSharedReader=False,
IsPileup=pileup,
IsRoundRobin=(strategy=='RoundRobin'),
EventsBeforeFork=events_before_fork,
Debug=debug_worker) ]
IsPileup=pileup,
IsRoundRobin=(strategy=='RoundRobin'),
EventsBeforeFork=events_before_fork,
Debug=debug_worker) ]
else:
from AthenaMPTools.AthenaMPToolsConf import SharedEvtQueueConsumer
self.Tools += [ SharedEvtQueueConsumer(UseSharedReader=False,
IsPileup=pileup,
IsRoundRobin=(strategy=='RoundRobin'),
EventsBeforeFork=events_before_fork,
Debug=debug_worker) ]
IsPileup=pileup,
IsRoundRobin=(strategy=='RoundRobin'),
ReadEventOrders=jp.AthenaMPFlags.ReadEventOrders(),
EventOrdersFile=jp.AthenaMPFlags.EventOrdersFile(),
EventsBeforeFork=events_before_fork,
Debug=debug_worker) ]
# Enable seeking
setupEvtSelForSeekOps()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment