Chris@16
|
1 //
|
Chris@16
|
2 // detail/op_queue.hpp
|
Chris@16
|
3 // ~~~~~~~~~~~~~~~~~~~
|
Chris@16
|
4 //
|
Chris@101
|
5 // Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com)
|
Chris@16
|
6 //
|
Chris@16
|
7 // Distributed under the Boost Software License, Version 1.0. (See accompanying
|
Chris@16
|
8 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
|
Chris@16
|
9 //
|
Chris@16
|
10
|
Chris@16
|
11 #ifndef BOOST_ASIO_DETAIL_OP_QUEUE_HPP
|
Chris@16
|
12 #define BOOST_ASIO_DETAIL_OP_QUEUE_HPP
|
Chris@16
|
13
|
Chris@16
|
14 #if defined(_MSC_VER) && (_MSC_VER >= 1200)
|
Chris@16
|
15 # pragma once
|
Chris@16
|
16 #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
|
Chris@16
|
17
|
Chris@16
|
18 #include <boost/asio/detail/noncopyable.hpp>
|
Chris@16
|
19
|
Chris@16
|
20 #include <boost/asio/detail/push_options.hpp>
|
Chris@16
|
21
|
Chris@16
|
22 namespace boost {
|
Chris@16
|
23 namespace asio {
|
Chris@16
|
24 namespace detail {
|
Chris@16
|
25
|
Chris@16
|
26 template <typename Operation>
|
Chris@16
|
27 class op_queue;
|
Chris@16
|
28
|
Chris@16
|
29 class op_queue_access
|
Chris@16
|
30 {
|
Chris@16
|
31 public:
|
Chris@16
|
32 template <typename Operation>
|
Chris@16
|
33 static Operation* next(Operation* o)
|
Chris@16
|
34 {
|
Chris@16
|
35 return static_cast<Operation*>(o->next_);
|
Chris@16
|
36 }
|
Chris@16
|
37
|
Chris@16
|
38 template <typename Operation1, typename Operation2>
|
Chris@16
|
39 static void next(Operation1*& o1, Operation2* o2)
|
Chris@16
|
40 {
|
Chris@16
|
41 o1->next_ = o2;
|
Chris@16
|
42 }
|
Chris@16
|
43
|
Chris@16
|
44 template <typename Operation>
|
Chris@16
|
45 static void destroy(Operation* o)
|
Chris@16
|
46 {
|
Chris@16
|
47 o->destroy();
|
Chris@16
|
48 }
|
Chris@16
|
49
|
Chris@16
|
50 template <typename Operation>
|
Chris@16
|
51 static Operation*& front(op_queue<Operation>& q)
|
Chris@16
|
52 {
|
Chris@16
|
53 return q.front_;
|
Chris@16
|
54 }
|
Chris@16
|
55
|
Chris@16
|
56 template <typename Operation>
|
Chris@16
|
57 static Operation*& back(op_queue<Operation>& q)
|
Chris@16
|
58 {
|
Chris@16
|
59 return q.back_;
|
Chris@16
|
60 }
|
Chris@16
|
61 };
|
Chris@16
|
62
|
Chris@16
|
63 template <typename Operation>
|
Chris@16
|
64 class op_queue
|
Chris@16
|
65 : private noncopyable
|
Chris@16
|
66 {
|
Chris@16
|
67 public:
|
Chris@16
|
68 // Constructor.
|
Chris@16
|
69 op_queue()
|
Chris@16
|
70 : front_(0),
|
Chris@16
|
71 back_(0)
|
Chris@16
|
72 {
|
Chris@16
|
73 }
|
Chris@16
|
74
|
Chris@16
|
75 // Destructor destroys all operations.
|
Chris@16
|
76 ~op_queue()
|
Chris@16
|
77 {
|
Chris@16
|
78 while (Operation* op = front_)
|
Chris@16
|
79 {
|
Chris@16
|
80 pop();
|
Chris@16
|
81 op_queue_access::destroy(op);
|
Chris@16
|
82 }
|
Chris@16
|
83 }
|
Chris@16
|
84
|
Chris@16
|
85 // Get the operation at the front of the queue.
|
Chris@16
|
86 Operation* front()
|
Chris@16
|
87 {
|
Chris@16
|
88 return front_;
|
Chris@16
|
89 }
|
Chris@16
|
90
|
Chris@16
|
91 // Pop an operation from the front of the queue.
|
Chris@16
|
92 void pop()
|
Chris@16
|
93 {
|
Chris@16
|
94 if (front_)
|
Chris@16
|
95 {
|
Chris@16
|
96 Operation* tmp = front_;
|
Chris@16
|
97 front_ = op_queue_access::next(front_);
|
Chris@16
|
98 if (front_ == 0)
|
Chris@16
|
99 back_ = 0;
|
Chris@16
|
100 op_queue_access::next(tmp, static_cast<Operation*>(0));
|
Chris@16
|
101 }
|
Chris@16
|
102 }
|
Chris@16
|
103
|
Chris@16
|
104 // Push an operation on to the back of the queue.
|
Chris@16
|
105 void push(Operation* h)
|
Chris@16
|
106 {
|
Chris@16
|
107 op_queue_access::next(h, static_cast<Operation*>(0));
|
Chris@16
|
108 if (back_)
|
Chris@16
|
109 {
|
Chris@16
|
110 op_queue_access::next(back_, h);
|
Chris@16
|
111 back_ = h;
|
Chris@16
|
112 }
|
Chris@16
|
113 else
|
Chris@16
|
114 {
|
Chris@16
|
115 front_ = back_ = h;
|
Chris@16
|
116 }
|
Chris@16
|
117 }
|
Chris@16
|
118
|
Chris@16
|
119 // Push all operations from another queue on to the back of the queue. The
|
Chris@16
|
120 // source queue may contain operations of a derived type.
|
Chris@16
|
121 template <typename OtherOperation>
|
Chris@16
|
122 void push(op_queue<OtherOperation>& q)
|
Chris@16
|
123 {
|
Chris@16
|
124 if (Operation* other_front = op_queue_access::front(q))
|
Chris@16
|
125 {
|
Chris@16
|
126 if (back_)
|
Chris@16
|
127 op_queue_access::next(back_, other_front);
|
Chris@16
|
128 else
|
Chris@16
|
129 front_ = other_front;
|
Chris@16
|
130 back_ = op_queue_access::back(q);
|
Chris@16
|
131 op_queue_access::front(q) = 0;
|
Chris@16
|
132 op_queue_access::back(q) = 0;
|
Chris@16
|
133 }
|
Chris@16
|
134 }
|
Chris@16
|
135
|
Chris@16
|
136 // Whether the queue is empty.
|
Chris@16
|
137 bool empty() const
|
Chris@16
|
138 {
|
Chris@16
|
139 return front_ == 0;
|
Chris@16
|
140 }
|
Chris@16
|
141
|
Chris@16
|
142 private:
|
Chris@16
|
143 friend class op_queue_access;
|
Chris@16
|
144
|
Chris@16
|
145 // The front of the queue.
|
Chris@16
|
146 Operation* front_;
|
Chris@16
|
147
|
Chris@16
|
148 // The back of the queue.
|
Chris@16
|
149 Operation* back_;
|
Chris@16
|
150 };
|
Chris@16
|
151
|
Chris@16
|
152 } // namespace detail
|
Chris@16
|
153 } // namespace asio
|
Chris@16
|
154 } // namespace boost
|
Chris@16
|
155
|
Chris@16
|
156 #include <boost/asio/detail/pop_options.hpp>
|
Chris@16
|
157
|
Chris@16
|
158 #endif // BOOST_ASIO_DETAIL_OP_QUEUE_HPP
|