summaryrefslogtreecommitdiffstatshomepage
path: root/src/lib/netlist/core/queue.h
blob: 19600f0198c5ea537d034d57dc978ba7dc619339 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
// license:BSD-3-Clause
// copyright-holders:Couriersud

///
/// \file queue.h
///

#ifndef NL_CORE_QUEUE_H_
#define NL_CORE_QUEUE_H_

#include "queue.h"

#include "../nl_errstr.h"
#include "../nltypes.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_