-
Notifications
You must be signed in to change notification settings - Fork 9
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #377 from JeffersonLab/nbrei_jfactory_finish
Bugfix: JFactory::Finish
- Loading branch information
Showing
29 changed files
with
907 additions
and
402 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
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,125 @@ | ||
|
|
||
| #include <JANA/JEvent.h> | ||
| #include <JANA/Services/JComponentManager.h> | ||
|
|
||
|
|
||
| JEvent::JEvent() : mInspector(this){ | ||
| mFactorySet = new JFactorySet(); | ||
| } | ||
|
|
||
| JEvent::JEvent(JApplication* app) : mInspector(this) { | ||
| // Furnish the JEvent with the parameter values and factory generators provided to the JApplication | ||
| app->Initialize(); | ||
| app->GetService<JComponentManager>()->configure_event(*this); | ||
| } | ||
|
|
||
| JEvent::~JEvent() { | ||
| if (mFactorySet != nullptr) { | ||
| // Prevent memory leaks of factory contents | ||
| mFactorySet->Clear(); | ||
| // We mustn't call EndRun() or Finish() here because that would give us an excepting destructor | ||
| } | ||
| delete mFactorySet; | ||
| } | ||
|
|
||
| void JEvent::SetFactorySet(JFactorySet* factorySet) { | ||
| delete mFactorySet; | ||
| mFactorySet = factorySet; | ||
| #if JANA2_HAVE_PODIO | ||
| // Maintain the index of PODIO factories | ||
| for (JFactory* factory : mFactorySet->GetAllFactories()) { | ||
| if (dynamic_cast<JFactoryPodio*>(factory) != nullptr) { | ||
| auto tag = factory->GetTag(); | ||
| auto it = mPodioFactories.find(tag); | ||
| if (it != mPodioFactories.end()) { | ||
| throw JException("SetFactorySet failed because PODIO factory tag '%s' is not unique", tag.c_str()); | ||
| } | ||
| mPodioFactories[tag] = factory; | ||
| } | ||
| } | ||
| #endif | ||
| } | ||
|
|
||
|
|
||
| /// GetFactory() should be used with extreme care because it subverts the JEvent abstraction. | ||
| /// Most historical uses of GetFactory are far better served by JMultifactory | ||
| JFactory* JEvent::GetFactory(const std::string& object_name, const std::string& tag) const { | ||
| return mFactorySet->GetFactory(object_name, tag); | ||
| } | ||
|
|
||
| /// GetAllFactories() should be used with extreme care because it subverts the JEvent abstraction. | ||
| /// Most historical uses of GetFactory are far better served by JMultifactory | ||
| std::vector<JFactory*> JEvent::GetAllFactories() const { | ||
| return mFactorySet->GetAllFactories(); | ||
| } | ||
|
|
||
| bool JEvent::HasParent(JEventLevel level) const { | ||
| for (const auto& pair : mParents) { | ||
| if (pair.first == level) return true; | ||
| } | ||
| return false; | ||
| } | ||
|
|
||
| const JEvent& JEvent::GetParent(JEventLevel level) const { | ||
| for (const auto& pair : mParents) { | ||
| if (pair.first == level) return *(*(pair.second)); | ||
| } | ||
| throw JException("Unable to find parent at level %s", | ||
| toString(level).c_str()); | ||
| } | ||
|
|
||
| void JEvent::SetParent(std::shared_ptr<JEvent>* parent) { | ||
| JEventLevel level = parent->get()->GetLevel(); | ||
| for (const auto& pair : mParents) { | ||
| if (pair.first == level) throw JException("Event already has a parent at level %s", | ||
| toString(parent->get()->GetLevel()).c_str()); | ||
| } | ||
| mParents.push_back({level, parent}); | ||
| parent->get()->mReferenceCount.fetch_add(1); | ||
| } | ||
|
|
||
| std::shared_ptr<JEvent>* JEvent::ReleaseParent(JEventLevel level) { | ||
| if (mParents.size() == 0) { | ||
| throw JException("ReleaseParent failed: child has no parents!"); | ||
| } | ||
| auto pair = mParents.back(); | ||
| if (pair.first != level) { | ||
| throw JException("JEvent::ReleaseParent called out of level order: Caller expected %s, but parent was actually %s", | ||
| toString(level).c_str(), toString(pair.first).c_str()); | ||
| } | ||
| mParents.pop_back(); | ||
| auto remaining_refs = pair.second->get()->mReferenceCount.fetch_sub(1); | ||
| if (remaining_refs < 1) { // Remember, this was fetched _before_ the last subtraction | ||
| throw JException("Parent refcount has gone negative!"); | ||
| } | ||
| if (remaining_refs == 1) { | ||
| return pair.second; | ||
| // Parent is no longer shared. Transfer back to arrow | ||
| } | ||
| else { | ||
| return nullptr; // Parent is still shared by other children | ||
| } | ||
| } | ||
|
|
||
| void JEvent::Release() { | ||
| auto remaining_refs = mReferenceCount.fetch_sub(1); | ||
| if (remaining_refs < 0) { | ||
| throw JException("JEvent's own refcount has gone negative!"); | ||
| } | ||
| } | ||
|
|
||
| void JEvent::Clear() { | ||
| if (mEventSource != nullptr) { | ||
| mEventSource->DoFinishEvent(*this); | ||
| } | ||
| mFactorySet->Clear(); | ||
| mInspector.Reset(); | ||
| mCallGraph.Reset(); | ||
| mReferenceCount = 1; | ||
| } | ||
|
|
||
| void JEvent::Finish() { | ||
| mFactorySet->Finish(); | ||
| } | ||
|
|
||
|
|
Oops, something went wrong.