coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2025-12-06 16:56:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix additional debug code in async pack traversal

Browse Source
This commit is contained in:
Denis Blank 2018-03-09 04:34:58 +01:00
parent 1a947d5c59
commit cc135da250
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
include/continuable/detail/traverse-async.hpp
View File

@ -155,9 +155,9 @@ using data_layout_t =
/// Stores the visitor and the arguments to traverse /// Stores the visitor and the arguments to traverse
template <typename Visitor, typename... Args> template <typename Visitor, typename... Args>
class async_traversal_frame : public data_layout_t<Visitor, Args...> { class async_traversal_frame : public data_layout_t<Visitor, Args...> {
#ifndef _NDEBUG #ifndef NDEBUG
std::atomic<bool> finished_; std::atomic<bool> finished_;
#endif // _NDEBUG #endif // NDEBUG
Visitor& visitor() noexcept { Visitor& visitor() noexcept {
return *static_cast<Visitor*>(this); return *static_cast<Visitor*>(this);
@ -171,10 +171,10 @@ public:
template <typename... T> template <typename... T>
explicit async_traversal_frame(T&&... args) explicit async_traversal_frame(T&&... args)
: data_layout_t<Visitor, Args...>(std::forward<T>(args)...) : data_layout_t<Visitor, Args...>(std::forward<T>(args)...)
#ifndef _NDEBUG #ifndef NDEBUG
, ,
finished_(false) finished_(false)
#endif // _NDEBUG #endif // NDEBUG
{ {
} }
@ -211,12 +211,12 @@ public:
/// Calls the visitor with no arguments to signalize that the /// Calls the visitor with no arguments to signalize that the
/// asynchronous traversal was finished. /// asynchronous traversal was finished.
void async_complete() { void async_complete() {
#ifndef _NDEBUG #ifndef NDEBUG
{ {
bool expected = false; bool expected = false;
assert(finished_.compare_exchange_strong(expected, true)); assert(finished_.compare_exchange_strong(expected, true));
} }
#endif // _NDEBUG #endif // NDEBUG
visitor()(async_traverse_complete_tag{}, std::move(this->head())); visitor()(async_traverse_complete_tag{}, std::move(this->head()));
} }