|
- // <memory_resource> -*- C++ -*-
-
- // Copyright (C) 2018-2020 Free Software Foundation, Inc.
- //
- // This file is part of the GNU ISO C++ Library. This library is free
- // software; you can redistribute it and/or modify it under the
- // terms of the GNU General Public License as published by the
- // Free Software Foundation; either version 3, or (at your option)
- // any later version.
-
- // This library is distributed in the hope that it will be useful,
- // but WITHOUT ANY WARRANTY; without even the implied warranty of
- // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- // GNU General Public License for more details.
-
- // Under Section 7 of GPL version 3, you are granted additional
- // permissions described in the GCC Runtime Library Exception, version
- // 3.1, as published by the Free Software Foundation.
-
- // You should have received a copy of the GNU General Public License and
- // a copy of the GCC Runtime Library Exception along with this program;
- // see the files COPYING3 and COPYING.RUNTIME respectively. If not, see
- // <http://www.gnu.org/licenses/>.
-
- /** @file include/memory_resource
- * This is a Standard C++ Library header.
- */
-
- #ifndef _GLIBCXX_MEMORY_RESOURCE
- #define _GLIBCXX_MEMORY_RESOURCE 1
-
- #pragma GCC system_header
-
- #if __cplusplus >= 201703L
-
- #include <memory> // align, allocator_arg_t, __uses_alloc
- #include <utility> // pair, index_sequence
- #include <vector> // vector
- #include <cstddef> // size_t, max_align_t, byte
- #include <shared_mutex> // shared_mutex
- #include <bits/functexcept.h>
- #include <ext/numeric_traits.h>
- #include <debug/assertions.h>
-
- namespace std _GLIBCXX_VISIBILITY(default)
- {
- _GLIBCXX_BEGIN_NAMESPACE_VERSION
- namespace pmr
- {
- #ifdef _GLIBCXX_HAS_GTHREADS
- // Header and all contents are present.
- # define __cpp_lib_memory_resource 201603
- #else
- // The pmr::synchronized_pool_resource type is missing.
- # define __cpp_lib_memory_resource 1
- #endif
-
- class memory_resource;
-
- #if __cplusplus == 201703L
- template<typename _Tp>
- class polymorphic_allocator;
- #else // C++20
- # define __cpp_lib_polymorphic_allocator 201902L
- template<typename _Tp = std::byte>
- class polymorphic_allocator;
- #endif
-
- // Global memory resources
- memory_resource* new_delete_resource() noexcept;
- memory_resource* null_memory_resource() noexcept;
- memory_resource* set_default_resource(memory_resource* __r) noexcept;
- memory_resource* get_default_resource() noexcept
- __attribute__((__returns_nonnull__));
-
- // Pool resource classes
- struct pool_options;
- #ifdef _GLIBCXX_HAS_GTHREADS
- class synchronized_pool_resource;
- #endif
- class unsynchronized_pool_resource;
- class monotonic_buffer_resource;
-
- /// Class memory_resource
- class memory_resource
- {
- static constexpr size_t _S_max_align = alignof(max_align_t);
-
- public:
- memory_resource() = default;
- memory_resource(const memory_resource&) = default;
- virtual ~memory_resource(); // key function
-
- memory_resource& operator=(const memory_resource&) = default;
-
- [[nodiscard]]
- void*
- allocate(size_t __bytes, size_t __alignment = _S_max_align)
- __attribute__((__returns_nonnull__,__alloc_size__(2),__alloc_align__(3)))
- { return do_allocate(__bytes, __alignment); }
-
- void
- deallocate(void* __p, size_t __bytes, size_t __alignment = _S_max_align)
- __attribute__((__nonnull__))
- { return do_deallocate(__p, __bytes, __alignment); }
-
- bool
- is_equal(const memory_resource& __other) const noexcept
- { return do_is_equal(__other); }
-
- private:
- virtual void*
- do_allocate(size_t __bytes, size_t __alignment) = 0;
-
- virtual void
- do_deallocate(void* __p, size_t __bytes, size_t __alignment) = 0;
-
- virtual bool
- do_is_equal(const memory_resource& __other) const noexcept = 0;
- };
-
- inline bool
- operator==(const memory_resource& __a, const memory_resource& __b) noexcept
- { return &__a == &__b || __a.is_equal(__b); }
-
- #if __cpp_impl_three_way_comparison < 201907L
- inline bool
- operator!=(const memory_resource& __a, const memory_resource& __b) noexcept
- { return !(__a == __b); }
- #endif
-
- // C++17 23.12.3 Class template polymorphic_allocator
- template<typename _Tp>
- class polymorphic_allocator
- {
- // _GLIBCXX_RESOLVE_LIB_DEFECTS
- // 2975. Missing case for pair construction in polymorphic allocators
- template<typename _Up>
- struct __not_pair { using type = void; };
-
- template<typename _Up1, typename _Up2>
- struct __not_pair<pair<_Up1, _Up2>> { };
-
- public:
- using value_type = _Tp;
-
- polymorphic_allocator() noexcept
- : _M_resource(get_default_resource())
- { }
-
- polymorphic_allocator(memory_resource* __r) noexcept
- __attribute__((__nonnull__))
- : _M_resource(__r)
- { _GLIBCXX_DEBUG_ASSERT(__r); }
-
- polymorphic_allocator(const polymorphic_allocator& __other) = default;
-
- template<typename _Up>
- polymorphic_allocator(const polymorphic_allocator<_Up>& __x) noexcept
- : _M_resource(__x.resource())
- { }
-
- polymorphic_allocator&
- operator=(const polymorphic_allocator&) = delete;
-
- [[nodiscard]]
- _Tp*
- allocate(size_t __n)
- __attribute__((__returns_nonnull__))
- {
- if (__n > (__gnu_cxx::__int_traits<size_t>::__max / sizeof(_Tp)))
- _GLIBCXX_THROW_OR_ABORT(bad_array_new_length());
- return static_cast<_Tp*>(_M_resource->allocate(__n * sizeof(_Tp),
- alignof(_Tp)));
- }
-
- void
- deallocate(_Tp* __p, size_t __n) noexcept
- __attribute__((__nonnull__))
- { _M_resource->deallocate(__p, __n * sizeof(_Tp), alignof(_Tp)); }
-
- #if __cplusplus > 201703L
- [[nodiscard]] void*
- allocate_bytes(size_t __nbytes,
- size_t __alignment = alignof(max_align_t))
- { return _M_resource->allocate(__nbytes, __alignment); }
-
- void
- deallocate_bytes(void* __p, size_t __nbytes,
- size_t __alignment = alignof(max_align_t))
- { _M_resource->deallocate(__p, __nbytes, __alignment); }
-
- template<typename _Up>
- [[nodiscard]] _Up*
- allocate_object(size_t __n = 1)
- {
- if ((__gnu_cxx::__int_traits<size_t>::__max / sizeof(_Up)) < __n)
- _GLIBCXX_THROW_OR_ABORT(bad_array_new_length());
- return static_cast<_Up*>(allocate_bytes(__n * sizeof(_Up),
- alignof(_Up)));
- }
-
- template<typename _Up>
- void
- deallocate_object(_Up* __p, size_t __n = 1)
- { deallocate_bytes(__p, __n * sizeof(_Up), alignof(_Up)); }
-
- template<typename _Up, typename... _CtorArgs>
- [[nodiscard]] _Up*
- new_object(_CtorArgs&&... __ctor_args)
- {
- _Up* __p = allocate_object<_Up>();
- __try
- {
- construct(__p, std::forward<_CtorArgs>(__ctor_args)...);
- }
- __catch (...)
- {
- deallocate_object(__p);
- __throw_exception_again;
- }
- return __p;
- }
-
- template<typename _Up>
- void
- delete_object(_Up* __p)
- {
- destroy(__p);
- deallocate_object(__p);
- }
- #endif // C++2a
-
- #if __cplusplus == 201703L
- template<typename _Tp1, typename... _Args>
- __attribute__((__nonnull__))
- typename __not_pair<_Tp1>::type
- construct(_Tp1* __p, _Args&&... __args)
- {
- // _GLIBCXX_RESOLVE_LIB_DEFECTS
- // 2969. polymorphic_allocator::construct() shouldn't pass resource()
- using __use_tag
- = std::__uses_alloc_t<_Tp1, polymorphic_allocator, _Args...>;
- if constexpr (is_base_of_v<__uses_alloc0, __use_tag>)
- ::new(__p) _Tp1(std::forward<_Args>(__args)...);
- else if constexpr (is_base_of_v<__uses_alloc1_, __use_tag>)
- ::new(__p) _Tp1(allocator_arg, *this,
- std::forward<_Args>(__args)...);
- else
- ::new(__p) _Tp1(std::forward<_Args>(__args)..., *this);
- }
-
- template<typename _Tp1, typename _Tp2,
- typename... _Args1, typename... _Args2>
- __attribute__((__nonnull__))
- void
- construct(pair<_Tp1, _Tp2>* __p, piecewise_construct_t,
- tuple<_Args1...> __x, tuple<_Args2...> __y)
- {
- auto __x_tag =
- __use_alloc<_Tp1, polymorphic_allocator, _Args1...>(*this);
- auto __y_tag =
- __use_alloc<_Tp2, polymorphic_allocator, _Args2...>(*this);
- index_sequence_for<_Args1...> __x_i;
- index_sequence_for<_Args2...> __y_i;
-
- ::new(__p) pair<_Tp1, _Tp2>(piecewise_construct,
- _S_construct_p(__x_tag, __x_i, __x),
- _S_construct_p(__y_tag, __y_i, __y));
- }
-
- template<typename _Tp1, typename _Tp2>
- __attribute__((__nonnull__))
- void
- construct(pair<_Tp1, _Tp2>* __p)
- { this->construct(__p, piecewise_construct, tuple<>(), tuple<>()); }
-
- template<typename _Tp1, typename _Tp2, typename _Up, typename _Vp>
- __attribute__((__nonnull__))
- void
- construct(pair<_Tp1, _Tp2>* __p, _Up&& __x, _Vp&& __y)
- {
- this->construct(__p, piecewise_construct,
- forward_as_tuple(std::forward<_Up>(__x)),
- forward_as_tuple(std::forward<_Vp>(__y)));
- }
-
- template <typename _Tp1, typename _Tp2, typename _Up, typename _Vp>
- __attribute__((__nonnull__))
- void
- construct(pair<_Tp1, _Tp2>* __p, const std::pair<_Up, _Vp>& __pr)
- {
- this->construct(__p, piecewise_construct,
- forward_as_tuple(__pr.first),
- forward_as_tuple(__pr.second));
- }
-
- template<typename _Tp1, typename _Tp2, typename _Up, typename _Vp>
- __attribute__((__nonnull__))
- void
- construct(pair<_Tp1, _Tp2>* __p, pair<_Up, _Vp>&& __pr)
- {
- this->construct(__p, piecewise_construct,
- forward_as_tuple(std::forward<_Up>(__pr.first)),
- forward_as_tuple(std::forward<_Vp>(__pr.second)));
- }
- #else
- template<typename _Tp1, typename... _Args>
- __attribute__((__nonnull__))
- void
- construct(_Tp1* __p, _Args&&... __args)
- {
- std::uninitialized_construct_using_allocator(__p, *this,
- std::forward<_Args>(__args)...);
- }
- #endif
-
- template<typename _Up>
- __attribute__((__nonnull__))
- void
- destroy(_Up* __p)
- { __p->~_Up(); }
-
- polymorphic_allocator
- select_on_container_copy_construction() const noexcept
- { return polymorphic_allocator(); }
-
- memory_resource*
- resource() const noexcept
- __attribute__((__returns_nonnull__))
- { return _M_resource; }
-
- private:
- using __uses_alloc1_ = __uses_alloc1<polymorphic_allocator>;
- using __uses_alloc2_ = __uses_alloc2<polymorphic_allocator>;
-
- template<typename _Ind, typename... _Args>
- static tuple<_Args&&...>
- _S_construct_p(__uses_alloc0, _Ind, tuple<_Args...>& __t)
- { return std::move(__t); }
-
- template<size_t... _Ind, typename... _Args>
- static tuple<allocator_arg_t, polymorphic_allocator, _Args&&...>
- _S_construct_p(__uses_alloc1_ __ua, index_sequence<_Ind...>,
- tuple<_Args...>& __t)
- {
- return {
- allocator_arg, *__ua._M_a, std::get<_Ind>(std::move(__t))...
- };
- }
-
- template<size_t... _Ind, typename... _Args>
- static tuple<_Args&&..., polymorphic_allocator>
- _S_construct_p(__uses_alloc2_ __ua, index_sequence<_Ind...>,
- tuple<_Args...>& __t)
- { return { std::get<_Ind>(std::move(__t))..., *__ua._M_a }; }
-
- memory_resource* _M_resource;
- };
-
- template<typename _Tp1, typename _Tp2>
- inline bool
- operator==(const polymorphic_allocator<_Tp1>& __a,
- const polymorphic_allocator<_Tp2>& __b) noexcept
- { return *__a.resource() == *__b.resource(); }
-
- #if __cpp_impl_three_way_comparison < 201907L
- template<typename _Tp1, typename _Tp2>
- inline bool
- operator!=(const polymorphic_allocator<_Tp1>& __a,
- const polymorphic_allocator<_Tp2>& __b) noexcept
- { return !(__a == __b); }
- #endif
-
- /// Parameters for tuning a pool resource's behaviour.
- struct pool_options
- {
- /** @brief Upper limit on number of blocks in a chunk.
- *
- * A lower value prevents allocating huge chunks that could remain mostly
- * unused, but means pools will need to replenished more frequently.
- */
- size_t max_blocks_per_chunk = 0;
-
- /* @brief Largest block size (in bytes) that should be served from pools.
- *
- * Larger allocations will be served directly by the upstream resource,
- * not from one of the pools managed by the pool resource.
- */
- size_t largest_required_pool_block = 0;
- };
-
- // Common implementation details for un-/synchronized pool resources.
- class __pool_resource
- {
- friend class synchronized_pool_resource;
- friend class unsynchronized_pool_resource;
-
- __pool_resource(const pool_options& __opts, memory_resource* __upstream);
-
- ~__pool_resource();
-
- __pool_resource(const __pool_resource&) = delete;
- __pool_resource& operator=(const __pool_resource&) = delete;
-
- // Allocate a large unpooled block.
- void*
- allocate(size_t __bytes, size_t __alignment);
-
- // Deallocate a large unpooled block.
- void
- deallocate(void* __p, size_t __bytes, size_t __alignment);
-
-
- // Deallocate unpooled memory.
- void release() noexcept;
-
- memory_resource* resource() const noexcept
- { return _M_unpooled.get_allocator().resource(); }
-
- struct _Pool;
-
- _Pool* _M_alloc_pools();
-
- const pool_options _M_opts;
-
- struct _BigBlock;
- // Collection of blocks too big for any pool, sorted by address.
- // This also stores the only copy of the upstream memory resource pointer.
- _GLIBCXX_STD_C::pmr::vector<_BigBlock> _M_unpooled;
-
- const int _M_npools;
- };
-
- #ifdef _GLIBCXX_HAS_GTHREADS
- /// A thread-safe memory resource that manages pools of fixed-size blocks.
- class synchronized_pool_resource : public memory_resource
- {
- public:
- synchronized_pool_resource(const pool_options& __opts,
- memory_resource* __upstream)
- __attribute__((__nonnull__));
-
- synchronized_pool_resource()
- : synchronized_pool_resource(pool_options(), get_default_resource())
- { }
-
- explicit
- synchronized_pool_resource(memory_resource* __upstream)
- __attribute__((__nonnull__))
- : synchronized_pool_resource(pool_options(), __upstream)
- { }
-
- explicit
- synchronized_pool_resource(const pool_options& __opts)
- : synchronized_pool_resource(__opts, get_default_resource()) { }
-
- synchronized_pool_resource(const synchronized_pool_resource&) = delete;
-
- virtual ~synchronized_pool_resource();
-
- synchronized_pool_resource&
- operator=(const synchronized_pool_resource&) = delete;
-
- void release();
-
- memory_resource*
- upstream_resource() const noexcept
- __attribute__((__returns_nonnull__))
- { return _M_impl.resource(); }
-
- pool_options options() const noexcept { return _M_impl._M_opts; }
-
- protected:
- void*
- do_allocate(size_t __bytes, size_t __alignment) override;
-
- void
- do_deallocate(void* __p, size_t __bytes, size_t __alignment) override;
-
- bool
- do_is_equal(const memory_resource& __other) const noexcept override
- { return this == &__other; }
-
- public:
- // Thread-specific pools (only public for access by implementation details)
- struct _TPools;
-
- private:
- _TPools* _M_alloc_tpools(lock_guard<shared_mutex>&);
- _TPools* _M_alloc_shared_tpools(lock_guard<shared_mutex>&);
- auto _M_thread_specific_pools() noexcept;
-
- __pool_resource _M_impl;
- __gthread_key_t _M_key;
- // Linked list of thread-specific pools. All threads share _M_tpools[0].
- _TPools* _M_tpools = nullptr;
- mutable shared_mutex _M_mx;
- };
- #endif
-
- /// A non-thread-safe memory resource that manages pools of fixed-size blocks.
- class unsynchronized_pool_resource : public memory_resource
- {
- public:
- [[__gnu__::__nonnull__]]
- unsynchronized_pool_resource(const pool_options& __opts,
- memory_resource* __upstream);
-
- unsynchronized_pool_resource()
- : unsynchronized_pool_resource(pool_options(), get_default_resource())
- { }
-
- [[__gnu__::__nonnull__]]
- explicit
- unsynchronized_pool_resource(memory_resource* __upstream)
- : unsynchronized_pool_resource(pool_options(), __upstream)
- { }
-
- explicit
- unsynchronized_pool_resource(const pool_options& __opts)
- : unsynchronized_pool_resource(__opts, get_default_resource()) { }
-
- unsynchronized_pool_resource(const unsynchronized_pool_resource&) = delete;
-
- virtual ~unsynchronized_pool_resource();
-
- unsynchronized_pool_resource&
- operator=(const unsynchronized_pool_resource&) = delete;
-
- void release();
-
- [[__gnu__::__returns_nonnull__]]
- memory_resource*
- upstream_resource() const noexcept
- { return _M_impl.resource(); }
-
- pool_options options() const noexcept { return _M_impl._M_opts; }
-
- protected:
- void*
- do_allocate(size_t __bytes, size_t __alignment) override;
-
- void
- do_deallocate(void* __p, size_t __bytes, size_t __alignment) override;
-
- bool
- do_is_equal(const memory_resource& __other) const noexcept override
- { return this == &__other; }
-
- private:
- using _Pool = __pool_resource::_Pool;
-
- auto _M_find_pool(size_t) noexcept;
-
- __pool_resource _M_impl;
- _Pool* _M_pools = nullptr;
- };
-
- class monotonic_buffer_resource : public memory_resource
- {
- public:
- explicit
- monotonic_buffer_resource(memory_resource* __upstream) noexcept
- __attribute__((__nonnull__))
- : _M_upstream(__upstream)
- { _GLIBCXX_DEBUG_ASSERT(__upstream != nullptr); }
-
- monotonic_buffer_resource(size_t __initial_size,
- memory_resource* __upstream) noexcept
- __attribute__((__nonnull__))
- : _M_next_bufsiz(__initial_size),
- _M_upstream(__upstream)
- {
- _GLIBCXX_DEBUG_ASSERT(__upstream != nullptr);
- _GLIBCXX_DEBUG_ASSERT(__initial_size > 0);
- }
-
- monotonic_buffer_resource(void* __buffer, size_t __buffer_size,
- memory_resource* __upstream) noexcept
- __attribute__((__nonnull__(4)))
- : _M_current_buf(__buffer), _M_avail(__buffer_size),
- _M_next_bufsiz(_S_next_bufsize(__buffer_size)),
- _M_upstream(__upstream),
- _M_orig_buf(__buffer), _M_orig_size(__buffer_size)
- {
- _GLIBCXX_DEBUG_ASSERT(__upstream != nullptr);
- _GLIBCXX_DEBUG_ASSERT(__buffer != nullptr || __buffer_size == 0);
- }
-
- monotonic_buffer_resource() noexcept
- : monotonic_buffer_resource(get_default_resource())
- { }
-
- explicit
- monotonic_buffer_resource(size_t __initial_size) noexcept
- : monotonic_buffer_resource(__initial_size, get_default_resource())
- { }
-
- monotonic_buffer_resource(void* __buffer, size_t __buffer_size) noexcept
- : monotonic_buffer_resource(__buffer, __buffer_size, get_default_resource())
- { }
-
- monotonic_buffer_resource(const monotonic_buffer_resource&) = delete;
-
- virtual ~monotonic_buffer_resource(); // key function
-
- monotonic_buffer_resource&
- operator=(const monotonic_buffer_resource&) = delete;
-
- void
- release() noexcept
- {
- if (_M_head)
- _M_release_buffers();
-
- // reset to initial state at contruction:
- if ((_M_current_buf = _M_orig_buf))
- {
- _M_avail = _M_orig_size;
- _M_next_bufsiz = _S_next_bufsize(_M_orig_size);
- }
- else
- {
- _M_avail = 0;
- _M_next_bufsiz = _M_orig_size;
- }
- }
-
- memory_resource*
- upstream_resource() const noexcept
- __attribute__((__returns_nonnull__))
- { return _M_upstream; }
-
- protected:
- void*
- do_allocate(size_t __bytes, size_t __alignment) override
- {
- if (__bytes == 0)
- __bytes = 1; // Ensures we don't return the same pointer twice.
-
- void* __p = std::align(__alignment, __bytes, _M_current_buf, _M_avail);
- if (!__p)
- {
- _M_new_buffer(__bytes, __alignment);
- __p = _M_current_buf;
- }
- _M_current_buf = (char*)_M_current_buf + __bytes;
- _M_avail -= __bytes;
- return __p;
- }
-
- void
- do_deallocate(void*, size_t, size_t) override
- { }
-
- bool
- do_is_equal(const memory_resource& __other) const noexcept override
- { return this == &__other; }
-
- private:
- // Update _M_current_buf and _M_avail to refer to a new buffer with
- // at least the specified size and alignment, allocated from upstream.
- void
- _M_new_buffer(size_t __bytes, size_t __alignment);
-
- // Deallocate all buffers obtained from upstream.
- void
- _M_release_buffers() noexcept;
-
- static size_t
- _S_next_bufsize(size_t __buffer_size) noexcept
- {
- if (__buffer_size == 0)
- __buffer_size = 1;
- return __buffer_size * _S_growth_factor;
- }
-
- static constexpr size_t _S_init_bufsize = 128 * sizeof(void*);
- static constexpr float _S_growth_factor = 1.5;
-
- void* _M_current_buf = nullptr;
- size_t _M_avail = 0;
- size_t _M_next_bufsiz = _S_init_bufsize;
-
- // Initial values set at construction and reused by release():
- memory_resource* const _M_upstream;
- void* const _M_orig_buf = nullptr;
- size_t const _M_orig_size = _M_next_bufsiz;
-
- class _Chunk;
- _Chunk* _M_head = nullptr;
- };
-
- } // namespace pmr
- _GLIBCXX_END_NAMESPACE_VERSION
- } // namespace std
-
- #endif // C++17
- #endif // _GLIBCXX_MEMORY_RESOURCE
|