Skip to content
Snippets Groups Projects
Commit 0da80c98 authored by Charles Leggett's avatar Charles Leggett
Browse files

downgrade to AthenaCommon-03-03-21

Former-commit-id: ff4fab5f
parent 1d99cef1
No related branches found
No related tags found
No related merge requests found
...@@ -230,8 +230,6 @@ def dumpMasterSequence(): ...@@ -230,8 +230,6 @@ def dumpMasterSequence():
# otherwise, manually do it... # otherwise, manually do it...
dumpSequence( AthSequencer ("AthMasterSeq"), indent=0 ) dumpSequence( AthSequencer ("AthMasterSeq"), indent=0 )
dumpSequence( AthSequencer ("AthFilterSeq"), indent=1 ) dumpSequence( AthSequencer ("AthFilterSeq"), indent=1 )
dumpSequence( AlgSequence ("AthBeginSeq"), indent=2 )
dumpSequence( AlgSequence ("TopAlg"), indent=2 ) dumpSequence( AlgSequence ("TopAlg"), indent=2 )
dumpSequence( AlgSequence ("AthEndSeq"), indent=2 )
dumpSequence( AthSequencer ("AthOutSeq"), indent=2 ) dumpSequence( AthSequencer ("AthOutSeq"), indent=2 )
dumpSequence( AthSequencer ("AthRegSeq"), indent=2 ) dumpSequence( AthSequencer ("AthRegSeq"), indent=2 )
...@@ -19,9 +19,7 @@ __author__ = 'Wim Lavrijsen (WLavrijsen@lbl.gov)' ...@@ -19,9 +19,7 @@ __author__ = 'Wim Lavrijsen (WLavrijsen@lbl.gov)'
__all__ = [ 'theApp', 'ServiceMgr', 'ToolSvc', 'AuditorSvc', 'theAuditorSvc', __all__ = [ 'theApp', 'ServiceMgr', 'ToolSvc', 'AuditorSvc', 'theAuditorSvc',
'athMasterSeq', 'athMasterSeq',
'athFilterSeq', 'athFilterSeq',
'athBeginSeq',
'athAlgSeq', 'topSequence', 'athAlgSeq', 'topSequence',
'athEndSeq'
'athOutSeq', 'athOutSeq',
'athRegSeq', 'athRegSeq',
] ]
...@@ -250,19 +248,14 @@ class AthAppMgr( AppMgr ): ...@@ -250,19 +248,14 @@ class AthAppMgr( AppMgr ):
pieces : AthMasterSeq, AthFilterSeq, AthAlgSeq, AthOutSeq, AthRegSeq pieces : AthMasterSeq, AthFilterSeq, AthAlgSeq, AthOutSeq, AthRegSeq
""" """
from . import AlgSequence as _as from . import AlgSequence as _as
from AthenaServices.AthenaServicesConf import AthIncFirerAlg as IFA
from GaudiCoreSvc.GaudiCoreSvcConf import IncidentProcAlg as IPA
def _build(): def _build():
Logging.log.debug ("building master sequence...") Logging.log.debug ("building master sequence...")
athMasterSeq = _as.AthSequencer ("AthMasterSeq") athMasterSeq = _as.AthSequencer ("AthMasterSeq")
athFilterSeq = _as.AthSequencer ("AthFilterSeq"); athFilterSeq = _as.AthSequencer ("AthFilterSeq");
athBeginSeq = _as.AthSequencer ("AthBeginSeq")
athAlgSeq = _as.AthSequencer ("AthAlgSeq") athAlgSeq = _as.AthSequencer ("AthAlgSeq")
athEndSeq = _as.AthSequencer ("AthEndSeq")
athOutSeq = _as.AthSequencer ("AthOutSeq") athOutSeq = _as.AthSequencer ("AthOutSeq")
athRegSeq = _as.AthSequencer ("AthRegSeq") athRegSeq = _as.AthSequencer ("AthRegSeq")
athMTSeq = _as.AthSequencer ("AthMTSeq")
# transfer old TopAlg to new AthAlgSeq # transfer old TopAlg to new AthAlgSeq
_top_alg = _as.AlgSequence("TopAlg") _top_alg = _as.AlgSequence("TopAlg")
# first transfer properties # first transfer properties
...@@ -276,28 +269,8 @@ class AthAppMgr( AppMgr ): ...@@ -276,28 +269,8 @@ class AthAppMgr( AppMgr ):
athAlgSeq += c athAlgSeq += c
delattr(_top_alg, c.getName()) delattr(_top_alg, c.getName())
del _top_alg, children del _top_alg, children
#Setup begin and end sequences
# Begin Sequence
# IFA->BeginEvent
# IPA
ifaBeg=IFA("BeginIncFiringAlg")
ifaBeg.Incidents=["BeginEvent"]
ifaBeg.FireSerial=True # we want serial incident to be fired as well
athBeginSeq += ifaBeg
ipa=IPA("IncidentProcAlg1")
athBeginSeq += ipa
# EndSequence
# IFA->EndEvent
# IPA
ifaEnd=IFA("EndIncFiringAlg")
ifaEnd.Incidents=["EndEvent"]
ifaEnd.FireSerial=True # we want serial incident to be fired as well
athEndSeq += ifaEnd
ipa2=IPA("IncidentProcAlg2")
athEndSeq += ipa2
# unroll AthFilterSeq to save some function calls and # unroll AthFilterSeq to save some function calls and
# stack size on the C++ side # stack size on the C++ side
for c in athFilterSeq.getChildren(): for c in athFilterSeq.getChildren():
...@@ -305,16 +278,9 @@ class AthAppMgr( AppMgr ): ...@@ -305,16 +278,9 @@ class AthAppMgr( AppMgr ):
# XXX: should we discard empty sequences ? # XXX: should we discard empty sequences ?
# might save some CPU and memory... # might save some CPU and memory...
athMTSeq+=athBeginSeq athMasterSeq += athAlgSeq
athMTSeq+=athAlgSeq
athMTSeq+=athEndSeq
# athMasterSeq += athBeginSeq
# athMasterSeq += athAlgSeq
# athMasterSeq += athEndSeq
athMasterSeq += athMTSeq
athMasterSeq += athOutSeq athMasterSeq += athOutSeq
athMasterSeq += athRegSeq athMasterSeq += athRegSeq
Logging.log.debug ("building master sequence... [done]") Logging.log.debug ("building master sequence... [done]")
return athMasterSeq return athMasterSeq
# prevent hysteresis effect # prevent hysteresis effect
...@@ -949,12 +915,8 @@ def AuditorSvc(): # backwards compatibility ...@@ -949,12 +915,8 @@ def AuditorSvc(): # backwards compatibility
# | # |
# +-- athFilterSeq # +-- athFilterSeq
# | # |
# +--- athBeginSeq
# |
# +--- athAlgSeq == TopAlg # +--- athAlgSeq == TopAlg
# | # |
# +--- athEndSeq
# |
# +--- athOutSeq # +--- athOutSeq
# | # |
# +--- athRegStreams # +--- athRegStreams
......
...@@ -51,9 +51,7 @@ def _setupAtlasThreadedJob(): ...@@ -51,9 +51,7 @@ def _setupAtlasThreadedJob():
from GaudiHive.GaudiHiveConf import AlgResourcePool from GaudiHive.GaudiHiveConf import AlgResourcePool
arp=AlgResourcePool( OutputLevel = INFO ); svcMgr += AlgResourcePool( OutputLevel = INFO );
arp.TopAlg=["AthMTSeq"] #this should enable control flow
svcMgr += arp
from GaudiHive.GaudiHiveConf import ForwardSchedulerSvc from GaudiHive.GaudiHiveConf import ForwardSchedulerSvc
svcMgr += ForwardSchedulerSvc() svcMgr += ForwardSchedulerSvc()
......
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