pdu_buffer_pool.cpp

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#include <kcenon/pacs/network/pdu_buffer_pool.h>
#include <kcenon/pacs/network/pdu_decoder.h>
 
namespace kcenon::pacs::network {
 
// ============================================================================
// pdu_buffer_pool Implementation
// ============================================================================
 
pdu_buffer_pool::pdu_buffer_pool()
    : buffer_pool_(DEFAULT_BUFFER_POOL_SIZE)
    , pdv_pool_(DEFAULT_PDV_POOL_SIZE)
    , p_data_pool_(DEFAULT_PDATA_POOL_SIZE) {}
 
auto pdu_buffer_pool::get() noexcept -> pdu_buffer_pool& {
    static pdu_buffer_pool instance;
    return instance;
}
 
auto pdu_buffer_pool::acquire_buffer()
    -> tracked_pdu_pool<pooled_buffer>::unique_ptr_type {
    auto buffer = buffer_pool_.acquire();
    buffer->clear();  // Reset buffer state for reuse
    return buffer;
}
 
auto pdu_buffer_pool::acquire_pdv(uint8_t context_id, bool is_command,
                                   bool is_last)
    -> tracked_pdu_pool<presentation_data_value>::unique_ptr_type {
    auto pdv = pdv_pool_.acquire();
    pdv->context_id = context_id;
    pdv->is_command = is_command;
    pdv->is_last = is_last;
    pdv->data.clear();  // Reset data vector for reuse
    return pdv;
}
 
auto pdu_buffer_pool::acquire_p_data_tf()
    -> tracked_pdu_pool<p_data_tf_pdu>::unique_ptr_type {
    auto p_data = p_data_pool_.acquire();
    p_data->pdvs.clear();  // Reset PDV vector for reuse
    return p_data;
}
 
auto pdu_buffer_pool::buffer_statistics() const noexcept
    -> const pdu_pool_statistics& {
    return buffer_pool_.statistics();
}
 
auto pdu_buffer_pool::pdv_statistics() const noexcept
    -> const pdu_pool_statistics& {
    return pdv_pool_.statistics();
}
 
auto pdu_buffer_pool::p_data_statistics() const noexcept
    -> const pdu_pool_statistics& {
    return p_data_pool_.statistics();
}
 
void pdu_buffer_pool::reserve_buffers(std::size_t count) {
    buffer_pool_.reserve(count);
}
 
void pdu_buffer_pool::reserve_pdvs(std::size_t count) {
    pdv_pool_.reserve(count);
}
 
void pdu_buffer_pool::clear_all() {
    buffer_pool_.clear();
    pdv_pool_.clear();
    p_data_pool_.clear();
}
 
void pdu_buffer_pool::reset_statistics() {
    const_cast<pdu_pool_statistics&>(buffer_pool_.statistics()).reset();
    const_cast<pdu_pool_statistics&>(pdv_pool_.statistics()).reset();
    const_cast<pdu_pool_statistics&>(p_data_pool_.statistics()).reset();
}
 
}  // namespace kcenon::pacs::network