for (async_states_t::iterator i = async_states_.begin(), e = async_states_.end();
i != e; ++i)
{
- (*i)->make_ready();
+ (*i)->notify_deferred();
}
}
}
}
- void BOOST_THREAD_DECL sleep_until(const timespec& ts)
+ void BOOST_THREAD_DECL sleep_until_realtime(const timespec& ts)
{
- timespec now = boost::detail::timespec_now();
+ timespec now = boost::detail::timespec_now_realtime();
if (boost::detail::timespec_gt(ts, now))
{
for (int foo=0; foo < 5; ++foo)
condition_variable cond;
cond.do_wait_until(lock, ts);
# endif
- timespec now2 = boost::detail::timespec_now();
+ timespec now2 = boost::detail::timespec_now_realtime();
if (boost::detail::timespec_ge(now2, ts))
{
return;
}
}
}
-
}
}
namespace hidden
}
}
- void BOOST_THREAD_DECL sleep_until(const timespec& ts)
+ void BOOST_THREAD_DECL sleep_until_realtime(const timespec& ts)
{
boost::detail::thread_data_base* const thread_info=boost::detail::get_current_thread_data();
}
else
{
- boost::this_thread::no_interruption_point::hidden::sleep_until(ts);
+ boost::this_thread::no_interruption_point::hidden::sleep_until_realtime(ts);
}
}
} // hidden