Replace Dispersion by GroupName

Reconstruction/RecExample/RecExOnline/share/RecExOnline_Partition_Online_ID.py

@@ -73,7 +73,7 @@ if ( publishName == "ID-AthenaMon-Noise" ):
     streamType        = 'monitoring'
     streamName        = 'IDMonitoring'
     streamLogic       = 'Or'# This should be taken out when we have a proper IDMonitoring stream
-    dispersion        = False
+    groupName        = ''
     lvl1Logic         = 'Or' if partitionName == "ATLAS" else 'Ignore' # cgrefe 08.09.15: see if the Or works in beam 
     lvl1Name          = 'L1_RD0_EMPTY'
     doIdGlobalErrorMon = True
@@ -117,7 +117,7 @@ elif ( publishName == "ID-Test-Application" ):
 elif ( publishName == 'ID-AthenaMon-TRTBeam' ):
     keyname      = 'dcm'
     keycount     = 255           # there are only around 100 SFIs - connect to all of them
-    dispersion   = False         # process the same events as other monitoring jobs with the same event selection
+    groupName   = ''         # process the same events as other monitoring jobs with the same event selection
     streamType   = 'monitoring'
     streamLogic  = 'Or'
     streamName   = 'IDMonitoring'# avoid PixelNoise and SCTNoise, because those streams contain mostly partial events without TRT data
@@ -129,7 +129,7 @@ elif ( publishName == 'ID-AthenaMon-TRTBeam' ):
 elif ( publishName == 'ID-AthenaMon-TRTBeam-Test' ):
     keyname      = 'dcm'
     keycount     = 255           # there are only around 100 SFIs - connect to all of them
-    dispersion   = False         # process the same events as other monitoring jobs with the same event selection
+    groupName   = ''         # process the same events as other monitoring jobs with the same event selection
     streamType   = 'monitoring'
     streamLogic  = 'Or'
     streamName   = 'IDMonitoring'# avoid PixelNoise and SCTNoise, because those streams contain mostly partial events without TRT data

Reconstruction/RecExample/RecExOnline/share/RecExOnline_Partition_Online_TRT.py

@@ -79,7 +79,7 @@ if False:                       # it would be nice if this could be set automati
 if (jobName == 'TRT-Monitoring-Noise'):
     keyname     = 'SFI'         # take the events straight from L2 - the IDMonitoring stream does not go through the Event Filter, anyway
     keycount    = 255           # there are only around 100 SFIs - connect to all of them
-    dispersion  = False         # process the same events as other monitoring jobs with the same event selection
+    groupName  = ''         # process the same events as other monitoring jobs with the same event selection
     streamLogic = 'Or'
     streamName  = 'IDMonitoring' # avoid PixelNoise and SCTNoise, because those streams contain mostly partial events without TRT data
     lvl1Logic   = 'Or'
@@ -89,7 +89,7 @@ if (jobName == 'TRT-Monitoring-Noise'):
 if (jobName == 'TRT-Monitoring-Beam'):
     keyname     = 'SFI'         # take the events straight from L2 - the IDMonitoring stream does not go through the Event Filter, anyway
     keycount    = 255           # there are only around 100 SFIs - connect to all of them
-    dispersion  = False         # process the same events as other monitoring jobs with the same event selection
+    groupName  = ''         # process the same events as other monitoring jobs with the same event selection
     streamLogic = 'Or'
     streamName  = 'IDMonitoring' # avoid PixelNoise and SCTNoise, because those streams contain mostly partial events without TRT data
     lvl1Logic   = 'Or'

Reconstruction/RecExample/RecExOnline/share/RecExOnline_emonsvc.py

@@ -43,8 +43,8 @@ if ('updateperiod' not in dir()):
 if ('timeout' not in dir()):
     timeout = 240000
 
-if ('dispersion' not in dir()):
-    dispersion = True
+if ('groupName' not in dir()):
+    groupName = 'RecExOnline'
 
 if ('isserverName' not in dir()):
     isserverName = 'Histogramming'
@@ -187,7 +187,15 @@ else:
 # For offline athena tasks mainly.
 # #################################################
 ByteStreamEmonInputSvc.ExitOnPartitionShutdown = False
-ByteStreamEmonInputSvc.Dispersion = dispersion
+
+# #################################################
+# Set groupName to "RecExOnline" by default so that 
+# each process belonging to the "RecExOnline" group 
+# gets a different set of events.
+# Set groupName to empty to allow other process get 
+# the same events.
+# #################################################
+ByteStreamEmonInputSvc.GroupName = groupName
 
 ByteStreamCnvSvc = Service('ByteStreamCnvSvc')
 theApp.ExtSvc += [ 'ByteStreamCnvSvc' ]

graphics/EventDisplaysOnline/share/ByteStreamInput_jobOptions.py

@@ -80,11 +80,11 @@ ByteStreamEmonInputSvc.KeyCount = Nodes
 # ByteStreamEmonInputSvc.Frequency = 5
 
 # #################################
-# Set dispersion flag to false (so other can sample the same event
+# Set GroupName to empty (so others can sample the same event)
 # #################################
-if not 'Dispersion' in dir():
-  Dispersion=False
-ByteStreamEmonInputSvc.Dispersion=Dispersion
+if not 'GroupName' in dir():
+  GroupName=""
+ByteStreamEmonInputSvc.GroupName=GroupName
 
 # #################################
 # Set timeout (in ms?)