symmetric_coroutine_call.hpp 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811
  1. // Copyright Oliver Kowalke 2009.
  2. // Distributed under the Boost Software License, Version 1.0.
  3. // (See accompanying file LICENSE_1_0.txt or copy at
  4. // http://www.boost.org/LICENSE_1_0.txt)
  5. #ifndef BOOST_COROUTINES_DETAIL_SYMMETRIC_COROUTINE_CALL_H
  6. #define BOOST_COROUTINES_DETAIL_SYMMETRIC_COROUTINE_CALL_H
  7. #include <boost/assert.hpp>
  8. #include <boost/config.hpp>
  9. #include <boost/move/move.hpp>
  10. #include <boost/utility/explicit_operator_bool.hpp>
  11. #include <boost/coroutine/attributes.hpp>
  12. #include <boost/coroutine/detail/config.hpp>
  13. #include <boost/coroutine/detail/preallocated.hpp>
  14. #include <boost/coroutine/detail/symmetric_coroutine_impl.hpp>
  15. #include <boost/coroutine/detail/symmetric_coroutine_object.hpp>
  16. #include <boost/coroutine/detail/symmetric_coroutine_yield.hpp>
  17. #include <boost/coroutine/stack_allocator.hpp>
  18. #include <boost/coroutine/stack_context.hpp>
  19. #ifdef BOOST_HAS_ABI_HEADERS
  20. # include BOOST_ABI_PREFIX
  21. #endif
  22. namespace boost {
  23. namespace coroutines {
  24. namespace detail {
  25. template< typename Arg >
  26. class symmetric_coroutine_call
  27. {
  28. private:
  29. template< typename X >
  30. friend class symmetric_coroutine_yield;
  31. typedef symmetric_coroutine_impl< Arg > impl_type;
  32. BOOST_MOVABLE_BUT_NOT_COPYABLE( symmetric_coroutine_call)
  33. struct dummy {};
  34. impl_type * impl_;
  35. public:
  36. typedef Arg value_type;
  37. typedef symmetric_coroutine_yield< Arg > yield_type;
  38. symmetric_coroutine_call() BOOST_NOEXCEPT :
  39. impl_( 0)
  40. {}
  41. #ifndef BOOST_NO_CXX11_RVALUE_REFERENCES
  42. # ifdef BOOST_MSVC
  43. typedef void ( * coroutine_fn)( yield_type &);
  44. explicit symmetric_coroutine_call( coroutine_fn fn,
  45. attributes const& attrs = attributes(),
  46. stack_allocator stack_alloc = stack_allocator() ) :
  47. impl_( 0)
  48. {
  49. // create a stack-context
  50. stack_context stack_ctx;
  51. // allocate the coroutine-stack
  52. stack_alloc.allocate( stack_ctx, attrs.size);
  53. BOOST_ASSERT( 0 != stack_ctx.sp);
  54. // typedef of internal coroutine-type
  55. typedef symmetric_coroutine_object< Arg, coroutine_fn, stack_allocator > object_t;
  56. // reserve space on top of coroutine-stack for internal coroutine-type
  57. std::size_t size = stack_ctx.size - sizeof( object_t);
  58. BOOST_ASSERT( 0 != size);
  59. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  60. BOOST_ASSERT( 0 != sp);
  61. // placement new for internal coroutine
  62. impl_ = new ( sp) object_t(
  63. boost::forward< coroutine_fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  64. BOOST_ASSERT( impl_);
  65. }
  66. template< typename StackAllocator >
  67. explicit symmetric_coroutine_call( coroutine_fn fn,
  68. attributes const& attrs,
  69. StackAllocator stack_alloc) :
  70. impl_( 0)
  71. {
  72. // create a stack-context
  73. stack_context stack_ctx;
  74. // allocate the coroutine-stack
  75. stack_alloc.allocate( stack_ctx, attrs.size);
  76. BOOST_ASSERT( 0 != stack_ctx.sp);
  77. // typedef of internal coroutine-type
  78. typedef symmetric_coroutine_object< Arg, coroutine_fn, StackAllocator > object_t;
  79. // reserve space on top of coroutine-stack for internal coroutine-type
  80. std::size_t size = stack_ctx.size - sizeof( object_t);
  81. BOOST_ASSERT( 0 != size);
  82. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  83. BOOST_ASSERT( 0 != sp);
  84. // placement new for internal coroutine
  85. impl_ = new ( sp) object_t(
  86. boost::forward< coroutine_fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  87. BOOST_ASSERT( impl_);
  88. }
  89. # endif
  90. template< typename Fn >
  91. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  92. attributes const& attrs = attributes(),
  93. stack_allocator stack_alloc = stack_allocator() ) :
  94. impl_( 0)
  95. {
  96. // create a stack-context
  97. stack_context stack_ctx;
  98. // allocate the coroutine-stack
  99. stack_alloc.allocate( stack_ctx, attrs.size);
  100. BOOST_ASSERT( 0 != stack_ctx.sp);
  101. // typedef of internal coroutine-type
  102. typedef symmetric_coroutine_object< Arg, Fn, stack_allocator > object_t;
  103. // reserve space on top of coroutine-stack for internal coroutine-type
  104. std::size_t size = stack_ctx.size - sizeof( object_t);
  105. BOOST_ASSERT( 0 != size);
  106. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  107. BOOST_ASSERT( 0 != sp);
  108. // placement new for internal coroutine
  109. impl_ = new ( sp) object_t(
  110. boost::forward< Fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  111. BOOST_ASSERT( impl_);
  112. }
  113. template< typename Fn, typename StackAllocator >
  114. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  115. attributes const& attrs,
  116. StackAllocator stack_alloc) :
  117. impl_( 0)
  118. {
  119. // create a stack-context
  120. stack_context stack_ctx;
  121. // allocate the coroutine-stack
  122. stack_alloc.allocate( stack_ctx, attrs.size);
  123. BOOST_ASSERT( 0 != stack_ctx.sp);
  124. // typedef of internal coroutine-type
  125. typedef symmetric_coroutine_object< Arg, Fn, StackAllocator > object_t;
  126. // reserve space on top of coroutine-stack for internal coroutine-type
  127. std::size_t size = stack_ctx.size - sizeof( object_t);
  128. BOOST_ASSERT( 0 != size);
  129. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  130. BOOST_ASSERT( 0 != sp);
  131. // placement new for internal coroutine
  132. impl_ = new ( sp) object_t(
  133. boost::forward< Fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  134. BOOST_ASSERT( impl_);
  135. }
  136. #else
  137. template< typename Fn >
  138. explicit symmetric_coroutine_call( Fn fn,
  139. attributes const& attrs = attributes(),
  140. stack_allocator stack_alloc = stack_allocator() ) :
  141. impl_( 0)
  142. {
  143. // create a stack-context
  144. stack_context stack_ctx;
  145. // allocate the coroutine-stack
  146. stack_alloc.allocate( stack_ctx, attrs.size);
  147. BOOST_ASSERT( 0 != stack_ctx.sp);
  148. // typedef of internal coroutine-type
  149. typedef symmetric_coroutine_object< Arg, Fn, stack_allocator > object_t;
  150. // reserve space on top of coroutine-stack for internal coroutine-type
  151. std::size_t size = stack_ctx.size - sizeof( object_t);
  152. BOOST_ASSERT( 0 != size);
  153. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  154. BOOST_ASSERT( 0 != sp);
  155. // placement new for internal coroutine
  156. impl_ = new ( sp) object_t(
  157. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  158. BOOST_ASSERT( impl_);
  159. }
  160. template< typename Fn, typename StackAllocator >
  161. explicit symmetric_coroutine_call( Fn fn,
  162. attributes const& attrs,
  163. StackAllocator stack_alloc) :
  164. impl_( 0)
  165. {
  166. // create a stack-context
  167. stack_context stack_ctx;
  168. // allocate the coroutine-stack
  169. stack_alloc.allocate( stack_ctx, attrs.size);
  170. BOOST_ASSERT( 0 != stack_ctx.sp);
  171. // typedef of internal coroutine-type
  172. typedef symmetric_coroutine_object< Arg, Fn, StackAllocator > object_t;
  173. // reserve space on top of coroutine-stack for internal coroutine-type
  174. std::size_t size = stack_ctx.size - sizeof( object_t);
  175. BOOST_ASSERT( 0 != size);
  176. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  177. BOOST_ASSERT( 0 != sp);
  178. // placement new for internal coroutine
  179. impl_ = new ( sp) object_t(
  180. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  181. BOOST_ASSERT( impl_);
  182. }
  183. template< typename Fn >
  184. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  185. attributes const& attrs = attributes(),
  186. stack_allocator stack_alloc = stack_allocator() ) :
  187. impl_( 0)
  188. {
  189. // create a stack-context
  190. stack_context stack_ctx;
  191. // allocate the coroutine-stack
  192. stack_alloc.allocate( stack_ctx, attrs.size);
  193. BOOST_ASSERT( 0 != stack_ctx.sp);
  194. // typedef of internal coroutine-type
  195. typedef symmetric_coroutine_object< Arg, Fn, stack_allocator > object_t;
  196. // reserve space on top of coroutine-stack for internal coroutine-type
  197. std::size_t size = stack_ctx.size - sizeof( object_t);
  198. BOOST_ASSERT( 0 != size);
  199. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  200. BOOST_ASSERT( 0 != sp);
  201. // placement new for internal coroutine
  202. impl_ = new ( sp) object_t(
  203. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  204. BOOST_ASSERT( impl_);
  205. }
  206. template< typename Fn, typename StackAllocator >
  207. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  208. attributes const& attrs,
  209. StackAllocator stack_alloc) :
  210. impl_( 0)
  211. {
  212. // create a stack-context
  213. stack_context stack_ctx;
  214. // allocate the coroutine-stack
  215. stack_alloc.allocate( stack_ctx, attrs.size);
  216. BOOST_ASSERT( 0 != stack_ctx.sp);
  217. // typedef of internal coroutine-type
  218. typedef symmetric_coroutine_object< Arg, Fn, StackAllocator > object_t;
  219. // reserve space on top of coroutine-stack for internal coroutine-type
  220. std::size_t size = stack_ctx.size - sizeof( object_t);
  221. BOOST_ASSERT( 0 != size);
  222. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  223. BOOST_ASSERT( 0 != sp);
  224. // placement new for internal coroutine
  225. impl_ = new ( sp) object_t(
  226. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  227. BOOST_ASSERT( impl_);
  228. }
  229. #endif
  230. ~symmetric_coroutine_call()
  231. {
  232. if ( 0 != impl_)
  233. {
  234. impl_->destroy();
  235. impl_ = 0;
  236. }
  237. }
  238. symmetric_coroutine_call( BOOST_RV_REF( symmetric_coroutine_call) other) BOOST_NOEXCEPT :
  239. impl_( 0)
  240. { swap( other); }
  241. symmetric_coroutine_call & operator=( BOOST_RV_REF( symmetric_coroutine_call) other) BOOST_NOEXCEPT
  242. {
  243. symmetric_coroutine_call tmp( boost::move( other) );
  244. swap( tmp);
  245. return * this;
  246. }
  247. BOOST_EXPLICIT_OPERATOR_BOOL();
  248. bool operator!() const BOOST_NOEXCEPT
  249. { return 0 == impl_ || impl_->is_complete() || impl_->is_running(); }
  250. void swap( symmetric_coroutine_call & other) BOOST_NOEXCEPT
  251. { std::swap( impl_, other.impl_); }
  252. symmetric_coroutine_call & operator()( Arg arg) BOOST_NOEXCEPT
  253. {
  254. BOOST_ASSERT( * this);
  255. impl_->resume( arg);
  256. return * this;
  257. }
  258. };
  259. template< typename Arg >
  260. class symmetric_coroutine_call< Arg & >
  261. {
  262. private:
  263. template< typename X >
  264. friend class symmetric_coroutine_yield;
  265. typedef symmetric_coroutine_impl< Arg & > impl_type;
  266. BOOST_MOVABLE_BUT_NOT_COPYABLE( symmetric_coroutine_call)
  267. struct dummy {};
  268. impl_type * impl_;
  269. public:
  270. typedef Arg value_type;
  271. typedef symmetric_coroutine_yield< Arg & > yield_type;
  272. symmetric_coroutine_call() BOOST_NOEXCEPT :
  273. impl_( 0)
  274. {}
  275. #ifndef BOOST_NO_CXX11_RVALUE_REFERENCES
  276. # ifdef BOOST_MSVC
  277. typedef void ( * coroutine_fn)( yield_type &);
  278. explicit symmetric_coroutine_call( coroutine_fn fn,
  279. attributes const& attrs = attributes(),
  280. stack_allocator stack_alloc = stack_allocator() ) :
  281. impl_( 0)
  282. {
  283. // create a stack-context
  284. stack_context stack_ctx;
  285. // allocate the coroutine-stack
  286. stack_alloc.allocate( stack_ctx, attrs.size);
  287. BOOST_ASSERT( 0 != stack_ctx.sp);
  288. // typedef of internal coroutine-type
  289. typedef symmetric_coroutine_object< Arg &, coroutine_fn, stack_allocator > object_t;
  290. // reserve space on top of coroutine-stack for internal coroutine-type
  291. std::size_t size = stack_ctx.size - sizeof( object_t);
  292. BOOST_ASSERT( 0 != size);
  293. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  294. BOOST_ASSERT( 0 != sp);
  295. // placement new for internal coroutine
  296. impl_ = new ( sp) object_t(
  297. boost::forward< coroutine_fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  298. BOOST_ASSERT( impl_);
  299. }
  300. template< typename StackAllocator >
  301. explicit symmetric_coroutine_call( coroutine_fn fn,
  302. attributes const& attrs,
  303. StackAllocator stack_alloc) :
  304. impl_( 0)
  305. {
  306. // create a stack-context
  307. stack_context stack_ctx;
  308. // allocate the coroutine-stack
  309. stack_alloc.allocate( stack_ctx, attrs.size);
  310. BOOST_ASSERT( 0 != stack_ctx.sp);
  311. // typedef of internal coroutine-type
  312. typedef symmetric_coroutine_object< Arg &, coroutine_fn, StackAllocator > object_t;
  313. // reserve space on top of coroutine-stack for internal coroutine-type
  314. std::size_t size = stack_ctx.size - sizeof( object_t);
  315. BOOST_ASSERT( 0 != size);
  316. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  317. BOOST_ASSERT( 0 != sp);
  318. // placement new for internal coroutine
  319. impl_ = new ( sp) object_t(
  320. boost::forward< coroutine_fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  321. BOOST_ASSERT( impl_);
  322. }
  323. # endif
  324. template< typename Fn >
  325. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  326. attributes const& attrs = attributes(),
  327. stack_allocator stack_alloc = stack_allocator() ) :
  328. impl_( 0)
  329. {
  330. // create a stack-context
  331. stack_context stack_ctx;
  332. // allocate the coroutine-stack
  333. stack_alloc.allocate( stack_ctx, attrs.size);
  334. BOOST_ASSERT( 0 != stack_ctx.sp);
  335. // typedef of internal coroutine-type
  336. typedef symmetric_coroutine_object< Arg &, Fn, stack_allocator > object_t;
  337. // reserve space on top of coroutine-stack for internal coroutine-type
  338. std::size_t size = stack_ctx.size - sizeof( object_t);
  339. BOOST_ASSERT( 0 != size);
  340. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  341. BOOST_ASSERT( 0 != sp);
  342. // placement new for internal coroutine
  343. impl_ = new ( sp) object_t(
  344. boost::forward< Fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  345. BOOST_ASSERT( impl_);
  346. }
  347. template< typename Fn, typename StackAllocator >
  348. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  349. attributes const& attrs,
  350. StackAllocator stack_alloc) :
  351. impl_( 0)
  352. {
  353. // create a stack-context
  354. stack_context stack_ctx;
  355. // allocate the coroutine-stack
  356. stack_alloc.allocate( stack_ctx, attrs.size);
  357. BOOST_ASSERT( 0 != stack_ctx.sp);
  358. // typedef of internal coroutine-type
  359. typedef symmetric_coroutine_object< Arg &, Fn, StackAllocator > object_t;
  360. // reserve space on top of coroutine-stack for internal coroutine-type
  361. std::size_t size = stack_ctx.size - sizeof( object_t);
  362. BOOST_ASSERT( 0 != size);
  363. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  364. BOOST_ASSERT( 0 != sp);
  365. // placement new for internal coroutine
  366. impl_ = new ( sp) object_t(
  367. boost::forward< Fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  368. BOOST_ASSERT( impl_);
  369. }
  370. #else
  371. template< typename Fn >
  372. explicit symmetric_coroutine_call( Fn fn,
  373. attributes const& attrs = attributes(),
  374. stack_allocator stack_alloc = stack_allocator() ) :
  375. impl_( 0)
  376. {
  377. // create a stack-context
  378. stack_context stack_ctx;
  379. // allocate the coroutine-stack
  380. stack_alloc.allocate( stack_ctx, attrs.size);
  381. BOOST_ASSERT( 0 != stack_ctx.sp);
  382. // typedef of internal coroutine-type
  383. typedef symmetric_coroutine_object< Arg &, Fn, stack_allocator > object_t;
  384. // reserve space on top of coroutine-stack for internal coroutine-type
  385. std::size_t size = stack_ctx.size - sizeof( object_t);
  386. BOOST_ASSERT( 0 != size);
  387. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  388. BOOST_ASSERT( 0 != sp);
  389. // placement new for internal coroutine
  390. impl_ = new ( sp) object_t(
  391. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  392. BOOST_ASSERT( impl_);
  393. }
  394. template< typename Fn, typename StackAllocator >
  395. explicit symmetric_coroutine_call( Fn fn,
  396. attributes const& attrs,
  397. StackAllocator stack_alloc) :
  398. impl_( 0)
  399. {
  400. // create a stack-context
  401. stack_context stack_ctx;
  402. // allocate the coroutine-stack
  403. stack_alloc.allocate( stack_ctx, attrs.size);
  404. BOOST_ASSERT( 0 != stack_ctx.sp);
  405. // typedef of internal coroutine-type
  406. typedef symmetric_coroutine_object< Arg &, Fn, StackAllocator > object_t;
  407. // reserve space on top of coroutine-stack for internal coroutine-type
  408. std::size_t size = stack_ctx.size - sizeof( object_t);
  409. BOOST_ASSERT( 0 != size);
  410. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  411. BOOST_ASSERT( 0 != sp);
  412. // placement new for internal coroutine
  413. impl_ = new ( sp) object_t(
  414. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  415. BOOST_ASSERT( impl_);
  416. }
  417. template< typename Fn >
  418. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  419. attributes const& attrs = attributes(),
  420. stack_allocator stack_alloc = stack_allocator() ) :
  421. impl_( 0)
  422. {
  423. // create a stack-context
  424. stack_context stack_ctx;
  425. // allocate the coroutine-stack
  426. stack_alloc.allocate( stack_ctx, attrs.size);
  427. BOOST_ASSERT( 0 != stack_ctx.sp);
  428. // typedef of internal coroutine-type
  429. typedef symmetric_coroutine_object< Arg &, Fn, stack_allocator > object_t;
  430. // reserve space on top of coroutine-stack for internal coroutine-type
  431. std::size_t size = stack_ctx.size - sizeof( object_t);
  432. BOOST_ASSERT( 0 != size);
  433. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  434. BOOST_ASSERT( 0 != sp);
  435. // placement new for internal coroutine
  436. impl_ = new ( sp) object_t(
  437. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  438. BOOST_ASSERT( impl_);
  439. }
  440. template< typename Fn, typename StackAllocator >
  441. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  442. attributes const& attrs,
  443. StackAllocator stack_alloc) :
  444. impl_( 0)
  445. {
  446. // create a stack-context
  447. stack_context stack_ctx;
  448. // allocate the coroutine-stack
  449. stack_alloc.allocate( stack_ctx, attrs.size);
  450. BOOST_ASSERT( 0 != stack_ctx.sp);
  451. // typedef of internal coroutine-type
  452. typedef symmetric_coroutine_object< Arg &, Fn, StackAllocator > object_t;
  453. // reserve space on top of coroutine-stack for internal coroutine-type
  454. std::size_t size = stack_ctx.size - sizeof( object_t);
  455. BOOST_ASSERT( 0 != size);
  456. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  457. BOOST_ASSERT( 0 != sp);
  458. // placement new for internal coroutine
  459. impl_ = new ( sp) object_t(
  460. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  461. BOOST_ASSERT( impl_);
  462. }
  463. #endif
  464. ~symmetric_coroutine_call()
  465. {
  466. if ( 0 != impl_)
  467. {
  468. impl_->destroy();
  469. impl_ = 0;
  470. }
  471. }
  472. symmetric_coroutine_call( BOOST_RV_REF( symmetric_coroutine_call) other) BOOST_NOEXCEPT :
  473. impl_( 0)
  474. { swap( other); }
  475. symmetric_coroutine_call & operator=( BOOST_RV_REF( symmetric_coroutine_call) other) BOOST_NOEXCEPT
  476. {
  477. symmetric_coroutine_call tmp( boost::move( other) );
  478. swap( tmp);
  479. return * this;
  480. }
  481. BOOST_EXPLICIT_OPERATOR_BOOL();
  482. bool operator!() const BOOST_NOEXCEPT
  483. { return 0 == impl_ || impl_->is_complete() || impl_->is_running(); }
  484. void swap( symmetric_coroutine_call & other) BOOST_NOEXCEPT
  485. { std::swap( impl_, other.impl_); }
  486. symmetric_coroutine_call & operator()( Arg & arg) BOOST_NOEXCEPT
  487. {
  488. BOOST_ASSERT( * this);
  489. impl_->resume( arg);
  490. return * this;
  491. }
  492. };
  493. template<>
  494. class symmetric_coroutine_call< void >
  495. {
  496. private:
  497. template< typename X >
  498. friend class symmetric_coroutine_yield;
  499. typedef symmetric_coroutine_impl< void > impl_type;
  500. BOOST_MOVABLE_BUT_NOT_COPYABLE( symmetric_coroutine_call)
  501. struct dummy {};
  502. impl_type * impl_;
  503. public:
  504. typedef void value_type;
  505. typedef symmetric_coroutine_yield< void > yield_type;
  506. symmetric_coroutine_call() BOOST_NOEXCEPT :
  507. impl_( 0)
  508. {}
  509. #ifndef BOOST_NO_CXX11_RVALUE_REFERENCES
  510. # ifdef BOOST_MSVC
  511. typedef void ( * coroutine_fn)( yield_type &);
  512. explicit symmetric_coroutine_call( coroutine_fn fn,
  513. attributes const& attrs = attributes(),
  514. stack_allocator stack_alloc = stack_allocator() ) :
  515. impl_( 0)
  516. {
  517. // create a stack-context
  518. stack_context stack_ctx;
  519. // allocate the coroutine-stack
  520. stack_alloc.allocate( stack_ctx, attrs.size);
  521. BOOST_ASSERT( 0 != stack_ctx.sp);
  522. // typedef of internal coroutine-type
  523. typedef symmetric_coroutine_object< void, coroutine_fn, stack_allocator > object_t;
  524. // reserve space on top of coroutine-stack for internal coroutine-type
  525. std::size_t size = stack_ctx.size - sizeof( object_t);
  526. BOOST_ASSERT( 0 != size);
  527. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  528. BOOST_ASSERT( 0 != sp);
  529. // placement new for internal coroutine
  530. impl_ = new ( sp) object_t(
  531. boost::forward< coroutine_fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  532. BOOST_ASSERT( impl_);
  533. }
  534. template< typename StackAllocator >
  535. explicit symmetric_coroutine_call( coroutine_fn fn,
  536. attributes const& attrs,
  537. StackAllocator stack_alloc) :
  538. impl_( 0)
  539. {
  540. // create a stack-context
  541. stack_context stack_ctx;
  542. // allocate the coroutine-stack
  543. stack_alloc.allocate( stack_ctx, attrs.size);
  544. BOOST_ASSERT( 0 != stack_ctx.sp);
  545. // typedef of internal coroutine-type
  546. typedef symmetric_coroutine_object< void, coroutine_fn, StackAllocator > object_t;
  547. // reserve space on top of coroutine-stack for internal coroutine-type
  548. std::size_t size = stack_ctx.size - sizeof( object_t);
  549. BOOST_ASSERT( 0 != size);
  550. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  551. BOOST_ASSERT( 0 != sp);
  552. // placement new for internal coroutine
  553. impl_ = new ( sp) object_t(
  554. boost::forward< coroutine_fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  555. BOOST_ASSERT( impl_);
  556. }
  557. # endif
  558. template< typename Fn >
  559. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  560. attributes const& attrs = attributes(),
  561. stack_allocator stack_alloc = stack_allocator() ) :
  562. impl_( 0)
  563. {
  564. // create a stack-context
  565. stack_context stack_ctx;
  566. // allocate the coroutine-stack
  567. stack_alloc.allocate( stack_ctx, attrs.size);
  568. BOOST_ASSERT( 0 != stack_ctx.sp);
  569. // typedef of internal coroutine-type
  570. typedef symmetric_coroutine_object< void, Fn, stack_allocator > object_t;
  571. // reserve space on top of coroutine-stack for internal coroutine-type
  572. std::size_t size = stack_ctx.size - sizeof( object_t);
  573. BOOST_ASSERT( 0 != size);
  574. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  575. BOOST_ASSERT( 0 != sp);
  576. // placement new for internal coroutine
  577. impl_ = new ( sp) object_t(
  578. boost::forward< Fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  579. BOOST_ASSERT( impl_);
  580. }
  581. template< typename Fn, typename StackAllocator >
  582. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  583. attributes const& attrs,
  584. StackAllocator stack_alloc) :
  585. impl_( 0)
  586. {
  587. // create a stack-context
  588. stack_context stack_ctx;
  589. // allocate the coroutine-stack
  590. stack_alloc.allocate( stack_ctx, attrs.size);
  591. BOOST_ASSERT( 0 != stack_ctx.sp);
  592. // typedef of internal coroutine-type
  593. typedef symmetric_coroutine_object< void, Fn, StackAllocator > object_t;
  594. // reserve space on top of coroutine-stack for internal coroutine-type
  595. std::size_t size = stack_ctx.size - sizeof( object_t);
  596. BOOST_ASSERT( 0 != size);
  597. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  598. BOOST_ASSERT( 0 != sp);
  599. // placement new for internal coroutine
  600. impl_ = new ( sp) object_t(
  601. boost::forward< Fn >( fn), attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  602. BOOST_ASSERT( impl_);
  603. }
  604. #else
  605. template< typename Fn >
  606. explicit symmetric_coroutine_call( Fn fn,
  607. attributes const& attrs = attributes(),
  608. stack_allocator stack_alloc = stack_allocator() ) :
  609. impl_( 0)
  610. {
  611. // create a stack-context
  612. stack_context stack_ctx;
  613. // allocate the coroutine-stack
  614. stack_alloc.allocate( stack_ctx, attrs.size);
  615. BOOST_ASSERT( 0 != stack_ctx.sp);
  616. // typedef of internal coroutine-type
  617. typedef symmetric_coroutine_object< void, Fn, stack_allocator > object_t;
  618. // reserve space on top of coroutine-stack for internal coroutine-type
  619. std::size_t size = stack_ctx.size - sizeof( object_t);
  620. BOOST_ASSERT( 0 != size);
  621. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  622. BOOST_ASSERT( 0 != sp);
  623. // placement new for internal coroutine
  624. impl_ = new ( sp) object_t(
  625. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  626. BOOST_ASSERT( impl_);
  627. }
  628. template< typename Fn, typename StackAllocator >
  629. explicit symmetric_coroutine_call( Fn fn,
  630. attributes const& attrs,
  631. StackAllocator stack_alloc) :
  632. impl_( 0)
  633. {
  634. // create a stack-context
  635. stack_context stack_ctx;
  636. // allocate the coroutine-stack
  637. stack_alloc.allocate( stack_ctx, attrs.size);
  638. BOOST_ASSERT( 0 != stack_ctx.sp);
  639. // typedef of internal coroutine-type
  640. typedef symmetric_coroutine_object< void, Fn, StackAllocator > object_t;
  641. // reserve space on top of coroutine-stack for internal coroutine-type
  642. std::size_t size = stack_ctx.size - sizeof( object_t);
  643. BOOST_ASSERT( 0 != size);
  644. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  645. BOOST_ASSERT( 0 != sp);
  646. // placement new for internal coroutine
  647. impl_ = new ( sp) object_t(
  648. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  649. BOOST_ASSERT( impl_);
  650. }
  651. template< typename Fn >
  652. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  653. attributes const& attrs = attributes(),
  654. stack_allocator stack_alloc = stack_allocator() ) :
  655. impl_( 0)
  656. {
  657. // create a stack-context
  658. stack_context stack_ctx;
  659. // allocate the coroutine-stack
  660. stack_alloc.allocate( stack_ctx, attrs.size);
  661. BOOST_ASSERT( 0 != stack_ctx.sp);
  662. // typedef of internal coroutine-type
  663. typedef symmetric_coroutine_object< void, Fn, stack_allocator > object_t;
  664. // reserve space on top of coroutine-stack for internal coroutine-type
  665. std::size_t size = stack_ctx.size - sizeof( object_t);
  666. BOOST_ASSERT( 0 != size);
  667. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  668. BOOST_ASSERT( 0 != sp);
  669. // placement new for internal coroutine
  670. impl_ = new ( sp) object_t(
  671. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  672. BOOST_ASSERT( impl_);
  673. }
  674. template< typename Fn, typename StackAllocator >
  675. explicit symmetric_coroutine_call( BOOST_RV_REF( Fn) fn,
  676. attributes const& attrs,
  677. StackAllocator stack_alloc) :
  678. impl_( 0)
  679. {
  680. // create a stack-context
  681. stack_context stack_ctx;
  682. // allocate the coroutine-stack
  683. stack_alloc.allocate( stack_ctx, attrs.size);
  684. BOOST_ASSERT( 0 != stack_ctx.sp);
  685. // typedef of internal coroutine-type
  686. typedef symmetric_coroutine_object< void, Fn, StackAllocator > object_t;
  687. // reserve space on top of coroutine-stack for internal coroutine-type
  688. std::size_t size = stack_ctx.size - sizeof( object_t);
  689. BOOST_ASSERT( 0 != size);
  690. void * sp = static_cast< char * >( stack_ctx.sp) - sizeof( object_t);
  691. BOOST_ASSERT( 0 != sp);
  692. // placement new for internal coroutine
  693. impl_ = new ( sp) object_t(
  694. fn, attrs, preallocated( sp, size, stack_ctx), stack_alloc);
  695. BOOST_ASSERT( impl_);
  696. }
  697. #endif
  698. ~symmetric_coroutine_call()
  699. {
  700. if ( 0 != impl_)
  701. {
  702. impl_->destroy();
  703. impl_ = 0;
  704. }
  705. }
  706. inline symmetric_coroutine_call( BOOST_RV_REF( symmetric_coroutine_call) other) BOOST_NOEXCEPT :
  707. impl_( 0)
  708. { swap( other); }
  709. inline symmetric_coroutine_call & operator=( BOOST_RV_REF( symmetric_coroutine_call) other) BOOST_NOEXCEPT
  710. {
  711. symmetric_coroutine_call tmp( boost::move( other) );
  712. swap( tmp);
  713. return * this;
  714. }
  715. BOOST_EXPLICIT_OPERATOR_BOOL();
  716. inline bool operator!() const BOOST_NOEXCEPT
  717. { return 0 == impl_ || impl_->is_complete() || impl_->is_running(); }
  718. inline void swap( symmetric_coroutine_call & other) BOOST_NOEXCEPT
  719. { std::swap( impl_, other.impl_); }
  720. inline symmetric_coroutine_call & operator()() BOOST_NOEXCEPT
  721. {
  722. BOOST_ASSERT( * this);
  723. impl_->resume();
  724. return * this;
  725. }
  726. };
  727. template< typename Arg >
  728. void swap( symmetric_coroutine_call< Arg > & l,
  729. symmetric_coroutine_call< Arg > & r)
  730. { l.swap( r); }
  731. }}}
  732. #ifdef BOOST_HAS_ABI_HEADERS
  733. # include BOOST_ABI_SUFFIX
  734. #endif
  735. #endif // BOOST_COROUTINES_DETAIL_SYMMETRIC_COROUTINE_CALL_H