Skip to content

Commit

Permalink
Revert Provenance Prefetching
Browse files Browse the repository at this point in the history
When running on very many threads it appears that the framework sometimes thinks the prefetching for the PoolOutputModule never finishes and therefore the module is never run. Until the problem is found, we need to not do the prefetching.
  • Loading branch information
Dr15Jones committed Feb 17, 2017
1 parent a2fc9ea commit 160b21b
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
6 changes: 0 additions & 6 deletions FWCore/Integration/test/unit_test_outputs/testGetBy2.log
Expand Up @@ -361,8 +361,6 @@ PathContext: pathName = e pathID = 0 (EndPath)
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ starting: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ starting: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++ finished: prefetching before processing event for module: stream = 0 label = 'out' id = 3
++++++++ starting: processing event for module: stream = 0 label = 'out' id = 3
++++++++ finished: processing event for module: stream = 0 label = 'out' id = 3
Expand Down Expand Up @@ -505,8 +503,6 @@ PathContext: pathName = e pathID = 0 (EndPath)
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ starting: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ starting: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++ finished: prefetching before processing event for module: stream = 0 label = 'out' id = 3
++++++++ starting: processing event for module: stream = 0 label = 'out' id = 3
++++++++ finished: processing event for module: stream = 0 label = 'out' id = 3
Expand Down Expand Up @@ -649,8 +645,6 @@ PathContext: pathName = e pathID = 0 (EndPath)
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ starting: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ starting: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++++ finished: event delayed read from source: stream = 0 label = 'out' id = 3
++++++++ finished: prefetching before processing event for module: stream = 0 label = 'out' id = 3
++++++++ starting: processing event for module: stream = 0 label = 'out' id = 3
++++++++ finished: processing event for module: stream = 0 label = 'out' id = 3
Expand Down
3 changes: 3 additions & 0 deletions IOPool/Output/src/PoolOutputModule.cc
Expand Up @@ -379,6 +379,8 @@ namespace edm {

void
PoolOutputModule::preActionBeforeRunEventAsync(WaitingTask* iTask, ModuleCallingContext const& iModuleCallingContext, Principal const& iPrincipal) const {
/* For the moment, there appears to be a race condition when
using this code.
if(DropAll != dropMetaData_ ) {
auto const* ep = dynamic_cast<EventPrincipal const*>(&iPrincipal);
if(ep)
Expand All @@ -389,6 +391,7 @@ namespace edm {
}
}
}
*/
}

void
Expand Down

0 comments on commit 160b21b

Please sign in to comment.