From a7d83f19b08eb4c6f79a82fe60c2b86db13f4420 Mon Sep 17 00:00:00 2001 From: David Robillard Date: Sat, 24 Nov 2018 13:44:03 +0100 Subject: Squashed 'waflib/' changes from 6e726eb1..5ea8f99f 5ea8f99f Improve test output spacing 0e23b29f Raise exception when test suite fails to ensure non-zero exit status d6de073b Show run time of unit tests 5b655541 Add short configure option for ultra-strict flags 4687ba6d Use gtest-like test output 258903d9 Fix failure count in test group summaries da07e738 Fix verbose tests with Python 3 git-subtree-dir: waflib git-subtree-split: 5ea8f99f6e1246079c1fe6bb590c38a53aadd40d --- src/server/Task.hpp | 120 ---------------------------------------------------- 1 file changed, 120 deletions(-) delete mode 100644 src/server/Task.hpp (limited to 'src/server/Task.hpp') diff --git a/src/server/Task.hpp b/src/server/Task.hpp deleted file mode 100644 index 2cdad71b..00000000 --- a/src/server/Task.hpp +++ /dev/null @@ -1,120 +0,0 @@ -/* - This file is part of Ingen. - Copyright 2007-2017 David Robillard - - Ingen is free software: you can redistribute it and/or modify it under the - terms of the GNU Affero General Public License as published by the Free - Software Foundation, either version 3 of the License, or any later version. - - Ingen is distributed in the hope that it will be useful, but WITHOUT ANY - WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR - A PARTICULAR PURPOSE. See the GNU Affero General Public License for details. - - You should have received a copy of the GNU Affero General Public License - along with Ingen. If not, see . -*/ - -#ifndef INGEN_ENGINE_TASK_HPP -#define INGEN_ENGINE_TASK_HPP - -#include -#include -#include -#include -#include -#include - -namespace Ingen { -namespace Server { - -class BlockImpl; -class RunContext; - -class Task { -public: - enum class Mode { - SINGLE, ///< Single block to run - SEQUENTIAL, ///< Elements must be run sequentially in order - PARALLEL ///< Elements may be run in any order in parallel - }; - - Task(Mode mode, BlockImpl* block = nullptr) - : _block(block) - , _mode(mode) - , _done_end(0) - , _next(0) - , _done(false) - { - assert(!(mode == Mode::SINGLE && !block)); - } - - Task(Task&& task) - : _children(std::move(task._children)) - , _block(task._block) - , _mode(task._mode) - , _done_end(task._done_end) - , _next(task._next.load()) - , _done(task._done.load()) - {} - - Task& operator=(Task&& task) - { - _children = std::move(task._children); - _block = task._block; - _mode = task._mode; - _done_end = task._done_end; - _next = task._next.load(); - _done = task._done.load(); - return *this; - } - - /** Run task in the given context. */ - void run(RunContext& context); - - /** Pretty print task to the given stream (recursively). */ - void dump(std::function sink, unsigned indent, bool first) const; - - /** Return true iff this is an empty task. */ - bool empty() const { return _mode != Mode::SINGLE && _children.empty(); } - - /** Simplify task expression. */ - static std::unique_ptr simplify(std::unique_ptr&& task); - - /** Steal a child task from this task (succeeds for PARALLEL only). */ - Task* steal(RunContext& context); - - /** Prepend a child to this task. */ - void push_front(Task&& task) { - _children.emplace_front(std::unique_ptr(new Task(std::move(task)))); - } - - Mode mode() const { return _mode; } - BlockImpl* block() const { return _block; } - bool done() const { return _done; } - - void set_done(bool done) { _done = done; } - -private: - typedef std::deque> Children; - - Task(const Task&) = delete; - Task& operator=(const Task&) = delete; - - Task* get_task(RunContext& context); - - void append(std::unique_ptr&& t) { - _children.emplace_back(std::move(t)); - } - - Children _children; ///< Vector of child tasks - BlockImpl* _block; ///< Used for SINGLE only - Mode _mode; ///< Execution mode - unsigned _done_end; ///< Index of rightmost done sub-task - std::atomic _next; ///< Index of next sub-task - std::atomic _done; ///< Completion phase -}; - -} // namespace Server -} // namespace Ingen - -#endif // INGEN_ENGINE_TASK_HPP -- cgit v1.2.1