mirror of
https://github.com/boostorg/asio.git
synced 2026-01-29 19:12:09 +00:00
bb38d425fb
* Chrono support. * Added object_handle support. * Need to enable the basic_handle class when object_handle is supported. * Update copyright notices. * Fix MSVC "performance warning". * Fix for NetBSD. Fixes #6098. * Fix regression in buffered_write_stream. Fixes #6310. * Fix deadlock on Mac OS X. Fixes #6275. * On linux, connect can return EAGAIN in certain circumstances. Remap to another error so that it doesn't look like a non-blocking operation. Fixes #6048. * Fix non-paged pool "leak" on Windows when io_service is repeatedly run without anything to do. Fixes #6321. * Disable object_handle on Windows CE. * Add extra include required for OVERLAPPED struct. * Fix doxygen comments. * Update documentation. * Add missing class. * Update copyright year. [SVN r76516]
88 lines
2.1 KiB
C++
88 lines
2.1 KiB
C++
//
|
|
// coroutine.hpp
|
|
// ~~~~~~~~~~~~~
|
|
//
|
|
// Copyright (c) 2003-2012 Christopher M. Kohlhoff (chris at kohlhoff dot com)
|
|
//
|
|
// 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 COROUTINE_HPP
|
|
#define COROUTINE_HPP
|
|
|
|
class coroutine
|
|
{
|
|
public:
|
|
coroutine() : value_(0) {}
|
|
bool is_child() const { return value_ < 0; }
|
|
bool is_parent() const { return !is_child(); }
|
|
bool is_complete() const { return value_ == -1; }
|
|
private:
|
|
friend class coroutine_ref;
|
|
int value_;
|
|
};
|
|
|
|
class coroutine_ref
|
|
{
|
|
public:
|
|
coroutine_ref(coroutine& c) : value_(c.value_), modified_(false) {}
|
|
coroutine_ref(coroutine* c) : value_(c->value_), modified_(false) {}
|
|
~coroutine_ref() { if (!modified_) value_ = -1; }
|
|
operator int() const { return value_; }
|
|
int& operator=(int v) { modified_ = true; return value_ = v; }
|
|
private:
|
|
void operator=(const coroutine_ref&);
|
|
int& value_;
|
|
bool modified_;
|
|
};
|
|
|
|
#define CORO_REENTER(c) \
|
|
switch (coroutine_ref _coro_value = c) \
|
|
case -1: if (_coro_value) \
|
|
{ \
|
|
goto terminate_coroutine; \
|
|
terminate_coroutine: \
|
|
_coro_value = -1; \
|
|
goto bail_out_of_coroutine; \
|
|
bail_out_of_coroutine: \
|
|
break; \
|
|
} \
|
|
else case 0:
|
|
|
|
#define CORO_YIELD_IMPL(n) \
|
|
for (_coro_value = (n);;) \
|
|
if (_coro_value == 0) \
|
|
{ \
|
|
case (n): ; \
|
|
break; \
|
|
} \
|
|
else \
|
|
switch (_coro_value ? 0 : 1) \
|
|
for (;;) \
|
|
case -1: if (_coro_value) \
|
|
goto terminate_coroutine; \
|
|
else for (;;) \
|
|
case 1: if (_coro_value) \
|
|
goto bail_out_of_coroutine; \
|
|
else case 0:
|
|
|
|
#define CORO_FORK_IMPL(n) \
|
|
for (_coro_value = -(n);; _coro_value = (n)) \
|
|
if (_coro_value == (n)) \
|
|
{ \
|
|
case -(n): ; \
|
|
break; \
|
|
} \
|
|
else
|
|
|
|
#if defined(_MSC_VER)
|
|
# define CORO_YIELD CORO_YIELD_IMPL(__COUNTER__ + 1)
|
|
# define CORO_FORK CORO_FORK_IMPL(__COUNTER__ + 1)
|
|
#else // defined(_MSC_VER)
|
|
# define CORO_YIELD CORO_YIELD_IMPL(__LINE__)
|
|
# define CORO_FORK CORO_FORK_IMPL(__LINE__)
|
|
#endif // defined(_MSC_VER)
|
|
|
|
#endif // COROUTINE_HPP
|