flow.hpp

#ifndef ENTT_GRAPH_FLOW_HPP
#define ENTT_GRAPH_FLOW_HPP
 
#include "../config/config.h"
#include "../container/dense_map.hpp"
#include "../container/dense_set.hpp"
#include "../core/compressed_pair.hpp"
#include "../core/fwd.hpp"
#include "../core/iterator.hpp"
#include "../stl/algorithm.hpp"
#include "../stl/concepts.hpp"
#include "../stl/cstddef.hpp"
#include "../stl/functional.hpp"
#include "../stl/iterator.hpp"
#include "../stl/memory.hpp"
#include "../stl/type_traits.hpp"
#include "../stl/utility.hpp"
#include "../stl/vector.hpp"
#include "adjacency_matrix.hpp"
#include "fwd.hpp"
 
namespace entt {

template<typename Allocator>
class basic_flow {
    using alloc_traits = stl::allocator_traits<Allocator>;
    static_assert(stl::is_same_v<typename alloc_traits::value_type, id_type>, "Invalid value type");
    using task_container_type = dense_set<id_type, stl::identity, stl::equal_to<>, typename alloc_traits::template rebind_alloc<id_type>>;
    using ro_rw_container_type = stl::vector<stl::pair<stl::size_t, bool>, typename alloc_traits::template rebind_alloc<stl::pair<stl::size_t, bool>>>;
    using deps_container_type = dense_map<id_type, ro_rw_container_type, stl::identity, stl::equal_to<>, typename alloc_traits::template rebind_alloc<stl::pair<const id_type, ro_rw_container_type>>>;
    using adjacency_matrix_type = adjacency_matrix<directed_tag, typename alloc_traits::template rebind_alloc<stl::size_t>>;
 
    void emplace(const id_type res, const bool is_rw) {
        ENTT_ASSERT(index.first() < vertices.size(), "Invalid node");
 
        if(!deps.contains(res) && sync_on != vertices.size()) {
            deps[res].emplace_back(sync_on, true);
        }
 
        deps[res].emplace_back(index.first(), is_rw);
    }
 
    void setup_graph(adjacency_matrix_type &matrix) const {
        for(const auto &elem: deps) {
            const auto last = elem.second.cend();
            auto it = elem.second.cbegin();
 
            while(it != last) {
                if(it->second) {
                    // rw item
                    if(auto curr = it++; it != last) {
                        if(it->second) {
                            matrix.insert(curr->first, it->first);
                        } else if(const auto next = stl::find_if(it, last, [](const auto &value) { return value.second; }); next != last) {
                            for(; it != next; ++it) {
                                matrix.insert(curr->first, it->first);
                                matrix.insert(it->first, next->first);
                            }
                        } else {
                            for(; it != next; ++it) {
                                matrix.insert(curr->first, it->first);
                            }
                        }
                    }
                } else {
                    // ro item (first iteration only)
                    if(const auto next = stl::find_if(it, last, [](const auto &value) { return value.second; }); next != last) {
                        for(; it != next; ++it) {
                            matrix.insert(it->first, next->first);
                        }
                    } else {
                        it = last;
                    }
                }
            }
        }
    }
 
    void transitive_closure(adjacency_matrix_type &matrix) const {
        const auto length = matrix.size();
 
        for(stl::size_t vk{}; vk < length; ++vk) {
            for(stl::size_t vi{}; vi < length; ++vi) {
                for(stl::size_t vj{}; vj < length; ++vj) {
                    if(matrix.contains(vi, vk) && matrix.contains(vk, vj)) {
                        matrix.insert(vi, vj);
                    }
                }
            }
        }
    }
 
