Chris@16: //
Chris@16: // detail/impl/timer_queue_set.ipp
Chris@16: // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Chris@16: //
Chris@101: // Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com)
Chris@16: //
Chris@16: // Distributed under the Boost Software License, Version 1.0. (See accompanying
Chris@16: // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
Chris@16: //
Chris@16: 
Chris@16: #ifndef BOOST_ASIO_DETAIL_IMPL_TIMER_QUEUE_SET_IPP
Chris@16: #define BOOST_ASIO_DETAIL_IMPL_TIMER_QUEUE_SET_IPP
Chris@16: 
Chris@16: #if defined(_MSC_VER) && (_MSC_VER >= 1200)
Chris@16: # pragma once
Chris@16: #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
Chris@16: 
Chris@16: #include <boost/asio/detail/config.hpp>
Chris@16: #include <boost/asio/detail/timer_queue_set.hpp>
Chris@16: 
Chris@16: #include <boost/asio/detail/push_options.hpp>
Chris@16: 
Chris@16: namespace boost {
Chris@16: namespace asio {
Chris@16: namespace detail {
Chris@16: 
Chris@16: timer_queue_set::timer_queue_set()
Chris@16:   : first_(0)
Chris@16: {
Chris@16: }
Chris@16: 
Chris@16: void timer_queue_set::insert(timer_queue_base* q)
Chris@16: {
Chris@16:   q->next_ = first_;
Chris@16:   first_ = q;
Chris@16: }
Chris@16: 
Chris@16: void timer_queue_set::erase(timer_queue_base* q)
Chris@16: {
Chris@16:   if (first_)
Chris@16:   {
Chris@16:     if (q == first_)
Chris@16:     {
Chris@16:       first_ = q->next_;
Chris@16:       q->next_ = 0;
Chris@16:       return;
Chris@16:     }
Chris@16: 
Chris@16:     for (timer_queue_base* p = first_; p->next_; p = p->next_)
Chris@16:     {
Chris@16:       if (p->next_ == q)
Chris@16:       {
Chris@16:         p->next_ = q->next_;
Chris@16:         q->next_ = 0;
Chris@16:         return;
Chris@16:       }
Chris@16:     }
Chris@16:   }
Chris@16: }
Chris@16: 
Chris@16: bool timer_queue_set::all_empty() const
Chris@16: {
Chris@16:   for (timer_queue_base* p = first_; p; p = p->next_)
Chris@16:     if (!p->empty())
Chris@16:       return false;
Chris@16:   return true;
Chris@16: }
Chris@16: 
Chris@16: long timer_queue_set::wait_duration_msec(long max_duration) const
Chris@16: {
Chris@16:   long min_duration = max_duration;
Chris@16:   for (timer_queue_base* p = first_; p; p = p->next_)
Chris@16:     min_duration = p->wait_duration_msec(min_duration);
Chris@16:   return min_duration;
Chris@16: }
Chris@16: 
Chris@16: long timer_queue_set::wait_duration_usec(long max_duration) const
Chris@16: {
Chris@16:   long min_duration = max_duration;
Chris@16:   for (timer_queue_base* p = first_; p; p = p->next_)
Chris@16:     min_duration = p->wait_duration_usec(min_duration);
Chris@16:   return min_duration;
Chris@16: }
Chris@16: 
Chris@16: void timer_queue_set::get_ready_timers(op_queue<operation>& ops)
Chris@16: {
Chris@16:   for (timer_queue_base* p = first_; p; p = p->next_)
Chris@16:     p->get_ready_timers(ops);
Chris@16: }
Chris@16: 
Chris@16: void timer_queue_set::get_all_timers(op_queue<operation>& ops)
Chris@16: {
Chris@16:   for (timer_queue_base* p = first_; p; p = p->next_)
Chris@16:     p->get_all_timers(ops);
Chris@16: }
Chris@16: 
Chris@16: } // namespace detail
Chris@16: } // namespace asio
Chris@16: } // namespace boost
Chris@16: 
Chris@16: #include <boost/asio/detail/pop_options.hpp>
Chris@16: 
Chris@16: #endif // BOOST_ASIO_DETAIL_IMPL_TIMER_QUEUE_SET_IPP