Skip to content
Snippets Groups Projects
Commit b11ce52b authored by Adam Edward Barton's avatar Adam Edward Barton :speech_balloon:
Browse files

Prevent unnecessary checking in offline mode

parent 2b33dfce
No related branches found
No related tags found
No related merge requests found
...@@ -138,7 +138,7 @@ namespace InDet{ ...@@ -138,7 +138,7 @@ namespace InDet{
const COLLECTION* RDO_Collection(*rdoCollections); const COLLECTION* RDO_Collection(*rdoCollections);
if (!RDO_Collection || RDO_Collection->empty()) continue; if (!RDO_Collection || RDO_Collection->empty()) continue;
PixelClusterContainer::IDC_WriteHandle lock = clusterContainer->getWriteHandle(rdoCollections.hashId()); PixelClusterContainer::IDC_WriteHandle lock = clusterContainer->getWriteHandle(rdoCollections.hashId());
if( lock.alreadyPresent() ) continue; if( lock.OnlineAndPresentInAnotherView() ) continue;
// Use one of the specific clustering AlgTools to make clusters // Use one of the specific clustering AlgTools to make clusters
std::unique_ptr<PixelClusterCollection> clusterCollection (m_clusteringTool->clusterize(*RDO_Collection, *m_idHelper)); std::unique_ptr<PixelClusterCollection> clusterCollection (m_clusteringTool->clusterize(*RDO_Collection, *m_idHelper));
...@@ -172,7 +172,7 @@ namespace InDet{ ...@@ -172,7 +172,7 @@ namespace InDet{
if (!RDO_Collection) continue; if (!RDO_Collection) continue;
PixelClusterContainer::IDC_WriteHandle lock = clusterContainer->getWriteHandle(listOfPixIds[i]); PixelClusterContainer::IDC_WriteHandle lock = clusterContainer->getWriteHandle(listOfPixIds[i]);
if( lock.alreadyPresent() ) continue; if( lock.OnlineAndPresentInAnotherView() ) continue;
// Use one of the specific clustering AlgTools to make clusters // Use one of the specific clustering AlgTools to make clusters
std::unique_ptr<PixelClusterCollection> clusterCollection (m_clusteringTool->clusterize(*RDO_Collection, *m_idHelper)); std::unique_ptr<PixelClusterCollection> clusterCollection (m_clusteringTool->clusterize(*RDO_Collection, *m_idHelper));
......
...@@ -119,7 +119,7 @@ namespace InDet { ...@@ -119,7 +119,7 @@ namespace InDet {
const InDetRawDataCollection<SCT_RDORawData>* rd{*rdoCollections}; const InDetRawDataCollection<SCT_RDORawData>* rd{*rdoCollections};
ATH_MSG_DEBUG("RDO collection size=" << rd->size() << ", Hash=" << rd->identifyHash()); ATH_MSG_DEBUG("RDO collection size=" << rd->size() << ", Hash=" << rd->identifyHash());
SCT_ClusterContainer::IDC_WriteHandle lock{clusterContainer->getWriteHandle(rdoCollections.hashId())}; SCT_ClusterContainer::IDC_WriteHandle lock{clusterContainer->getWriteHandle(rdoCollections.hashId())};
if (lock.alreadyPresent()) { if (lock.OnlineAndPresentInAnotherView()) {
ATH_MSG_DEBUG("Item already in cache , Hash=" << rd->identifyHash()); ATH_MSG_DEBUG("Item already in cache , Hash=" << rd->identifyHash());
continue; continue;
} }
...@@ -187,7 +187,7 @@ namespace InDet { ...@@ -187,7 +187,7 @@ namespace InDet {
SCT_ClusterContainer::IDC_WriteHandle lock{clusterContainer->getWriteHandle(listOfSCTIds[i])}; SCT_ClusterContainer::IDC_WriteHandle lock{clusterContainer->getWriteHandle(listOfSCTIds[i])};
if (lock.alreadyPresent()) { if (lock.OnlineAndPresentInAnotherView()) {
ATH_MSG_DEBUG("Item already in cache , Hash=" << listOfSCTIds[i]); ATH_MSG_DEBUG("Item already in cache , Hash=" << listOfSCTIds[i]);
continue; continue;
} }
......
...@@ -96,7 +96,7 @@ namespace InDet { ...@@ -96,7 +96,7 @@ namespace InDet {
for(const auto& rdoCollections : *rdoContainer) { for(const auto& rdoCollections : *rdoContainer) {
const InDetRawDataCollection<TRT_RDORawData>* currentCollection(rdoCollections); const InDetRawDataCollection<TRT_RDORawData>* currentCollection(rdoCollections);
InDet::TRT_DriftCircleContainer::IDC_WriteHandle lock = rioContainer->getWriteHandle(currentCollection->identifyHash()); InDet::TRT_DriftCircleContainer::IDC_WriteHandle lock = rioContainer->getWriteHandle(currentCollection->identifyHash());
if( lock.alreadyPresent() ) continue; if( lock.OnlineAndPresentInAnotherView() ) continue;
std::unique_ptr<TRT_DriftCircleCollection> p_rio(m_driftcircle_tool->convert(m_mode_rio_production, std::unique_ptr<TRT_DriftCircleCollection> p_rio(m_driftcircle_tool->convert(m_mode_rio_production,
currentCollection, ctx, m_trtBadChannels)); currentCollection, ctx, m_trtBadChannels));
if(p_rio && !p_rio->empty()) { if(p_rio && !p_rio->empty()) {
...@@ -120,7 +120,7 @@ namespace InDet { ...@@ -120,7 +120,7 @@ namespace InDet {
const InDetRawDataCollection<TRT_RDORawData>* RDO_Collection (rdoContainer->indexFindPtr(id)); const InDetRawDataCollection<TRT_RDORawData>* RDO_Collection (rdoContainer->indexFindPtr(id));
if (!RDO_Collection) continue; if (!RDO_Collection) continue;
InDet::TRT_DriftCircleContainer::IDC_WriteHandle lock = rioContainer->getWriteHandle(id); InDet::TRT_DriftCircleContainer::IDC_WriteHandle lock = rioContainer->getWriteHandle(id);
if( lock.alreadyPresent() ) continue; if( lock.OnlineAndPresentInAnotherView() ) continue;
// Use one of the specific clustering AlgTools to make clusters // Use one of the specific clustering AlgTools to make clusters
std::unique_ptr<TRT_DriftCircleCollection> p_rio(m_driftcircle_tool->convert(m_mode_rio_production, std::unique_ptr<TRT_DriftCircleCollection> p_rio(m_driftcircle_tool->convert(m_mode_rio_production,
......
...@@ -221,7 +221,7 @@ StatusCode SiTrackerSpacePointFinder::execute (const EventContext& ctx) const ...@@ -221,7 +221,7 @@ StatusCode SiTrackerSpacePointFinder::execute (const EventContext& ctx) const
// Create SpacePointCollection // Create SpacePointCollection
IdentifierHash idHash = colNext->identifyHash(); IdentifierHash idHash = colNext->identifyHash();
SpacePointContainer::IDC_WriteHandle lock = spacePointContainer_SCT->getWriteHandle(idHash); SpacePointContainer::IDC_WriteHandle lock = spacePointContainer_SCT->getWriteHandle(idHash);
if(lock.alreadyPresent()){ if(lock.OnlineAndPresentInAnotherView()){
ATH_MSG_DEBUG("SCT Hash " << idHash << " is already in cache"); ATH_MSG_DEBUG("SCT Hash " << idHash << " is already in cache");
++sctCacheCount; ++sctCacheCount;
continue; //Skip if already present in cache continue; //Skip if already present in cache
...@@ -277,7 +277,7 @@ StatusCode SiTrackerSpacePointFinder::execute (const EventContext& ctx) const ...@@ -277,7 +277,7 @@ StatusCode SiTrackerSpacePointFinder::execute (const EventContext& ctx) const
nReceivedClustersPIX = (*colNext)->size(); nReceivedClustersPIX = (*colNext)->size();
IdentifierHash idHash = (*colNext)->identifyHash(); IdentifierHash idHash = (*colNext)->identifyHash();
SpacePointContainer::IDC_WriteHandle lock = spacePointContainerPixel->getWriteHandle(idHash); SpacePointContainer::IDC_WriteHandle lock = spacePointContainerPixel->getWriteHandle(idHash);
if(lock.alreadyPresent()){ if(lock.OnlineAndPresentInAnotherView()){
ATH_MSG_DEBUG("pixel Hash " << idHash << " is already in cache"); ATH_MSG_DEBUG("pixel Hash " << idHash << " is already in cache");
++pixCacheCount; ++pixCacheCount;
continue; continue;
......
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