diff options
Diffstat (limited to 'src/lib/netlist/core/queue.h')
-rw-r--r-- | src/lib/netlist/core/queue.h | 107 |
1 files changed, 107 insertions, 0 deletions
diff --git a/src/lib/netlist/core/queue.h b/src/lib/netlist/core/queue.h new file mode 100644 index 00000000000..9fdd6ac1c64 --- /dev/null +++ b/src/lib/netlist/core/queue.h @@ -0,0 +1,107 @@ +// license:BSD-3-Clause +// copyright-holders:Couriersud + +/// +/// \file queue.h +/// + +#ifndef NL_CORE_QUEUE_H_ +#define NL_CORE_QUEUE_H_ + +#include "../nl_errstr.h" +#include "../nltypes.h" +#include "queue.h" + +#include "../plib/pstate.h" +#include "../plib/pstring.h" +#include "../plib/ptimed_queue.h" + +#include <array> +#include <queue> +#include <unordered_map> +#include <utility> +#include <vector> + +namespace netlist::detail +{ + // ----------------------------------------------------------------------------- + // queue_t + // ----------------------------------------------------------------------------- + + // We don't need a thread-safe queue currently. Parallel processing of + // solvers will update inputs after parallel processing. + + template <typename A, typename O> + class queue_base + : public config::timed_queue<A, plib::queue_entry_t<netlist_time_ext, O *>> + , public plib::state_manager_t::callback_t + { + public: + using entry_t = plib::queue_entry_t<netlist_time_ext, O *>; + using base_queue = config::timed_queue<A, entry_t>; + using id_delegate = plib::pmfp<std::size_t(const O *)>; + using obj_delegate = plib::pmfp<O *(std::size_t)>; + + explicit queue_base(A &arena, std::size_t size, id_delegate get_id, + obj_delegate get_obj) + : base_queue(arena, size) + , m_size(0) + , m_times(size) + , m_net_ids(size) + , m_get_id(get_id) + , m_obj_by_id(get_obj) + { + } + + ~queue_base() noexcept override = default; + + queue_base(const queue_base &) = delete; + queue_base(queue_base &&) = delete; + queue_base &operator=(const queue_base &) = delete; + queue_base &operator=(queue_base &&) = delete; + + protected: + void register_state(plib::state_manager_t &manager, + const pstring & module) override + { + manager.save_item(this, m_size, module + "." + "size"); + manager.save_item(this, &m_times[0], module + "." + "times", + m_times.size()); + manager.save_item(this, &m_net_ids[0], module + "." + "names", + m_net_ids.size()); + } + void on_pre_save( + [[maybe_unused]] plib::state_manager_t &manager) override + { + m_size = this->size(); + for (std::size_t i = 0; i < m_size; i++) + { + m_times[i] = this->list_pointer()[i].exec_time().as_raw(); + m_net_ids[i] = m_get_id(this->list_pointer()[i].object()); + } + } + void on_post_load( + [[maybe_unused]] plib::state_manager_t &manager) override + { + this->clear(); + for (std::size_t i = 0; i < m_size; i++) + { + O *n = m_obj_by_id(m_net_ids[i]); + this->template push<false>( + entry_t(netlist_time_ext::from_raw(m_times[i]), n)); + } + } + + private: + std::size_t m_size; + std::vector<netlist_time_ext::internal_type> m_times; + std::vector<std::size_t> m_net_ids; + id_delegate m_get_id; + obj_delegate m_obj_by_id; + }; + + using queue_t = queue_base<device_arena, net_t>; + +} // namespace netlist::detail + +#endif // NL_CORE_QUEUE_H_ |