    void transitive_reduction(adjacency_matrix_type &matrix) const {
        const auto length = matrix.size();
 
        for(stl::size_t vert{}; vert < length; ++vert) {
            matrix.erase(vert, vert);
        }
 
        for(stl::size_t vj{}; vj < length; ++vj) {
            for(stl::size_t vi{}; vi < length; ++vi) {
                if(matrix.contains(vi, vj)) {
                    for(stl::size_t vk{}; vk < length; ++vk) {
                        if(matrix.contains(vj, vk)) {
                            matrix.erase(vi, vk);
                        }
                    }
                }
            }
        }
    }
 
public:
    using allocator_type = Allocator;
    using size_type = stl::size_t;
    using iterable = iterable_adaptor<typename task_container_type::const_iterator>;
    using graph_type = adjacency_matrix_type;

    basic_flow()
        : basic_flow{allocator_type{}} {}

    explicit basic_flow(const allocator_type &allocator)
        : index{0u, allocator},
          vertices{allocator},
          deps{allocator} {}

    basic_flow(const basic_flow &) = default;

    basic_flow(const basic_flow &other, const allocator_type &allocator)
        : index{other.index.first(), allocator},
          vertices{other.vertices, allocator},
          deps{other.deps, allocator},
          sync_on{other.sync_on} {}

    basic_flow(basic_flow &&) noexcept = default;

    basic_flow(basic_flow &&other, const allocator_type &allocator)
        : index{other.index.first(), allocator},
          vertices{stl::move(other.vertices), allocator},
          deps{stl::move(other.deps), allocator},
          sync_on{other.sync_on} {}

    ~basic_flow() = default;

    basic_flow &operator=(const basic_flow &) = default;

    basic_flow &operator=(basic_flow &&) noexcept = default;

    void swap(basic_flow &other) noexcept {
        using stl::swap;
        swap(index, other.index);
        swap(vertices, other.vertices);
        swap(deps, other.deps);
        swap(sync_on, other.sync_on);
    }

    [[nodiscard]] constexpr allocator_type get_allocator() const noexcept {
        return allocator_type{index.second()};
    }

    [[nodiscard]] id_type operator[](const size_type pos) const {
        return vertices.cbegin()[static_cast<task_container_type::difference_type>(pos)];
    }

    void clear() noexcept {
        index.first() = {};
        vertices.clear();
        deps.clear();
        sync_on = {};
    }

    [[nodiscard]] bool empty() const noexcept {
        return vertices.empty();
    }

    [[nodiscard]] size_type size() const noexcept {
        return vertices.size();
    }

    basic_flow &bind(const id_type value) {
        sync_on += (sync_on == vertices.size());
        const auto it = vertices.emplace(value).first;
        index.first() = size_type(it - vertices.begin());
        return *this;
    }

    basic_flow &sync() {
        ENTT_ASSERT(index.first() < vertices.size(), "Invalid node");
        sync_on = index.first();
 
        for(const auto &elem: deps) {
            elem.second.emplace_back(sync_on, true);
        }
 
        return *this;
    }

    basic_flow &set(const id_type res, bool is_rw = false) {
        emplace(res, is_rw);
        return *this;
    }

    basic_flow &ro(const id_type res) {
        emplace(res, false);
        return *this;
    }

    basic_flow &ro(stl::input_iterator auto first, stl::input_iterator auto last) {
        for(; first != last; ++first) {
            emplace(*first, false);
        }
 
        return *this;
    }

    basic_flow &rw(const id_type res) {
        emplace(res, true);
        return *this;
    }

    basic_flow &rw(stl::input_iterator auto first, stl::input_iterator auto last) {
        for(; first != last; ++first) {
            emplace(*first, true);
        }
 
        return *this;
    }

    [[nodiscard]] graph_type graph() const {
        graph_type matrix{vertices.size(), get_allocator()};
 
        setup_graph(matrix);
        transitive_closure(matrix);
        transitive_reduction(matrix);
 
        return matrix;
    }
 
private:
    compressed_pair<size_type, allocator_type> index;
    task_container_type vertices;
    deps_container_type deps;
    size_type sync_on{};
};
 
} // namespace entt
 
#endif