mirror of
https://github.com/Icinga/icinga2.git
synced 2025-04-08 17:05:25 +02:00
Introduce SharedMemory
This commit is contained in:
parent
f3b148517f
commit
a66ace7245
@ -65,6 +65,7 @@ set(base_SOURCES
|
||||
scriptutils.cpp scriptutils.hpp
|
||||
serializer.cpp serializer.hpp
|
||||
shared.hpp
|
||||
shared-memory.hpp
|
||||
shared-object.hpp
|
||||
singleton.hpp
|
||||
socket.cpp socket.hpp
|
||||
|
45
lib/base/shared-memory.hpp
Normal file
45
lib/base/shared-memory.hpp
Normal file
@ -0,0 +1,45 @@
|
||||
/* Icinga 2 | (c) 2023 Icinga GmbH | GPLv2+ */
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <boost/interprocess/anonymous_shared_memory.hpp>
|
||||
#include <utility>
|
||||
|
||||
namespace icinga
|
||||
{
|
||||
|
||||
/**
|
||||
* Type-safe memory shared across fork(2).
|
||||
*
|
||||
* @ingroup base
|
||||
*/
|
||||
template<class T>
|
||||
class SharedMemory
|
||||
{
|
||||
public:
|
||||
template<class... Args>
|
||||
SharedMemory(Args&&... args) : m_Memory(boost::interprocess::anonymous_shared_memory(sizeof(T)))
|
||||
{
|
||||
new(GetAddress()) T(std::forward<Args>(args)...);
|
||||
}
|
||||
|
||||
SharedMemory(const SharedMemory&) = delete;
|
||||
SharedMemory(SharedMemory&&) = delete;
|
||||
SharedMemory& operator=(const SharedMemory&) = delete;
|
||||
SharedMemory& operator=(SharedMemory&&) = delete;
|
||||
|
||||
inline T& Get() const
|
||||
{
|
||||
return *GetAddress();
|
||||
}
|
||||
|
||||
private:
|
||||
inline T* GetAddress() const
|
||||
{
|
||||
return (T*)m_Memory.get_address();
|
||||
}
|
||||
|
||||
boost::interprocess::mapped_region m_Memory;
|
||||
};
|
||||
|
||||
}
|
Loading…
x
Reference in New Issue
Block a user