Index/include / boost / corosio / detail / intrusive.hpp

include/boost/corosio/detail/intrusive.hpp

96.1% Lines (73/76) 100.0% List of functions (82/84) 37.6% Branches (231/614)
[ ] prev/next file n p prev/next uncovered line
intrusive.hpp
f(x) Functions (84)
Function Calls Lines Branches Blocks
<unknown function 43> :43 – – – – boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_datagram_socket>::intrusive_list() :47 1326x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_acceptor>::intrusive_list() :47 1326x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_socket>::intrusive_list() :47 1326x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_acceptor>::intrusive_list() :47 1326x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_socket>::intrusive_list() :47 1326x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_udp_socket>::intrusive_list() :47 1326x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file::raf_op>::intrusive_list() :47 86x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file>::intrusive_list() :47 2184x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_resolver>::intrusive_list() :47 2184x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_signal>::intrusive_list() :47 2184x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_stream_file>::intrusive_list() :47 2184x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_datagram_socket>::intrusive_list() :47 858x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_acceptor>::intrusive_list() :47 858x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_socket>::intrusive_list() :47 858x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_acceptor>::intrusive_list() :47 858x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_socket>::intrusive_list() :47 858x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_udp_socket>::intrusive_list() :47 858x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::waiter_node>::intrusive_list() :47 1914836x 0.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::waiter_node>::empty() const :61 38x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_datagram_socket>::push_back(boost::corosio::detail::kqueue_local_datagram_socket*) :72 63x 100.0% 40.4% 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_acceptor>::push_back(boost::corosio::detail::kqueue_local_stream_acceptor*) :72 22x 100.0% – 62.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_socket>::push_back(boost::corosio::detail::kqueue_local_stream_socket*) :72 68x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_acceptor>::push_back(boost::corosio::detail::kqueue_tcp_acceptor*) :72 827x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_socket>::push_back(boost::corosio::detail::kqueue_tcp_socket*) :72 11676x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_udp_socket>::push_back(boost::corosio::detail::kqueue_udp_socket*) :72 91x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file::raf_op>::push_back(boost::corosio::detail::posix_random_access_file::raf_op*) :72 150x 100.0% 66.7% 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file>::push_back(boost::corosio::detail::posix_random_access_file*) :72 43x 100.0% – 62.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_resolver>::push_back(boost::corosio::detail::posix_resolver*) :72 42x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_signal>::push_back(boost::corosio::detail::posix_signal*) :72 104x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_stream_file>::push_back(boost::corosio::detail::posix_stream_file*) :72 43x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_datagram_socket>::push_back(boost::corosio::detail::select_local_datagram_socket*) :72 63x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_acceptor>::push_back(boost::corosio::detail::select_local_stream_acceptor*) :72 22x 100.0% – 62.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_socket>::push_back(boost::corosio::detail::select_local_stream_socket*) :72 68x 81.8% 66.7% 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_acceptor>::push_back(boost::corosio::detail::select_tcp_acceptor*) :72 110x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_socket>::push_back(boost::corosio::detail::select_tcp_socket*) :72 5642x 100.0% 66.7% 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_udp_socket>::push_back(boost::corosio::detail::select_udp_socket*) :72 91x 100.0% – 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::waiter_node>::push_back(boost::corosio::detail::waiter_node*) :72 11708x 100.0% 100.0% 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_datagram_socket>::pop_front() :103 663x 100.0% 12.2% 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_acceptor>::pop_front() :103 663x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_socket>::pop_front() :103 663x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_acceptor>::pop_front() :103 663x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_socket>::pop_front() :103 663x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_udp_socket>::pop_front() :103 663x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file>::pop_front() :103 1092x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_resolver>::pop_front() :103 1092x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_signal>::pop_front() :103 1092x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_stream_file>::pop_front() :103 1092x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_datagram_socket>::pop_front() :103 429x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_acceptor>::pop_front() :103 429x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_socket>::pop_front() :103 429x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_acceptor>::pop_front() :103 429x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_socket>::pop_front() :103 429x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_udp_socket>::pop_front() :103 429x 100.0% – 23.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::waiter_node>::pop_front() :103 974547x 0.0% 0.0% 100.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_datagram_socket>::remove(boost::corosio::detail::kqueue_local_datagram_socket*) :121 63x 92.3% 46.2% 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_acceptor>::remove(boost::corosio::detail::kqueue_local_stream_acceptor*) :121 22x 100.0% – 57.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_local_stream_socket>::remove(boost::corosio::detail::kqueue_local_stream_socket*) :121 68x 100.0% – 89.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_acceptor>::remove(boost::corosio::detail::kqueue_tcp_acceptor*) :121 827x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_tcp_socket>::remove(boost::corosio::detail::kqueue_tcp_socket*) :121 11676x 100.0% – 89.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::kqueue_udp_socket>::remove(boost::corosio::detail::kqueue_udp_socket*) :121 91x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file::raf_op>::remove(boost::corosio::detail::posix_random_access_file::raf_op*) :121 150x 84.6% 50.0% 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file>::remove(boost::corosio::detail::posix_random_access_file*) :121 43x 100.0% – 57.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_resolver>::remove(boost::corosio::detail::posix_resolver*) :121 42x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_signal>::remove(boost::corosio::detail::posix_signal*) :121 104x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_stream_file>::remove(boost::corosio::detail::posix_stream_file*) :121 43x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_datagram_socket>::remove(boost::corosio::detail::select_local_datagram_socket*) :121 63x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_acceptor>::remove(boost::corosio::detail::select_local_stream_acceptor*) :121 22x 100.0% – 57.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_local_stream_socket>::remove(boost::corosio::detail::select_local_stream_socket*) :121 68x 100.0% – 89.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_acceptor>::remove(boost::corosio::detail::select_tcp_acceptor*) :121 110x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_tcp_socket>::remove(boost::corosio::detail::select_tcp_socket*) :121 5642x 100.0% – 89.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::select_udp_socket>::remove(boost::corosio::detail::select_udp_socket*) :121 91x 100.0% – 73.0% boost::corosio::detail::intrusive_list<boost::corosio::detail::waiter_node>::remove(boost::corosio::detail::waiter_node*) :121 36x 84.6% 58.3% 76.0% void boost::corosio::detail::intrusive_list<boost::corosio::detail::posix_random_access_file::raf_op>::for_each<boost::corosio::detail::posix_random_access_file::cancel()::'lambda'(boost::corosio::detail::posix_random_access_file::raf_op*)>(boost::corosio::detail::posix_random_access_file::cancel()::'lambda'(boost::corosio::detail::posix_random_access_file::raf_op*)) :141 122x 50.0% 25.0% 42.0% <unknown function 179> :179 – – – – boost::corosio::detail::intrusive_queue<boost::corosio::detail::pool_work_item>::intrusive_queue() :183 2188x 100.0% – 100.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::scheduler_op>::intrusive_queue() :183 3944904x 100.0% – 100.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::pool_work_item>::empty() const :197 1094x 100.0% – 100.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::scheduler_op>::empty() const :197 7465299x 100.0% – 100.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::pool_work_item>::push(boost::corosio::detail::pool_work_item*) :202 217x 100.0% 50.0% 100.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::scheduler_op>::push(boost::corosio::detail::scheduler_op*) :202 2271867x 100.0% 100.0% 100.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::scheduler_op>::splice(boost::corosio::detail::intrusive_queue<boost::corosio::detail::scheduler_op>&) :212 1138953x 90.0% 75.0% 85.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::pool_work_item>::pop() :225 2413x 100.0% 100.0% 100.0% boost::corosio::detail::intrusive_queue<boost::corosio::detail::scheduler_op>::pop() :225 3200976x 100.0% 50.0% 100.0%
Line Branch TLA Hits Source Code
1 //
2 // Copyright (c) 2025 Vinnie Falco ([email protected])
3 //
4 // Distributed under the Boost Software License, Version 1.0. (See accompanying
5 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6 //
7 // Official repository: https://github.com/cppalliance/corosio
8 //
9
10 #ifndef BOOST_COROSIO_DETAIL_INTRUSIVE_HPP
11 #define BOOST_COROSIO_DETAIL_INTRUSIVE_HPP
12
13 namespace boost::corosio::detail {
14
15 /** An intrusive doubly linked list.
16
17 This container provides O(1) push and pop operations for
18 elements that derive from @ref node. Elements are not
19 copied or moved; they are linked directly into the list.
20
21 @tparam T The element type. Must derive from `intrusive_list<T>::node`.
22 */
23 template<class T>
24 class intrusive_list
25 {
26 public:
27 /** Base class for list elements.
28
29 Derive from this class to make a type usable with
30 @ref intrusive_list. The `next_` and `prev_` pointers
31 are private and accessible only to the list.
32 */
33 class node
34 {
35 friend class intrusive_list;
36
37 private:
38 T* next_;
39 T* prev_;
40 };
41
42 private:
43 968381x T* head_ = nullptr;
44 968381x T* tail_ = nullptr;
45
46 public:
47 2905143x intrusive_list() = default;
48
49 intrusive_list(intrusive_list&& other) noexcept
50 : head_(other.head_)
51 , tail_(other.tail_)
52 {
53 other.head_ = nullptr;
54 other.tail_ = nullptr;
55 }
56
57 intrusive_list(intrusive_list const&) = delete;
58 intrusive_list& operator=(intrusive_list const&) = delete;
59 intrusive_list& operator=(intrusive_list&&) = delete;
60
61 38x bool empty() const noexcept
62 {
63 38x return head_ == nullptr;
64 }
65
66 /// Peek at the head element without removing it.
67 T* front() const noexcept
68 {
69 return head_;
70 }
71
72 30833x void push_back(T* w) noexcept
73 {
74
12/34
✗ Branch 0 not taken.
✓ Branch 1 taken 11936 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5814 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 43 times.
✗ Branch 6 not taken.
✓ Branch 7 taken 43 times.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✓ Branch 13 taken 110 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 91 times.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✓ Branch 19 taken 22 times.
✗ Branch 20 not taken.
✓ Branch 21 taken 63 times.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✓ Branch 25 taken 827 times.
✗ Branch 26 not taken.
✓ Branch 27 taken 91 times.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 30 not taken.
✓ Branch 31 taken 22 times.
✗ Branch 32 not taken.
✓ Branch 33 taken 63 times.
 30833x auto* n = static_cast<node*>(w);
75 30833x n->next_ = nullptr;
76 30833x n->prev_ = tail_;
77
23/36
✓ Branch 0 taken 11048 times.
✓ Branch 1 taken 12554 times.
✓ Branch 2 taken 5560 times.
✓ Branch 3 taken 192 times.
✓ Branch 4 taken 10 times.
✓ Branch 5 taken 94 times.
✓ Branch 6 taken 1 time.
✓ Branch 7 taken 42 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 43 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✓ Branch 14 taken 7 times.
✓ Branch 15 taken 103 times.
✓ Branch 16 taken 24 times.
✓ Branch 17 taken 67 times.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✓ Branch 21 taken 22 times.
✓ Branch 22 taken 22 times.
✓ Branch 23 taken 41 times.
✗ Branch 24 not taken.
✗ Branch 25 not taken.
✓ Branch 26 taken 9 times.
✓ Branch 27 taken 818 times.
✓ Branch 28 taken 24 times.
✓ Branch 29 taken 67 times.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✓ Branch 33 taken 22 times.
✓ Branch 34 taken 22 times.
✓ Branch 35 taken 41 times.
 30833x if (tail_)
78
11/38
✗ Branch 0 not taken.
✗ Branch 0 not taken.
✓ Branch 1 taken 11001 times.
✓ Branch 1 taken 1 time.
✗ Branch 2 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 5559 times.
✓ Branch 3 taken 10 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1 time.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✓ Branch 13 taken 7 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 24 times.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✓ Branch 21 taken 22 times.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✓ Branch 25 taken 9 times.
✗ Branch 26 not taken.
✓ Branch 27 taken 24 times.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✓ Branch 33 taken 22 times.
 16727x static_cast<node*>(tail_)->next_ = w;
79 else
80 14106x head_ = w;
81 30833x tail_ = w;
82 30833x }
83
84 void splice_back(intrusive_list& other) noexcept
85 {
86 if (other.empty())
87 return;
88 if (tail_)
89 {
90 static_cast<node*>(tail_)->next_ = other.head_;
91 static_cast<node*>(other.head_)->prev_ = tail_;
92 tail_ = other.tail_;
93 }
94 else
95 {
96 head_ = other.head_;
97 tail_ = other.tail_;
98 }
99 other.head_ = nullptr;
100 other.tail_ = nullptr;
101 }
102
103 985467x T* pop_front() noexcept
104 {
105
18/34
✓ Branch 0 taken 11672 times.
✓ Branch 1 taken 962875 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 1092 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1092 times.
✗ Branch 6 not taken.
✓ Branch 7 taken 1092 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 1092 times.
✗ Branch 10 not taken.
✓ Branch 11 taken 429 times.
✗ Branch 12 not taken.
✓ Branch 13 taken 429 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 429 times.
✗ Branch 16 not taken.
✓ Branch 17 taken 429 times.
✗ Branch 18 not taken.
✓ Branch 19 taken 429 times.
✗ Branch 20 not taken.
✓ Branch 21 taken 429 times.
✗ Branch 22 not taken.
✓ Branch 23 taken 663 times.
✗ Branch 24 not taken.
✓ Branch 25 taken 663 times.
✗ Branch 26 not taken.
✓ Branch 27 taken 663 times.
✗ Branch 28 not taken.
✓ Branch 29 taken 663 times.
✗ Branch 30 not taken.
✓ Branch 31 taken 663 times.
✗ Branch 32 not taken.
✓ Branch 33 taken 663 times.
 985467x if (!head_)
106 973795x return nullptr;
107 11672x T* w = head_;
108
0/32
✗ Branch 0 not taken.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✗ Branch 25 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
 11672x head_ = static_cast<node*>(head_)->next_;
109
2/34
✓ Branch 0 taken 45 times.
✓ Branch 1 taken 11627 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✗ Branch 25 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✗ Branch 33 not taken.
 11672x if (head_)
110
0/32
✗ Branch 0 not taken.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✗ Branch 25 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
 45x static_cast<node*>(head_)->prev_ = nullptr;
111 else
112 11627x tail_ = nullptr;
113 // Defensive: clear stale linkage so remove() on a
114 // popped node cannot corrupt the list.
115
0/32
✗ Branch 0 not taken.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✗ Branch 25 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
 11672x auto* n = static_cast<node*>(w);
116 11672x n->next_ = nullptr;
117 11672x n->prev_ = nullptr;
118 11672x return w;
119 985467x }
120
121 19161x void remove(T* w) noexcept
122 {
123
16/34
✗ Branch 0 not taken.
✓ Branch 1 taken 192 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 104 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 43 times.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✓ Branch 9 taken 43 times.
✗ Branch 10 not taken.
✓ Branch 11 taken 5642 times.
✗ Branch 12 not taken.
✓ Branch 13 taken 110 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 91 times.
✗ Branch 16 not taken.
✓ Branch 17 taken 68 times.
✗ Branch 18 not taken.
✓ Branch 19 taken 22 times.
✗ Branch 20 not taken.
✓ Branch 21 taken 63 times.
✗ Branch 22 not taken.
✓ Branch 23 taken 11676 times.
✗ Branch 24 not taken.
✓ Branch 25 taken 827 times.
✗ Branch 26 not taken.
✓ Branch 27 taken 91 times.
✗ Branch 28 not taken.
✓ Branch 29 taken 68 times.
✗ Branch 30 not taken.
✓ Branch 31 taken 22 times.
✗ Branch 32 not taken.
✓ Branch 33 taken 63 times.
 19161x auto* n = static_cast<node*>(w);
124 // Already detached — nothing to do.
125
69/144
✓ Branch 0 taken 63 times.
✓ Branch 1 taken 123 times.
✓ Branch 2 taken 63 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 63 times.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 42 times.
✗ Branch 9 not taken.
✓ Branch 10 taken 41 times.
✓ Branch 11 taken 1 time.
✗ Branch 12 not taken.
✓ Branch 13 taken 41 times.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✓ Branch 16 taken 104 times.
✗ Branch 17 not taken.
✓ Branch 18 taken 94 times.
✓ Branch 19 taken 10 times.
✗ Branch 20 not taken.
✓ Branch 21 taken 94 times.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✓ Branch 24 taken 43 times.
✗ Branch 25 not taken.
✓ Branch 26 taken 42 times.
✓ Branch 27 taken 1 time.
✗ Branch 28 not taken.
✓ Branch 29 taken 42 times.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✗ Branch 33 not taken.
✗ Branch 34 not taken.
✗ Branch 35 not taken.
✗ Branch 36 not taken.
✗ Branch 37 not taken.
✗ Branch 38 not taken.
✗ Branch 39 not taken.
✓ Branch 40 taken 43 times.
✗ Branch 41 not taken.
✓ Branch 42 taken 43 times.
✗ Branch 43 not taken.
✗ Branch 44 not taken.
✓ Branch 45 taken 43 times.
✗ Branch 46 not taken.
✗ Branch 47 not taken.
✓ Branch 48 taken 1920 times.
✓ Branch 49 taken 3722 times.
✓ Branch 50 taken 112 times.
✓ Branch 51 taken 1808 times.
✗ Branch 52 not taken.
✓ Branch 53 taken 112 times.
✗ Branch 54 not taken.
✗ Branch 55 not taken.
✓ Branch 56 taken 110 times.
✗ Branch 57 not taken.
✓ Branch 58 taken 103 times.
✓ Branch 59 taken 7 times.
✗ Branch 60 not taken.
✓ Branch 61 taken 103 times.
✗ Branch 62 not taken.
✗ Branch 63 not taken.
✓ Branch 64 taken 91 times.
✗ Branch 65 not taken.
✓ Branch 66 taken 67 times.
✓ Branch 67 taken 24 times.
✗ Branch 68 not taken.
✓ Branch 69 taken 67 times.
✗ Branch 70 not taken.
✗ Branch 71 not taken.
✓ Branch 72 taken 56 times.
✓ Branch 73 taken 12 times.
✓ Branch 74 taken 39 times.
✓ Branch 75 taken 17 times.
✗ Branch 76 not taken.
✓ Branch 77 taken 39 times.
✗ Branch 78 not taken.
✗ Branch 79 not taken.
✓ Branch 80 taken 22 times.
✗ Branch 81 not taken.
✓ Branch 82 taken 22 times.
✗ Branch 83 not taken.
✗ Branch 84 not taken.
✓ Branch 85 taken 22 times.
✗ Branch 86 not taken.
✗ Branch 87 not taken.
✓ Branch 88 taken 63 times.
✗ Branch 89 not taken.
✓ Branch 90 taken 41 times.
✓ Branch 91 taken 22 times.
✗ Branch 92 not taken.
✓ Branch 93 taken 41 times.
✗ Branch 94 not taken.
✗ Branch 95 not taken.
✓ Branch 96 taken 3950 times.
✓ Branch 97 taken 7726 times.
✓ Branch 98 taken 825 times.
✓ Branch 99 taken 3125 times.
✗ Branch 100 not taken.
✓ Branch 101 taken 825 times.
✗ Branch 102 not taken.
✗ Branch 103 not taken.
✓ Branch 104 taken 827 times.
✗ Branch 105 not taken.
✓ Branch 106 taken 818 times.
✓ Branch 107 taken 9 times.
✗ Branch 108 not taken.
✓ Branch 109 taken 818 times.
✗ Branch 110 not taken.
✗ Branch 111 not taken.
✓ Branch 112 taken 91 times.
✗ Branch 113 not taken.
✓ Branch 114 taken 67 times.
✓ Branch 115 taken 24 times.
✗ Branch 116 not taken.
✓ Branch 117 taken 67 times.
✗ Branch 118 not taken.
✗ Branch 119 not taken.
✓ Branch 120 taken 56 times.
✓ Branch 121 taken 12 times.
✓ Branch 122 taken 39 times.
✓ Branch 123 taken 17 times.
✗ Branch 124 not taken.
✓ Branch 125 taken 39 times.
✗ Branch 126 not taken.
✗ Branch 127 not taken.
✓ Branch 128 taken 22 times.
✗ Branch 129 not taken.
✓ Branch 130 taken 22 times.
✗ Branch 131 not taken.
✗ Branch 132 not taken.
✓ Branch 133 taken 22 times.
✗ Branch 134 not taken.
✗ Branch 135 not taken.
✓ Branch 136 taken 63 times.
✗ Branch 137 not taken.
✓ Branch 138 taken 41 times.
✓ Branch 139 taken 22 times.
✗ Branch 140 not taken.
✓ Branch 141 taken 41 times.
✗ Branch 142 not taken.
✗ Branch 143 not taken.
 19161x if (!n->next_ && !n->prev_ && head_ != w && tail_ != w)
126 ✗ return;
127
30/36
✗ Branch 0 not taken.
✓ Branch 1 taken 186 times.
✓ Branch 2 taken 1 time.
✓ Branch 3 taken 41 times.
✓ Branch 4 taken 10 times.
✓ Branch 5 taken 94 times.
✓ Branch 6 taken 1 time.
✓ Branch 7 taken 42 times.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 43 times.
✓ Branch 12 taken 1828 times.
✓ Branch 13 taken 3814 times.
✓ Branch 14 taken 7 times.
✓ Branch 15 taken 103 times.
✓ Branch 16 taken 24 times.
✓ Branch 17 taken 67 times.
✓ Branch 18 taken 17 times.
✓ Branch 19 taken 51 times.
✗ Branch 20 not taken.
✓ Branch 21 taken 22 times.
✓ Branch 22 taken 22 times.
✓ Branch 23 taken 41 times.
✓ Branch 24 taken 3208 times.
✓ Branch 25 taken 8468 times.
✓ Branch 26 taken 9 times.
✓ Branch 27 taken 818 times.
✓ Branch 28 taken 24 times.
✓ Branch 29 taken 67 times.
✓ Branch 30 taken 17 times.
✓ Branch 31 taken 51 times.
✗ Branch 32 not taken.
✓ Branch 33 taken 22 times.
✓ Branch 34 taken 22 times.
✓ Branch 35 taken 41 times.
 19161x if (n->prev_)
128
13/36
✗ Branch 0 not taken.
✗ Branch 0 not taken.
✗ Branch 1 not taken.
✓ Branch 1 taken 1 time.
✗ Branch 2 not taken.
✓ Branch 3 taken 10 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1 time.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 1828 times.
✗ Branch 12 not taken.
✓ Branch 13 taken 7 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 24 times.
✗ Branch 16 not taken.
✓ Branch 17 taken 17 times.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✓ Branch 21 taken 22 times.
✗ Branch 22 not taken.
✓ Branch 23 taken 3208 times.
✗ Branch 24 not taken.
✓ Branch 25 taken 9 times.
✗ Branch 26 not taken.
✓ Branch 27 taken 24 times.
✗ Branch 28 not taken.
✓ Branch 29 taken 17 times.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✓ Branch 33 taken 22 times.
 5190x static_cast<node*>(n->prev_)->next_ = n->next_;
129 else
130 13971x head_ = n->next_;
131
22/36
✓ Branch 0 taken 123 times.
✓ Branch 1 taken 63 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 42 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 104 times.
✗ Branch 6 not taken.
✓ Branch 7 taken 43 times.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 43 times.
✓ Branch 12 taken 3722 times.
✓ Branch 13 taken 1920 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 110 times.
✗ Branch 16 not taken.
✓ Branch 17 taken 91 times.
✓ Branch 18 taken 12 times.
✓ Branch 19 taken 56 times.
✗ Branch 20 not taken.
✓ Branch 21 taken 22 times.
✗ Branch 22 not taken.
✓ Branch 23 taken 63 times.
✓ Branch 24 taken 7726 times.
✓ Branch 25 taken 3950 times.
✗ Branch 26 not taken.
✓ Branch 27 taken 827 times.
✗ Branch 28 not taken.
✓ Branch 29 taken 91 times.
✓ Branch 30 taken 12 times.
✓ Branch 31 taken 56 times.
✗ Branch 32 not taken.
✓ Branch 33 taken 22 times.
✗ Branch 34 not taken.
✓ Branch 35 taken 63 times.
 19161x if (n->next_)
132
5/36
✗ Branch 0 not taken.
✗ Branch 0 not taken.
✓ Branch 1 taken 121 times.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 3722 times.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✓ Branch 17 taken 12 times.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
✓ Branch 23 taken 7726 times.
✗ Branch 24 not taken.
✗ Branch 25 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
✗ Branch 28 not taken.
✓ Branch 29 taken 12 times.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✗ Branch 33 not taken.
 11595x static_cast<node*>(n->next_)->prev_ = n->prev_;
133 else
134 7566x tail_ = n->prev_;
135 19161x n->next_ = nullptr;
136 19161x n->prev_ = nullptr;
137 19161x }
138
139 /// Invoke @p f for each element in the list.
140 template<class F>
141 122x void for_each(F f)
142 {
143
1/4
✗ Branch 0 not taken.
✓ Branch 1 taken 122 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
 122x for (T* p = head_; p; p = static_cast<node*>(p)->next_)
144 ✗ f(p);
145 122x }
146 };
147
148 /** An intrusive singly linked FIFO queue.
149
150 This container provides O(1) push and pop operations for
151 elements that derive from @ref node. Elements are not
152 copied or moved; they are linked directly into the queue.
153
154 Unlike @ref intrusive_list, this uses only a single `next_`
155 pointer per node, saving memory at the cost of not supporting
156 O(1) removal of arbitrary elements.
157
158 @tparam T The element type. Must derive from `intrusive_queue<T>::node`.
159 */
160 template<class T>
161 class intrusive_queue
162 {
163 public:
164 /** Base class for queue elements.
165
166 Derive from this class to make a type usable with
167 @ref intrusive_queue. The `next_` pointer is private
168 and accessible only to the queue.
169 */
170 class node
171 {
172 friend class intrusive_queue;
173
174 private:
175 T* next_;
176 };
177
178 private:
179 1973546x T* head_ = nullptr;
180 1973546x T* tail_ = nullptr;
181
182 public:
183 5920638x intrusive_queue() = default;
184
185 intrusive_queue(intrusive_queue&& other) noexcept
186 : head_(other.head_)
187 , tail_(other.tail_)
188 {
189 other.head_ = nullptr;
190 other.tail_ = nullptr;
191 }
192
193 intrusive_queue(intrusive_queue const&) = delete;
194 intrusive_queue& operator=(intrusive_queue const&) = delete;
195 intrusive_queue& operator=(intrusive_queue&&) = delete;
196
197 7466393x bool empty() const noexcept
198 {
199 7466393x return head_ == nullptr;
200 }
201
202 2272084x void push(T* w) noexcept
203 {
204 2272084x w->next_ = nullptr;
205
2/4
✓ Branch 0 taken 1040899 times.
✓ Branch 1 taken 1231185 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
 2272084x if (tail_)
206 1040899x tail_->next_ = w;
207 else
208 1231185x head_ = w;
209 2272084x tail_ = w;
210 2272084x }
211
212 1138953x void splice(intrusive_queue& other) noexcept
213 {
214
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1138953 times.
 1138953x if (other.empty())
215 ✗ return;
216
2/2
✓ Branch 0 taken 235132 times.
✓ Branch 1 taken 903821 times.
 1138953x if (tail_)
217 235132x tail_->next_ = other.head_;
218 else
219 903821x head_ = other.head_;
220 1138953x tail_ = other.tail_;
221 1138953x other.head_ = nullptr;
222 1138953x other.tail_ = nullptr;
223 1138953x }
224
225 3203389x T* pop() noexcept
226 {
227
2/4
✓ Branch 0 taken 2272084 times.
✓ Branch 1 taken 931305 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
 3203389x if (!head_)
228 931305x return nullptr;
229 2272084x T* w = head_;
230 2272084x head_ = head_->next_;
231
2/4
✓ Branch 0 taken 1276031 times.
✓ Branch 1 taken 996053 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
 2272084x if (!head_)
232 996053x tail_ = nullptr;
233 // Defensive: clear stale linkage on popped node.
234 2272084x w->next_ = nullptr;
235 2272084x return w;
236 3203389x }
237 };
238
239 } // namespace boost::corosio::detail
240
241 #endif
242