Chris@16
|
1 //
|
Chris@16
|
2 // detail/impl/timer_queue_set.ipp
|
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_IMPL_TIMER_QUEUE_SET_IPP
|
Chris@16
|
12 #define BOOST_ASIO_DETAIL_IMPL_TIMER_QUEUE_SET_IPP
|
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/config.hpp>
|
Chris@16
|
19 #include <boost/asio/detail/timer_queue_set.hpp>
|
Chris@16
|
20
|
Chris@16
|
21 #include <boost/asio/detail/push_options.hpp>
|
Chris@16
|
22
|
Chris@16
|
23 namespace boost {
|
Chris@16
|
24 namespace asio {
|
Chris@16
|
25 namespace detail {
|
Chris@16
|
26
|
Chris@16
|
27 timer_queue_set::timer_queue_set()
|
Chris@16
|
28 : first_(0)
|
Chris@16
|
29 {
|
Chris@16
|
30 }
|
Chris@16
|
31
|
Chris@16
|
32 void timer_queue_set::insert(timer_queue_base* q)
|
Chris@16
|
33 {
|
Chris@16
|
34 q->next_ = first_;
|
Chris@16
|
35 first_ = q;
|
Chris@16
|
36 }
|
Chris@16
|
37
|
Chris@16
|
38 void timer_queue_set::erase(timer_queue_base* q)
|
Chris@16
|
39 {
|
Chris@16
|
40 if (first_)
|
Chris@16
|
41 {
|
Chris@16
|
42 if (q == first_)
|
Chris@16
|
43 {
|
Chris@16
|
44 first_ = q->next_;
|
Chris@16
|
45 q->next_ = 0;
|
Chris@16
|
46 return;
|
Chris@16
|
47 }
|
Chris@16
|
48
|
Chris@16
|
49 for (timer_queue_base* p = first_; p->next_; p = p->next_)
|
Chris@16
|
50 {
|
Chris@16
|
51 if (p->next_ == q)
|
Chris@16
|
52 {
|
Chris@16
|
53 p->next_ = q->next_;
|
Chris@16
|
54 q->next_ = 0;
|
Chris@16
|
55 return;
|
Chris@16
|
56 }
|
Chris@16
|
57 }
|
Chris@16
|
58 }
|
Chris@16
|
59 }
|
Chris@16
|
60
|
Chris@16
|
61 bool timer_queue_set::all_empty() const
|
Chris@16
|
62 {
|
Chris@16
|
63 for (timer_queue_base* p = first_; p; p = p->next_)
|
Chris@16
|
64 if (!p->empty())
|
Chris@16
|
65 return false;
|
Chris@16
|
66 return true;
|
Chris@16
|
67 }
|
Chris@16
|
68
|
Chris@16
|
69 long timer_queue_set::wait_duration_msec(long max_duration) const
|
Chris@16
|
70 {
|
Chris@16
|
71 long min_duration = max_duration;
|
Chris@16
|
72 for (timer_queue_base* p = first_; p; p = p->next_)
|
Chris@16
|
73 min_duration = p->wait_duration_msec(min_duration);
|
Chris@16
|
74 return min_duration;
|
Chris@16
|
75 }
|
Chris@16
|
76
|
Chris@16
|
77 long timer_queue_set::wait_duration_usec(long max_duration) const
|
Chris@16
|
78 {
|
Chris@16
|
79 long min_duration = max_duration;
|
Chris@16
|
80 for (timer_queue_base* p = first_; p; p = p->next_)
|
Chris@16
|
81 min_duration = p->wait_duration_usec(min_duration);
|
Chris@16
|
82 return min_duration;
|
Chris@16
|
83 }
|
Chris@16
|
84
|
Chris@16
|
85 void timer_queue_set::get_ready_timers(op_queue<operation>& ops)
|
Chris@16
|
86 {
|
Chris@16
|
87 for (timer_queue_base* p = first_; p; p = p->next_)
|
Chris@16
|
88 p->get_ready_timers(ops);
|
Chris@16
|
89 }
|
Chris@16
|
90
|
Chris@16
|
91 void timer_queue_set::get_all_timers(op_queue<operation>& ops)
|
Chris@16
|
92 {
|
Chris@16
|
93 for (timer_queue_base* p = first_; p; p = p->next_)
|
Chris@16
|
94 p->get_all_timers(ops);
|
Chris@16
|
95 }
|
Chris@16
|
96
|
Chris@16
|
97 } // namespace detail
|
Chris@16
|
98 } // namespace asio
|
Chris@16
|
99 } // namespace boost
|
Chris@16
|
100
|
Chris@16
|
101 #include <boost/asio/detail/pop_options.hpp>
|
Chris@16
|
102
|
Chris@16
|
103 #endif // BOOST_ASIO_DETAIL_IMPL_TIMER_QUEUE_SET_IPP
|