diff options
Diffstat (limited to 'src/lib/netlist/core/queue.h')
-rw-r--r-- | src/lib/netlist/core/queue.h | 50 |
1 files changed, 27 insertions, 23 deletions
diff --git a/src/lib/netlist/core/queue.h b/src/lib/netlist/core/queue.h index 19600f0198c..9fdd6ac1c64 100644 --- a/src/lib/netlist/core/queue.h +++ b/src/lib/netlist/core/queue.h @@ -8,10 +8,9 @@ #ifndef NL_CORE_QUEUE_H_ #define NL_CORE_QUEUE_H_ -#include "queue.h" - #include "../nl_errstr.h" #include "../nltypes.h" +#include "queue.h" #include "../plib/pstate.h" #include "../plib/pstring.h" @@ -33,17 +32,18 @@ namespace netlist::detail // 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 + 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)>; + 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) + 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) @@ -61,43 +61,47 @@ namespace netlist::detail queue_base &operator=(queue_base &&) = delete; protected: - - void register_state(plib::state_manager_t &manager, const pstring &module) override + 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()); + 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 + 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++ ) + for (std::size_t i = 0; i < m_size; i++) { - m_times[i] = this->list_pointer()[i].exec_time().as_raw(); + 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 + void on_post_load( + [[maybe_unused]] plib::state_manager_t &manager) override { this->clear(); - for (std::size_t i = 0; i < m_size; i++ ) + 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)); + this->template push<false>( + entry_t(netlist_time_ext::from_raw(m_times[i]), n)); } } private: - std::size_t m_size; + 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; + 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_ |