boost/fiber
2
0
Fork 0
mirror of https://github.com/boostorg/fiber.git synced 2026-02-13 12:22:36 +00:00
Code Issues Projects Releases Wiki Activity

let scheduler::instance() return a pointer

Browse Source
This commit is contained in:
Oliver Kowalke
2013-06-23 12:24:42 +02:00
parent 11eb0c6082
commit 3ba86d0e27
55 changed files with 180 additions and 103 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/interruption.cpp
View File

@@ -25,40 +25,40 @@ namespace boost {
namespace this_fiber {
disable_interruption::disable_interruption() BOOST_NOEXCEPT :
set_( ( fibers::detail::scheduler::instance().active()->interruption_blocked() ) )
set_( ( fibers::detail::scheduler::instance()->active()->interruption_blocked() ) )
{
if ( ! set_)
fibers::detail::scheduler::instance().active()->interruption_blocked( true);
fibers::detail::scheduler::instance()->active()->interruption_blocked( true);
}
disable_interruption::~disable_interruption() BOOST_NOEXCEPT
{
if ( ! set_)
fibers::detail::scheduler::instance().active()->interruption_blocked( false);
fibers::detail::scheduler::instance()->active()->interruption_blocked( false);
}
restore_interruption::restore_interruption( disable_interruption & disabler) BOOST_NOEXCEPT :
disabler_( disabler)
{
if ( ! disabler_.set_)
fibers::detail::scheduler::instance().active()->interruption_blocked( false);
fibers::detail::scheduler::instance()->active()->interruption_blocked( false);
}
restore_interruption::~restore_interruption() BOOST_NOEXCEPT
{
if ( ! disabler_.set_)
fibers::detail::scheduler::instance().active()->interruption_blocked( true);
fibers::detail::scheduler::instance()->active()->interruption_blocked( true);
}
bool interruption_enabled() BOOST_NOEXCEPT
{
fibers::detail::fiber_base::ptr_t f( fibers::detail::scheduler::instance().active() );
fibers::detail::fiber_base::ptr_t f( fibers::detail::scheduler::instance()->active() );
return f && f->interruption_enabled();
}
bool interruption_requested() BOOST_NOEXCEPT
{
fibers::detail::fiber_base::ptr_t f( fibers::detail::scheduler::instance().active() );
fibers::detail::fiber_base::ptr_t f( fibers::detail::scheduler::instance()->active() );
if ( ! f) return false;
return f->interruption_requested();
}
@@ -67,7 +67,7 @@ void interruption_point()
{
if ( interruption_requested() && interruption_enabled() )
{
fibers::detail::scheduler::instance().active()->request_interruption( false);
fibers::detail::scheduler::instance()->active()->request_interruption( false);
boost::throw_exception( fibers::fiber_interrupted() );
}
}