mirror of https://github.com/Icinga/icinga2.git
mkclass: make .ti class members atomic if possible
... not to have to lock the objects while setting attributes.
This commit is contained in:
parent
d5d89b7f39
commit
bbe0f2d8c4
|
@ -4,6 +4,8 @@
|
|||
#define ATOMIC_H
|
||||
|
||||
#include <atomic>
|
||||
#include <type_traits>
|
||||
#include <utility>
|
||||
|
||||
namespace icinga
|
||||
{
|
||||
|
@ -38,6 +40,80 @@ public:
|
|||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* Wraps T into a std::atomic<T>-like interface.
|
||||
*
|
||||
* @ingroup base
|
||||
*/
|
||||
template<class T>
|
||||
class NotAtomic
|
||||
{
|
||||
public:
|
||||
inline T load() const
|
||||
{
|
||||
return m_Value;
|
||||
}
|
||||
|
||||
inline void store(T desired)
|
||||
{
|
||||
m_Value = std::move(desired);
|
||||
}
|
||||
|
||||
T m_Value;
|
||||
};
|
||||
|
||||
/**
|
||||
* Tells whether to use std::atomic<T> or NotAtomic<T>.
|
||||
*
|
||||
* @ingroup base
|
||||
*/
|
||||
template<class T>
|
||||
struct Atomicable
|
||||
{
|
||||
// Doesn't work with too old compilers.
|
||||
//static constexpr bool value = std::is_trivially_copyable<T>::value && sizeof(T) <= sizeof(void*);
|
||||
static constexpr bool value = (std::is_fundamental<T>::value || std::is_pointer<T>::value) && sizeof(T) <= sizeof(void*);
|
||||
};
|
||||
|
||||
/**
|
||||
* Uses either std::atomic<T> or NotAtomic<T> depending on atomicable.
|
||||
*
|
||||
* @ingroup base
|
||||
*/
|
||||
template<bool atomicable>
|
||||
struct AtomicTemplate;
|
||||
|
||||
template<>
|
||||
struct AtomicTemplate<false>
|
||||
{
|
||||
template<class T>
|
||||
struct tmplt
|
||||
{
|
||||
typedef NotAtomic<T> type;
|
||||
};
|
||||
};
|
||||
|
||||
template<>
|
||||
struct AtomicTemplate<true>
|
||||
{
|
||||
template<class T>
|
||||
struct tmplt
|
||||
{
|
||||
typedef std::atomic<T> type;
|
||||
};
|
||||
};
|
||||
|
||||
/**
|
||||
* Uses either std::atomic<T> or NotAtomic<T> depending on T.
|
||||
*
|
||||
* @ingroup base
|
||||
*/
|
||||
template<class T>
|
||||
struct EventuallyAtomic
|
||||
{
|
||||
typedef typename AtomicTemplate<Atomicable<T>::value>::template tmplt<T>::type type;
|
||||
};
|
||||
|
||||
}
|
||||
|
||||
#endif /* ATOMIC_H */
|
||||
|
|
|
@ -59,10 +59,10 @@ abstract class ConfigObject : ConfigObjectBase < ConfigType
|
|||
[config, no_user_modify] String __name (Name);
|
||||
[config, no_user_modify] String "name" (ShortName) {
|
||||
get {{{
|
||||
if (m_ShortName.IsEmpty())
|
||||
if (m_ShortName.m_Value.IsEmpty())
|
||||
return GetName();
|
||||
else
|
||||
return m_ShortName;
|
||||
return m_ShortName.m_Value;
|
||||
}}}
|
||||
};
|
||||
[config, no_user_modify] name(Zone) zone (ZoneName);
|
||||
|
|
|
@ -21,10 +21,10 @@ class Host : Checkable
|
|||
|
||||
[config] String display_name {
|
||||
get {{{
|
||||
if (m_DisplayName.IsEmpty())
|
||||
if (m_DisplayName.m_Value.IsEmpty())
|
||||
return GetName();
|
||||
else
|
||||
return m_DisplayName;
|
||||
return m_DisplayName.m_Value;
|
||||
}}}
|
||||
};
|
||||
|
||||
|
|
|
@ -11,10 +11,10 @@ class HostGroup : CustomVarObject
|
|||
{
|
||||
[config] String display_name {
|
||||
get {{{
|
||||
if (m_DisplayName.IsEmpty())
|
||||
if (m_DisplayName.m_Value.IsEmpty())
|
||||
return GetName();
|
||||
else
|
||||
return m_DisplayName;
|
||||
return m_DisplayName.m_Value;
|
||||
}}}
|
||||
};
|
||||
|
||||
|
|
|
@ -33,10 +33,10 @@ class Service : Checkable < ServiceNameComposer
|
|||
|
||||
[config] String display_name {
|
||||
get {{{
|
||||
if (m_DisplayName.IsEmpty())
|
||||
if (m_DisplayName.m_Value.IsEmpty())
|
||||
return GetShortName();
|
||||
else
|
||||
return m_DisplayName;
|
||||
return m_DisplayName.m_Value;
|
||||
}}}
|
||||
};
|
||||
[config, required] name(Host) host_name;
|
||||
|
|
|
@ -11,10 +11,10 @@ class ServiceGroup : CustomVarObject
|
|||
{
|
||||
[config] String display_name {
|
||||
get {{{
|
||||
if (m_DisplayName.IsEmpty())
|
||||
if (m_DisplayName.m_Value.IsEmpty())
|
||||
return GetName();
|
||||
else
|
||||
return m_DisplayName;
|
||||
return m_DisplayName.m_Value;
|
||||
}}}
|
||||
};
|
||||
|
||||
|
|
|
@ -12,10 +12,10 @@ class TimePeriod : CustomVarObject
|
|||
{
|
||||
[config] String display_name {
|
||||
get {{{
|
||||
if (m_DisplayName.IsEmpty())
|
||||
if (m_DisplayName.m_Value.IsEmpty())
|
||||
return GetName();
|
||||
else
|
||||
return m_DisplayName;
|
||||
return m_DisplayName.m_Value;
|
||||
}}}
|
||||
};
|
||||
[config] Dictionary::Ptr ranges;
|
||||
|
|
|
@ -13,10 +13,10 @@ class User : CustomVarObject
|
|||
{
|
||||
[config] String display_name {
|
||||
get {{{
|
||||
if (m_DisplayName.IsEmpty())
|
||||
if (m_DisplayName.m_Value.IsEmpty())
|
||||
return GetName();
|
||||
else
|
||||
return m_DisplayName;
|
||||
return m_DisplayName.m_Value;
|
||||
}}}
|
||||
};
|
||||
[config, no_user_modify, required] array(name(UserGroup)) groups {
|
||||
|
|
|
@ -11,10 +11,10 @@ class UserGroup : CustomVarObject
|
|||
{
|
||||
[config] String display_name {
|
||||
get {{{
|
||||
if (m_DisplayName.IsEmpty())
|
||||
if (m_DisplayName.m_Value.IsEmpty())
|
||||
return GetName();
|
||||
else
|
||||
return m_DisplayName;
|
||||
return m_DisplayName.m_Value;
|
||||
}}}
|
||||
};
|
||||
|
||||
|
|
|
@ -797,7 +797,7 @@ void ClassCompiler::HandleClass(const Klass& klass, const ClassDebugInfo&)
|
|||
<< "{" << std::endl;
|
||||
|
||||
if (field.GetAccessor.empty() && !(field.Attributes & FANoStorage))
|
||||
m_Impl << "\t" << "return m_" << field.GetFriendlyName() << ";" << std::endl;
|
||||
m_Impl << "\t" << "return m_" << field.GetFriendlyName() << ".load();" << std::endl;
|
||||
else
|
||||
m_Impl << field.GetAccessor << std::endl;
|
||||
|
||||
|
@ -835,7 +835,7 @@ void ClassCompiler::HandleClass(const Klass& klass, const ClassDebugInfo&)
|
|||
|
||||
|
||||
if (field.SetAccessor.empty() && !(field.Attributes & FANoStorage))
|
||||
m_Impl << "\t" << "m_" << field.GetFriendlyName() << " = value;" << std::endl;
|
||||
m_Impl << "\t" << "m_" << field.GetFriendlyName() << ".store(value);" << std::endl;
|
||||
else
|
||||
m_Impl << field.SetAccessor << std::endl << std::endl;
|
||||
|
||||
|
@ -1044,7 +1044,7 @@ void ClassCompiler::HandleClass(const Klass& klass, const ClassDebugInfo&)
|
|||
if (field.Attributes & FANoStorage)
|
||||
continue;
|
||||
|
||||
m_Header << "\t" << field.Type.GetRealType() << " m_" << field.GetFriendlyName() << ";" << std::endl;
|
||||
m_Header << "\tEventuallyAtomic<" << field.Type.GetRealType() << ">::type m_" << field.GetFriendlyName() << ";" << std::endl;
|
||||
}
|
||||
|
||||
/* signal */
|
||||
|
@ -1431,6 +1431,7 @@ void ClassCompiler::CompileStream(const std::string& path, std::istream& input,
|
|||
<< "#include \"base/type.hpp\"" << std::endl
|
||||
<< "#include \"base/value.hpp\"" << std::endl
|
||||
<< "#include \"base/array.hpp\"" << std::endl
|
||||
<< "#include \"base/atomic.hpp\"" << std::endl
|
||||
<< "#include \"base/dictionary.hpp\"" << std::endl
|
||||
<< "#include <boost/signals2.hpp>" << std::endl << std::endl;
|
||||
|
||||
|
|
Loading…
Reference in New Issue