2 Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
5 #ifndef ASGTOOLS_ANATOOLHANDLE_ICC
6 #define ASGTOOLS_ANATOOLHANDLE_ICC
8 #include <AsgTools/MessageCheckAsgTools.h>
9 #include "CxxUtils/checker_macros.h"
13 #ifndef XAOD_STANDALONE
14 #include "Gaudi/Interfaces/IOptionsSvc.h"
22 #ifdef XAOD_STANDALONE
23 StatusCode makeToolRootCore (const std::string& type,
24 const std::string& name,
27 StatusCode readToolConfig (AsgToolConfig& config, const std::string& toolName);
28 StatusCode copyPropertiesInCatalogue( const std::string& fromTool, const std::string& toTool );
29 StatusCode hasPropertiesInCatalogue( const std::string& toolName );
30 StatusCode addPropertyToCatalogue( const std::string& toolName, const std::string& property, const std::string& val);
31 StatusCode removePropertyFromCatalogue( const std::string& toolName, const std::string& property);
32 StatusCode toolExists( const std::string& fullName, interfaceType_t*& tool );
37 /// \brief do a checked cast from one ToolHandle interface to
42 /// interface not supported for tool
43 template<typename T1,typename T2> StatusCode
44 toolHandleCast (ToolHandle<T1>& to, ToolHandle<T2>& from)
46 using namespace msgUserCode;
48 #ifdef XAOD_STANDALONE
49 to = ToolHandle<T1> (dynamic_cast<T1*>(&*from));
50 if (!from.empty() && to.operator->() == nullptr)
52 ANA_MSG_ERROR ("failed to cast from type " << typeid(T2).name() << " to " << typeid(T1).name());
53 return StatusCode::FAILURE;
56 to = ToolHandle<T1> (from.typeAndName(), from.parent());
58 ANA_CHECK (to.retrieve());
60 return StatusCode::SUCCESS;
67 /// \brief the information needed to share a tool
75 /// \brief standard constructor
81 AnaToolShare (const ToolHandle<interfaceType_t>& val_th,
82 std::shared_ptr<void> val_cleanup,
83 std::vector<std::function<StatusCode ()>>&& extraInit);
86 /// \brief the tool we contain
89 /// \post result != nullptr
91 ToolHandle<interfaceType_t>& th ();
99 /// \brief the value of \ref tool
101 ToolHandle<interfaceType_t> m_th;
103 /// \brief resources to release when we are releasing the tool
105 std::vector<std::function<StatusCode ()>> m_extraInit;
107 /// \brief resources to release when we are releasing the tool
109 std::shared_ptr<void> m_cleanup;
116 /// \brief a service for sharing tools of a given type
118 class AnaToolShareList
124 /// \brief the singleton we are using
128 static AnaToolShareList& singleton () noexcept;
131 /// \brief get the share for the given name, or nullptr if no
132 /// share has been defined
138 std::shared_ptr<AnaToolShare>
139 getShare (const std::string& name) const;
142 /// \brief set the share for the given name
143 /// \return the share to use, this is either the share passed in
144 /// or the already set share
150 std::shared_ptr<AnaToolShare>
151 setShare (const std::string& name,
152 std::unique_ptr<AnaToolShare> val_share);
155 /// \brief make or get a share for the given name
156 /// \return the share to use, either freshly created or
157 /// retrieved from the store
161 /// tool creation failures\n
165 makeShare (const std::string& name,
166 const AsgToolConfig& config,
167 std::vector<std::function<StatusCode ()>>&& extraInit,
168 std::shared_ptr<AnaToolShare>& result);
176 /// \brief the shares we manage
178 std::map<std::string,std::weak_ptr<AnaToolShare> > m_shared;
179 mutable std::recursive_mutex m_mutex;
180 typedef std::lock_guard<std::recursive_mutex> lock_t;
186 template <typename T>
187 std::ostream& operator << (std::ostream& str, const AnaToolHandle<T>& obj)
189 return str << obj.getHandle();
194 template<class T> void AnaToolHandle<T> ::
195 testInvariant () const
197 #define CHECK_INVARIANT(x) \
198 if (!(x)) { std::cerr << __FILE__ << ":" << __LINE__ << ": invariant violated: " << #x << std::endl; std::abort(); }
200 // General requirements
201 CHECK_INVARIANT (m_handleUser != nullptr);
202 CHECK_INVARIANT (m_name == m_config.name());
204 #undef CHECK_INVARIANT
209 template<class T> AnaToolHandle<T> ::
210 AnaToolHandle (const std::string& val_name, parentType_t *val_parent)
211 : m_parentPtr (val_parent),
212 m_handleUser (new ToolHandle<T> (val_name, val_parent)),
213 m_allowEmpty (val_name.empty())
215 setTypeAndName (val_name);
218 this->testInvariant ();
224 template<class T> AnaToolHandle<T> ::
225 AnaToolHandle (AnaToolHandle<T>&& that)
233 template<class T> AnaToolHandle<T> ::
234 AnaToolHandle (const AnaToolHandle<T>& that)
235 : m_config (that.m_config),
236 m_name (that.m_name),
237 m_parentPtr (that.m_parentPtr),
238 m_handleUser (new ToolHandle<T> (*that.m_handleUser)),
239 m_originalTypeAndName (that.m_originalTypeAndName),
240 m_isInitialized (that.m_isInitialized.load()),
241 m_allowEmpty (that.m_allowEmpty)
243 if (m_isInitialized.load())
245 m_toolPtr = that.m_toolPtr.load();
246 m_mode = that.m_mode;
247 m_extraInit = that.m_extraInit;
248 m_cleanup = that.m_cleanup;
251 #ifndef XAOD_STANDALONE
252 if (!m_handleUser->empty())
253 (*m_handleUser)->release();
257 that.testInvariant ();
264 template<class T> AnaToolHandle<T>& AnaToolHandle<T> ::
265 operator = (const AnaToolHandle<T>& that)
268 AnaToolHandle<T> (that).swap (*this);
274 template<class T> void AnaToolHandle<T> ::
275 swap (AnaToolHandle<T>& that) noexcept
279 that.testInvariant ();
282 std::swap (m_extraInit, that.m_extraInit);
283 std::swap (m_cleanup, that.m_cleanup);
284 std::swap (m_config, that.m_config);
285 m_name.swap (that.m_name);
286 std::swap (m_parentPtr, that.m_parentPtr);
288 ToolHandle<T> tmp = *m_handleUser;
289 #ifndef XAOD_STANDALONE
294 catch (const GaudiException&) {
299 *m_handleUser = *that.m_handleUser;
300 *that.m_handleUser = std::move(tmp);
302 m_originalTypeAndName.swap (that.m_originalTypeAndName);
304 const auto tmp = m_isInitialized.load();
305 m_isInitialized = that.m_isInitialized.load();
306 that.m_isInitialized = tmp;
309 const auto tmp = m_toolPtr.load();
310 m_toolPtr = that.m_toolPtr.load();
311 that.m_toolPtr = tmp;
313 std::swap (m_mode, that.m_mode);
314 std::swap (m_allowEmpty, that.m_allowEmpty);
318 that.testInvariant ();
324 template<class T> AnaToolHandle<T>& AnaToolHandle<T> ::
325 operator = (AnaToolHandle<T>&& that)
334 template<class T> AnaToolHandle<T> ::
335 ~AnaToolHandle () noexcept
337 using namespace msgToolHandle;
339 this->testInvariant ();
344 template<class T> bool
349 this->testInvariant ();
353 case detail::AnaToolHandleMode::EMPTY:
355 case detail::AnaToolHandleMode::CREATE_PRIVATE:
356 case detail::AnaToolHandleMode::CREATE_SHARED:
357 case detail::AnaToolHandleMode::RETRIEVE_SHARED:
359 case detail::AnaToolHandleMode::USER:
360 return m_handleUser->empty();
362 return false; //compiler dummy
367 template<class T> inline bool AnaToolHandle<T> ::
368 isPublic () const noexcept
371 this->testInvariant ();
373 return m_parentPtr == nullptr;
378 template<class T> inline const std::string& AnaToolHandle<T> ::
379 type () const noexcept
382 this->testInvariant ();
384 return m_config.type();
389 template<class T> inline const std::string&
391 name () const noexcept
394 this->testInvariant ();
401 template<typename T> template<typename T2>
402 StatusCode AnaToolHandle<T> ::
403 setProperty (const std::string& property, const T2& value)
405 using namespace msgToolHandle;
408 this->testInvariant ();
411 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
416 return m_config.setProperty (property, value);
421 template<typename T> template<typename T2>
422 typename std::enable_if<std::is_base_of_v<parentType_t, T2>, StatusCode>::type
424 setProperty (const std::string& property,
425 const ToolHandle<T2>& value)
427 using namespace msgToolHandle;
430 this->testInvariant ();
433 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
438 ANA_MSG_DEBUG ("adding sub-tool from ToolHandle: " << value);
440 return setProperty (property, std::string ());
441 #ifndef XAOD_STANDALONE
442 else if (value.isPublic())
444 else if (value.parentName() == "ToolSvc")
447 return setProperty (property,
448 value.type() + "/" + value.name());
451 #ifndef XAOD_STANDALONE
452 AsgToolConfig subToolConfig;
453 ANA_CHECK (detail::readToolConfig (subToolConfig, value.parentName() + "." + value.name()));
454 ANA_CHECK (m_config.addPrivateTool (property, std::move(subToolConfig)));
455 return StatusCode::SUCCESS;
457 return setProperty (property, value.name());
464 template<typename T> template<typename T2>
465 StatusCode AnaToolHandle<T> ::
466 setProperty (const std::string& property,
467 const AnaToolHandle<T2>& value)
469 using namespace msgToolHandle;
472 this->testInvariant ();
475 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
480 // once initialized the AnaToolHandle is not that different from
481 // a regular ToolHandle and we just use it as such
482 if (value.isInitialized())
483 return setProperty (property, value.getHandle());
485 ANA_MSG_DEBUG ("adding sub-tool from AnaToolHandle with mode " << unsigned (value.mode()) << " and name " << value.name());
486 switch (value.mode())
488 case detail::AnaToolHandleMode::EMPTY:
489 return setProperty (property, ToolHandle<T2> ());
490 case detail::AnaToolHandleMode::CREATE_PRIVATE:
491 return m_config.addPrivateTool (property, value.config());
492 case detail::AnaToolHandleMode::CREATE_SHARED:
493 case detail::AnaToolHandleMode::RETRIEVE_SHARED:
494 m_extraInit.emplace_back ([toolhandle = value] () mutable -> StatusCode
496 ANA_CHECK (toolhandle.initialize());
497 return StatusCode::SUCCESS;
499 return m_config.setProperty (property, value.name());
500 case detail::AnaToolHandleMode::USER:
501 return setProperty (property, value.getHandle());
503 return StatusCode::FAILURE; //compiler dummy
508 template<typename T> template<typename T2>
509 typename std::enable_if<std::is_base_of_v<parentType_t, T2>, StatusCode>::type
511 setProperty (const std::string& property,
512 const ToolHandleArray<T2>& value)
514 using namespace msgToolHandle;
517 this->testInvariant ();
520 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
525 std::vector<std::string> tools;
526 // loop over toolhandles in array, strip off any parent naming
527 // and set property with the result
528 for (auto& toolHandle : value)
530 if (toolHandle.empty())
532 ANA_MSG_ERROR ("trying to initialize ToolHandleArray property " << property << " with empty handle");
533 return StatusCode::FAILURE;
536 tools.push_back (toolHandle.type() + "/" + toolHandle.name());
539 return setProperty (property, tools);
544 template<class T> StatusCode
548 using namespace msgToolHandle;
550 // ensure we don't initialize twice concurrently
551 std::lock_guard<std::recursive_mutex> lock (m_initializeMutex);
554 this->testInvariant ();
557 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
562 std::shared_ptr<detail::AnaToolShare> sharedTool;
563 const detail::AnaToolHandleMode mode = getMode (sharedTool);
565 ToolHandle<T> th (typeAndName(), m_parentPtr);
566 std::shared_ptr<void> cleanup;
570 case detail::AnaToolHandleMode::EMPTY:
572 case detail::AnaToolHandleMode::CREATE_PRIVATE:
573 for (auto& extraInit : m_extraInit)
574 ANA_CHECK (extraInit());
575 ANA_CHECK (m_config.makeTool (th, cleanup, true));
577 case detail::AnaToolHandleMode::CREATE_SHARED:
578 ANA_CHECK (detail::AnaToolShareList::singleton().makeShare (m_name, m_config, std::move (m_extraInit), sharedTool));
580 case detail::AnaToolHandleMode::RETRIEVE_SHARED:
581 assert (sharedTool != nullptr);
582 ANA_CHECK (detail::toolHandleCast (th, sharedTool->th()));
583 #ifndef XAOD_STANDALONE
587 cleanup = sharedTool;
589 case detail::AnaToolHandleMode::USER:
591 if (th.empty() && !m_allowEmpty)
593 ANA_MSG_ERROR ("user configured an empty handle for a non-empty AnaToolHandle: " << *this);
594 return StatusCode::FAILURE;
599 T *toolPtr = nullptr;
600 ANA_CHECK (makeToolRetrieve (toolPtr, th));
603 #ifndef XAOD_STANDALONE
608 std::swap (m_cleanup, cleanup);
610 m_isInitialized = true;
613 this->testInvariant ();
615 return StatusCode::SUCCESS;
620 template<class T> StatusCode
625 return initialize ();
629 template<class T> bool
631 isConfigurable () const
633 using namespace msgToolHandle;
635 this->testInvariant ();
639 case detail::AnaToolHandleMode::EMPTY:
640 case detail::AnaToolHandleMode::CREATE_PRIVATE:
641 case detail::AnaToolHandleMode::CREATE_SHARED:
643 case detail::AnaToolHandleMode::RETRIEVE_SHARED:
644 case detail::AnaToolHandleMode::USER:
647 return true; //compiler dummy
656 bool AnaToolHandle<T> ::
657 isInitialized () const noexcept
660 this->testInvariant ();
662 return m_isInitialized;
667 template<class T> inline T *
677 template<class T> inline const T *
687 template<class T> inline T&
697 template<class T> inline const T&
707 template<class T> inline T*
711 using namespace msgToolHandle;
714 this->testInvariant ();
717 if (m_isInitialized.load())
721 std::lock_guard<std::recursive_mutex> lock (m_initializeMutex);
722 if (!m_isInitialized)
723 ANA_CHECK_THROW (initialize());
724 assert (m_isInitialized);
731 template<class T> inline const T*
735 AnaToolHandle<T>* this_nc ATLAS_THREAD_SAFE = const_cast<AnaToolHandle<T>*>(this);
736 return this_nc->get();
741 template <class T> template<typename T2> void
743 declarePropertyFor (T2 *tool, const std::string& name,
744 const std::string& description)
746 using namespace msgToolHandle;
748 this->testInvariant ();
751 ANA_MSG_FATAL ("can't declare tool handle " << *this << " as property " << name << " after tool has been instantiated");
756 if (m_parentPtr != nullptr && m_parentPtr != tool)
758 ANA_MSG_FATAL ("can't declare tool handle " << *this << " as property for tool " << tool->name() << " as it has a different parent tool " << m_parentPtr->name());
761 if (m_originalTypeAndName.empty())
762 m_originalTypeAndName = m_handleUser->typeAndName ();
763 ANA_CHECK_THROW (tool->declareProperty (name, *m_handleUser, description));
771 template <class T> const ToolHandle<T>&
773 getHandle () const noexcept
776 this->testInvariant ();
778 return *m_handleUser;
783 template <class T> bool
785 isUserConfigured () const
787 using namespace msgToolHandle;
789 this->testInvariant ();
792 // getMode can throw an exception (from dereferencing the ToolSvc handle),
793 // so this function is not noexcept.
796 case detail::AnaToolHandleMode::EMPTY:
797 case detail::AnaToolHandleMode::CREATE_PRIVATE:
798 case detail::AnaToolHandleMode::CREATE_SHARED:
800 case detail::AnaToolHandleMode::RETRIEVE_SHARED:
801 case detail::AnaToolHandleMode::USER:
804 return false; //compiler dummy
809 template<class T> std::string
814 this->testInvariant ();
816 #ifndef XAOD_STANDALONE
817 return m_handleUser->parentName() + "." + name();
819 std::string toolName;
821 toolName = m_parentPtr->name() + "." + name();
823 toolName = "ToolSvc." + name();
830 template<class T> detail::AnaToolHandleMode AnaToolHandle<T> ::
831 getMode (std::shared_ptr<detail::AnaToolShare>& sharedTool) const
833 using namespace msgToolHandle;
835 this->testInvariant ();
838 assert (!m_isInitialized);
840 if (m_handleUser->isSet())
841 return detail::AnaToolHandleMode::USER;
843 if (m_config.empty() && m_name.empty())
844 return detail::AnaToolHandleMode::EMPTY;
846 if (!m_originalTypeAndName.empty() &&
847 m_handleUser->typeAndName() != m_originalTypeAndName)
848 return detail::AnaToolHandleMode::USER;
850 #ifdef XAOD_STANDALONE
851 if (m_parentPtr != nullptr)
853 if (m_handleUser->parentName() != m_parentPtr->name())
854 return detail::AnaToolHandleMode::USER;
857 if (m_handleUser->parentName() != "ToolSvc")
858 return detail::AnaToolHandleMode::USER;
864 if ((sharedTool = detail::AnaToolShareList::singleton()
866 return detail::AnaToolHandleMode::RETRIEVE_SHARED;
867 #ifdef XAOD_STANDALONE
868 /// \todo check whether this is actually what we want to do
869 if (ToolStore::contains<T> (m_handleUser->name()))
870 return detail::AnaToolHandleMode::USER;
874 #ifndef XAOD_STANDALONE
875 //for athena, all we do here is check if the tool already exists
876 interfaceType_t *tool = nullptr;
877 if( detail::toolExists( fullName(), tool ) )
878 return detail::AnaToolHandleMode::USER;
880 if (detail::hasPropertiesInCatalogue (fullName()))
881 return detail::AnaToolHandleMode::USER;
884 if (m_config.empty() && !m_handleUser->typeAndName().empty() && (m_handleUser->type() != this->type() || m_handleUser->name() != this->name()))
885 return detail::AnaToolHandleMode::USER;
888 return detail::AnaToolHandleMode::CREATE_SHARED;
890 return detail::AnaToolHandleMode::CREATE_PRIVATE;
895 template<class T> detail::AnaToolHandleMode AnaToolHandle<T> ::
901 std::shared_ptr<detail::AnaToolShare> sharedTool;
902 return getMode (sharedTool);
907 template<class T> std::string AnaToolHandle<T> ::
911 this->testInvariant ();
913 return m_config.typeAndName();
918 template<class T> void AnaToolHandle<T> ::
919 setType (std::string val_type) noexcept
921 using namespace msgToolHandle;
923 this->testInvariant ();
926 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
931 m_config.setType (std::move (val_type));
932 if (m_originalTypeAndName.empty() &&
933 !this->type().empty() && !this->name().empty())
934 m_handleUser->setTypeAndName (this->type() + "/" + this->name());
937 this->testInvariant ();
943 template<class T> void AnaToolHandle<T> ::
944 setName (std::string val_name) noexcept
946 using namespace msgToolHandle;
948 this->testInvariant ();
951 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
956 m_config.setName (val_name);
957 m_name = std::move (val_name);
958 if (m_originalTypeAndName.empty() &&
959 !this->type().empty() && !this->name().empty())
960 m_handleUser->setTypeAndName (this->type() + "/" + this->name());
963 this->testInvariant ();
969 template<class T> void AnaToolHandle<T> ::
970 setTypeAndName (const std::string& val_typeAndName)
972 using namespace msgToolHandle;
976 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
980 auto split = val_typeAndName.find ("/");
981 if (split != std::string::npos)
983 setTypeAndName (val_typeAndName.substr (0, split),
984 val_typeAndName.substr (split+1));
987 setTypeAndName (val_typeAndName, val_typeAndName);
993 template<class T> void AnaToolHandle<T> ::
994 setTypeAndName (std::string val_type, std::string val_name) noexcept
996 using namespace msgToolHandle;
1000 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
1004 setType (std::move (val_type));
1005 setName (std::move (val_name));
1010 template<class T> StatusCode AnaToolHandle<T> ::
1011 makeToolRetrieve (T*& toolPtr, ToolHandle<T>& toolHandle) const
1013 using namespace msgToolHandle;
1015 if (toolHandle.empty())
1018 return StatusCode::SUCCESS;
1023 toolPtr = toolHandle.operator->();
1024 if (toolPtr == nullptr)
1026 ANA_MSG_ERROR ("failed to retrieve tool from tool handle " << *m_handleUser);
1027 return StatusCode::FAILURE;
1029 return StatusCode::SUCCESS;
1030 } catch (std::exception& e)
1032 ANA_MSG_ERROR ("encountered exception during tool retrieval (" << toolHandle << "): " << e.what());
1033 return StatusCode::FAILURE;
1039 template<class T> detail::AnaToolHandleMode AnaToolHandle<T> ::
1043 this->testInvariant ();
1050 template<class T> const AsgToolConfig& AnaToolHandle<T> ::
1054 this->testInvariant ();
1061 template<class T> bool AnaToolHandle<T> ::
1062 allowEmpty () const noexcept
1065 this->testInvariant ();
1067 return m_allowEmpty;
1072 template<class T> void AnaToolHandle<T> ::
1073 setAllowEmpty (bool val_allowEmpty) noexcept
1075 using namespace msgToolHandle;
1077 this->testInvariant ();
1078 if (isInitialized())
1080 ANA_MSG_FATAL ("AnaToolHandle has already been initialized: " << *this);
1084 m_allowEmpty = val_allowEmpty;
1088 #endif // ASGTOOLS_ANATOOLHANDLE_ICC