summaryrefslogtreecommitdiff
path: root/boost/coroutine2/detail/pull_control_block.ipp
diff options
context:
space:
mode:
Diffstat (limited to 'boost/coroutine2/detail/pull_control_block.ipp')
-rw-r--r--boost/coroutine2/detail/pull_control_block.ipp299
1 files changed, 0 insertions, 299 deletions
diff --git a/boost/coroutine2/detail/pull_control_block.ipp b/boost/coroutine2/detail/pull_control_block.ipp
deleted file mode 100644
index 536e5e6a94..0000000000
--- a/boost/coroutine2/detail/pull_control_block.ipp
+++ /dev/null
@@ -1,299 +0,0 @@
-
-// Copyright Oliver Kowalke 2014.
-// Distributed under the Boost Software License, Version 1.0.
-// (See accompanying file LICENSE_1_0.txt or copy at
-// http://www.boost.org/LICENSE_1_0.txt)
-
-#ifndef BOOST_COROUTINES2_DETAIL_PULL_CONTROL_BLOCK_IPP
-#define BOOST_COROUTINES2_DETAIL_PULL_CONTROL_BLOCK_IPP
-
-#include <exception>
-#include <memory>
-
-#include <boost/assert.hpp>
-#include <boost/config.hpp>
-
-#include <boost/context/execution_context.hpp>
-
-#include <boost/coroutine2/detail/config.hpp>
-#include <boost/coroutine2/detail/forced_unwind.hpp>
-#include <boost/coroutine2/detail/state.hpp>
-
-#ifdef BOOST_HAS_ABI_HEADERS
-# include BOOST_ABI_PREFIX
-#endif
-
-namespace boost {
-namespace coroutines2 {
-namespace detail {
-
-// pull_coroutine< T >
-
-template< typename T >
-template< typename StackAllocator, typename Fn >
-pull_coroutine< T >::control_block::control_block( context::preallocated palloc, StackAllocator salloc,
- Fn && fn_, bool preserve_fpu_) :
- other( nullptr),
- ctx( std::allocator_arg, palloc, salloc,
- [=,fn=std::forward< Fn >( fn_),ctx=boost::context::execution_context::current()] (void *) mutable -> void {
- // create synthesized push_coroutine< T >
- typename push_coroutine< T >::control_block synthesized_cb( this, ctx);
- push_coroutine< T > synthesized( & synthesized_cb);
- other = & synthesized_cb;
- try {
- // call coroutine-fn with synthesized push_coroutine as argument
- fn( synthesized);
- } catch ( forced_unwind const&) {
- // do nothing for unwinding exception
- } catch (...) {
- // store other exceptions in exception-pointer
- except = std::current_exception();
- }
- // set termination flags
- state |= static_cast< int >( state_t::complete);
- // jump back to ctx
- other->ctx( nullptr, preserve_fpu);
- BOOST_ASSERT_MSG( false, "pull_coroutine is complete");
- }),
- preserve_fpu( preserve_fpu_),
- state( static_cast< int >( state_t::unwind) ),
- except(),
- bvalid( false),
- storage() {
- // enter coroutine-fn in order to have first value available after ctor (of `*this`) returns
- set( reinterpret_cast< T * >( ctx( nullptr, preserve_fpu) ) );
-}
-
-template< typename T >
-pull_coroutine< T >::control_block::control_block( typename push_coroutine< T >::control_block * cb,
- boost::context::execution_context const& ctx_) :
- other( cb),
- ctx( ctx_),
- preserve_fpu( other->preserve_fpu),
- state( 0),
- except(),
- bvalid( false),
- storage() {
-}
-
-template< typename T >
-pull_coroutine< T >::control_block::~control_block() {
- if ( 0 == ( state & static_cast< int >( state_t::complete ) ) &&
- 0 != ( state & static_cast< int >( state_t::unwind) ) ) {
- // set early-exit flag
- state |= static_cast< int >( state_t::early_exit);
- ctx( nullptr, preserve_fpu);
- }
- // destroy data if it set
- if ( bvalid) {
- reinterpret_cast< T const* >( storage)->~T();
- }
-}
-
-template< typename T >
-void
-pull_coroutine< T >::control_block::resume() {
- other->ctx = boost::context::execution_context::current();
- set( reinterpret_cast< T * >( ctx( nullptr, preserve_fpu) ) );
- if ( except) {
- std::rethrow_exception( except);
- }
- // test early-exit-flag
- if ( 0 != ( ( other->state) & static_cast< int >( state_t::early_exit) ) ) {
- throw forced_unwind();
- }
-}
-
-template< typename T >
-void
-pull_coroutine< T >::control_block::set( T * t) {
- // destroy data if it set
- if ( bvalid) {
- reinterpret_cast< T const* >( storage)->~T();
- }
- if ( nullptr != t) {
- new ( storage) T( std::move( * t) ); // FIXME: differrentiation between move/copy
- bvalid = true;
- } else {
- bvalid = false;
- }
-}
-
-template< typename T >
-T &
-pull_coroutine< T >::control_block::get() {
- return * reinterpret_cast< T * >( storage);
-}
-
-template< typename T >
-bool
-pull_coroutine< T >::control_block::valid() const noexcept {
- return nullptr != other && 0 == ( state & static_cast< int >( state_t::complete) ) && bvalid;
-}
-
-
-// pull_coroutine< T & >
-
-template< typename T >
-template< typename StackAllocator, typename Fn >
-pull_coroutine< T & >::control_block::control_block( context::preallocated palloc, StackAllocator salloc,
- Fn && fn_, bool preserve_fpu_) :
- other( nullptr),
- ctx( std::allocator_arg, palloc, salloc,
- [=,fn=std::forward< Fn >( fn_),ctx=boost::context::execution_context::current()] (void *) mutable -> void {
- // create synthesized push_coroutine< T >
- typename push_coroutine< T & >::control_block synthesized_cb( this, ctx);
- push_coroutine< T & > synthesized( & synthesized_cb);
- other = & synthesized_cb;
- try {
- // call coroutine-fn with synthesized push_coroutine as argument
- fn( synthesized);
- } catch ( forced_unwind const&) {
- // do nothing for unwinding exception
- } catch (...) {
- // store other exceptions in exception-pointer
- except = std::current_exception();
- }
- // set termination flags
- state |= static_cast< int >( state_t::complete);
- // jump back to ctx
- other->ctx( nullptr, preserve_fpu);
- BOOST_ASSERT_MSG( false, "pull_coroutine is complete");
- }),
- preserve_fpu( preserve_fpu_),
- state( static_cast< int >( state_t::unwind) ),
- except(),
- t( nullptr) {
- // enter coroutine-fn in order to have first value available after ctor (of `*this`) returns
- t = reinterpret_cast< T * >( ctx( nullptr, preserve_fpu) );
-}
-
-template< typename T >
-pull_coroutine< T & >::control_block::control_block( typename push_coroutine< T & >::control_block * cb,
- boost::context::execution_context const& ctx_) :
- other( cb),
- ctx( ctx_),
- preserve_fpu( other->preserve_fpu),
- state( 0),
- except(),
- t( nullptr) {
-}
-
-template< typename T >
-pull_coroutine< T & >::control_block::~control_block() {
- if ( 0 == ( state & static_cast< int >( state_t::complete ) ) &&
- 0 != ( state & static_cast< int >( state_t::unwind) ) ) {
- // set early-exit flag
- state |= static_cast< int >( state_t::early_exit);
- ctx( nullptr, preserve_fpu);
- }
-}
-
-template< typename T >
-void
-pull_coroutine< T & >::control_block::resume() {
- other->ctx = boost::context::execution_context::current();
- t = reinterpret_cast< T * >( ctx( nullptr, preserve_fpu) );
- if ( except) {
- std::rethrow_exception( except);
- }
- // test early-exit-flag
- if ( 0 != ( ( other->state) & static_cast< int >( state_t::early_exit) ) ) {
- throw forced_unwind();
- }
-}
-
-template< typename T >
-T &
-pull_coroutine< T & >::control_block::get() {
- return * reinterpret_cast< T * >( t);
-}
-
-template< typename T >
-bool
-pull_coroutine< T & >::control_block::valid() const noexcept {
- return nullptr != other && 0 == ( state & static_cast< int >( state_t::complete) ) && nullptr != t;
-}
-
-
-// pull_coroutine< void >
-
-template< typename StackAllocator, typename Fn >
-pull_coroutine< void >::control_block::control_block( context::preallocated palloc, StackAllocator salloc,
- Fn && fn_, bool preserve_fpu_) :
- other( nullptr),
- ctx( std::allocator_arg, palloc, salloc,
- [=,fn=std::forward< Fn >( fn_),ctx=boost::context::execution_context::current()] (void *) mutable -> void {
- // create synthesized push_coroutine< T >
- typename push_coroutine< void >::control_block synthesized_cb( this, ctx);
- push_coroutine< void > synthesized( & synthesized_cb);
- other = & synthesized_cb;
- try {
- // call coroutine-fn with synthesized push_coroutine as argument
- fn( synthesized);
- } catch ( forced_unwind const&) {
- // do nothing for unwinding exception
- } catch (...) {
- // store other exceptions in exception-pointer
- except = std::current_exception();
- }
- // set termination flags
- state |= static_cast< int >( state_t::complete);
- // jump back to ctx
- other->ctx( nullptr, preserve_fpu);
- BOOST_ASSERT_MSG( false, "pull_coroutine is complete");
- }),
- preserve_fpu( preserve_fpu_),
- state( static_cast< int >( state_t::unwind) ),
- except() {
- // enter coroutine-fn in order to have first value available after ctor returns
- ctx( nullptr, preserve_fpu);
-}
-
-inline
-pull_coroutine< void >::control_block::control_block( push_coroutine< void >::control_block * cb,
- boost::context::execution_context const& ctx_) :
- other( cb),
- ctx( ctx_),
- preserve_fpu( other->preserve_fpu),
- state( 0),
- except() {
-}
-
-inline
-pull_coroutine< void >::control_block::~control_block() {
- if ( 0 == ( state & static_cast< int >( state_t::complete ) ) &&
- 0 != ( state & static_cast< int >( state_t::unwind) ) ) {
- // set early-exit flag
- state |= static_cast< int >( state_t::early_exit);
- ctx( nullptr, preserve_fpu);
- }
-}
-
-inline
-void
-pull_coroutine< void >::control_block::resume() {
- other->ctx = boost::context::execution_context::current();
- ctx( nullptr, preserve_fpu);
- if ( except) {
- std::rethrow_exception( except);
- }
- // test early-exit-flag
- if ( 0 != ( ( other->state) & static_cast< int >( state_t::early_exit) ) ) {
- throw forced_unwind();
- }
-}
-
-inline
-bool
-pull_coroutine< void >::control_block::valid() const noexcept {
- return nullptr != other && 0 == ( state & static_cast< int >( state_t::complete) );
-}
-
-}}}
-
-#ifdef BOOST_HAS_ABI_HEADERS
-# include BOOST_ABI_SUFFIX
-#endif
-
-#endif // BOOST_COROUTINES2_DETAIL_PULL_CONTROL_BLOCK_IPP