Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Modules in SubProcesses are run concurrently on global begin transitions
Extended the concurrent running of modules on global begin transitions to SubProcesses. Child SubProcesses are also run concurrently.
- Loading branch information
Showing
5 changed files
with
384 additions
and
209 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,112 @@ | ||
| #ifndef FWCore_Framework_globalTransitionAsync_h | ||
| #define FWCore_Framework_globalTransitionAsync_h | ||
| // -*- C++ -*- | ||
| // | ||
| // Package: FWCore/Framework | ||
| // Function: globalTransitionAsync | ||
| // | ||
| /**\function globalTransitionAsync globalTransitionAsync.h "globalTransitionAsync.h" | ||
| Description: Helper functions for handling asynchronous global transitions | ||
| Usage: | ||
| <usage> | ||
| */ | ||
| // | ||
| // Original Author: Chris Jones | ||
| // Created: Tue, 06 Sep 2016 16:04:26 GMT | ||
| // | ||
|
|
||
| // system include files | ||
| #include "FWCore/Framework/interface/Schedule.h" | ||
| #include "FWCore/Framework/interface/SubProcess.h" | ||
| #include "FWCore/Concurrency/interface/WaitingTask.h" | ||
| #include "FWCore/Concurrency/interface/WaitingTaskHolder.h" | ||
|
|
||
| // user include files | ||
|
|
||
| // forward declarations | ||
|
|
||
| namespace edm { | ||
| class IOVSyncValue; | ||
| class EventSetup; | ||
| class LuminosityBlockPrincipal; | ||
| class RunPrincipal; | ||
|
|
||
| //This is code in common between beginStreamRun and beginGlobalLuminosityBlock | ||
| inline void subProcessDoGlobalBeginTransitionAsync(WaitingTaskHolder iHolder,SubProcess& iSubProcess, LuminosityBlockPrincipal& iPrincipal, IOVSyncValue const& iTS) { | ||
| iSubProcess.doBeginLuminosityBlockAsync(std::move(iHolder),iPrincipal, iTS); | ||
| } | ||
|
|
||
| inline void subProcessDoGlobalBeginTransitionAsync(WaitingTaskHolder iHolder, SubProcess& iSubProcess, RunPrincipal& iPrincipal, IOVSyncValue const& iTS) { | ||
| iSubProcess.doBeginRunAsync(std::move(iHolder),iPrincipal, iTS); | ||
| } | ||
|
|
||
| /*Not implemented yet | ||
| inline void subProcessDoGlobalEndTransitionAsync(WaitingTaskHolder iHolder, SubProcess& iSubProcess, LuminosityBlockPrincipal& iPrincipal, IOVSyncValue const& iTS, bool cleaningUpAfterException) { | ||
| iSubProcess.doEndLuminosityBlockAsync(std::move(iHolder),iPrincipal, iTS,cleaningUpAfterException); | ||
| } | ||
| inline void subProcessDoGlobalEndTransitionAsync(WaitingTaskHolder iHolder, SubProcess& iSubProcess, RunPrincipal& iPrincipal, IOVSyncValue const& iTS, bool cleaningUpAfterException) { | ||
| iSubProcess.doEndRunAsync(std::move(iHolder), iPrincipal, iTS, cleaningUpAfterException); | ||
| } | ||
| */ | ||
|
|
||
| template<typename Traits, typename P, typename SC > | ||
| void beginGlobalTransitionAsync(WaitingTaskHolder iWait, | ||
| Schedule& iSchedule, | ||
| P& iPrincipal, | ||
| IOVSyncValue const & iTS, | ||
| EventSetup const& iES, | ||
| SC& iSubProcesses) { | ||
| ServiceToken token = ServiceRegistry::instance().presentToken(); | ||
|
|
||
| //When we are done processing the global for this process, | ||
| // we need to run the global for all SubProcesses | ||
| auto subs = make_waiting_task(tbb::task::allocate_root(), [&iSubProcesses, iWait,&iPrincipal,iTS,token](std::exception_ptr const* iPtr) mutable { | ||
| if(iPtr) { | ||
| iWait.doneWaiting(*iPtr); | ||
| return; | ||
| } | ||
| ServiceRegistry::Operate op(token); | ||
| for_all(iSubProcesses, [&iWait, &iPrincipal, iTS](auto& subProcess){ subProcessDoGlobalBeginTransitionAsync(iWait,subProcess,iPrincipal, iTS); }); | ||
| }); | ||
|
|
||
| WaitingTaskHolder h(subs); | ||
| iSchedule.processOneGlobalAsync<Traits>(std::move(h),iPrincipal, iES); | ||
| } | ||
|
|
||
|
|
||
| template<typename Traits, typename P, typename SC > | ||
| void endGlobalTransitionAsync(WaitingTaskHolder iWait, | ||
| Schedule& iSchedule, | ||
| P& iPrincipal, | ||
| IOVSyncValue const & iTS, | ||
| EventSetup const& iES, | ||
| SC& iSubProcesses, | ||
| bool cleaningUpAfterException) | ||
| { | ||
| ServiceToken token = ServiceRegistry::instance().presentToken(); | ||
|
|
||
| //When we are done processing the global for this process, | ||
| // we need to run the global for all SubProcesses | ||
| auto subs = make_waiting_task(tbb::task::allocate_root(), [&iSubProcesses, iWait,&iPrincipal,iTS,token,cleaningUpAfterException](std::exception_ptr const* iPtr) mutable { | ||
| if(iPtr) { | ||
| iWait.doneWaiting(*iPtr); | ||
| return; | ||
| } | ||
| ServiceRegistry::Operate op(token); | ||
| for_all(iSubProcesses, [&iWait, &iPrincipal, iTS,cleaningUpAfterException](auto& subProcess){ | ||
| subProcessDoGlobalEndTransitionAsync(iWait,subProcess,iPrincipal, iTS,cleaningUpAfterException); }); | ||
| }); | ||
|
|
||
| WaitingTaskHolder h(subs); | ||
| iSchedule.processOneGlobalAsync<Traits>(std::move(h),iPrincipal, iES,cleaningUpAfterException); | ||
|
|
||
|
|
||
| } | ||
|
|
||
| }; | ||
|
|
||
| #endif |
Oops, something went wrong.