make_persistent_array_atomic.hpp

Go to the documentation of this file.

// SPDX-License-Identifier: BSD-3-Clause
/* Copyright 2016-2021, Intel Corporation */
 
#ifndef LIBPMEMOBJ_CPP_MAKE_PERSISTENT_ARRAY_ATOMIC_HPP
#define LIBPMEMOBJ_CPP_MAKE_PERSISTENT_ARRAY_ATOMIC_HPP
 
#include <libpmemobj++/allocation_flag.hpp>
#include <libpmemobj++/detail/array_traits.hpp>
#include <libpmemobj++/detail/check_persistent_ptr_array.hpp>
#include <libpmemobj++/detail/common.hpp>
#include <libpmemobj++/detail/make_atomic_impl.hpp>
#include <libpmemobj++/detail/variadic.hpp>
#include <libpmemobj++/pexceptions.hpp>
#include <libpmemobj/atomic_base.h>
 
namespace pmem
{
 
namespace obj
{
 
template <typename T>
void
make_persistent_atomic(
    pool_base &pool, typename detail::pp_if_array<T>::type &ptr,
    std::size_t N,
    allocation_flag_atomic flag = allocation_flag_atomic::none())
{
    typedef typename detail::pp_array_type<T>::type I;
 
    auto ret = pmemobj_xalloc(pool.handle(), ptr.raw_ptr(), sizeof(I) * N,
                  detail::type_num<I>(), flag.value,
                  &detail::array_constructor<I>,
                  static_cast<void *>(&N));
 
    if (ret != 0)
        throw std::bad_alloc();
}
 
template <typename T>
void
make_persistent_atomic(
    pool_base &pool, typename detail::pp_if_size_array<T>::type &ptr,
    allocation_flag_atomic flag = allocation_flag_atomic::none())
{
    typedef typename detail::pp_array_type<T>::type I;
    std::size_t N = detail::pp_array_elems<T>::elems;
 
    auto ret = pmemobj_xalloc(pool.handle(), ptr.raw_ptr(), sizeof(I) * N,
                  detail::type_num<I>(), flag.value,
                  &detail::array_constructor<I>,
                  static_cast<void *>(&N));
 
    if (ret != 0)
        throw std::bad_alloc();
}
 
template <typename T>
void
delete_persistent_atomic(typename detail::pp_if_array<T>::type &ptr,
             std::size_t)
{
    if (ptr == nullptr)
        return;
 
    /* we CAN'T call destructor */
    pmemobj_free(ptr.raw_ptr());
}
 
template <typename T>
void
delete_persistent_atomic(typename detail::pp_if_size_array<T>::type &ptr)
{
    if (ptr == nullptr)
        return;
 
    /* we CAN'T call destructor */
    pmemobj_free(ptr.raw_ptr());
}
 
} /* namespace obj */
 
} /* namespace pmem */
 
#endif /* LIBPMEMOBJ_CPP_MAKE_PERSISTENT_ARRAY_ATOMIC_HPP */