schedule_test.cpp

#include <migraphx/schedule.hpp>
#include <migraphx/pass_manager.hpp>
#include <migraphx/generate.hpp>
#include <migraphx/instruction.hpp>
#include <migraphx/iterator_for.hpp>
#include <migraphx/ranges.hpp>
#include <migraphx/dfor.hpp>
#include <basic_ops.hpp>
#include <migraphx/make_op.hpp>

#include <test.hpp>

struct unary_op
{
    std::string name() const { return "unary"; }
    migraphx::argument
    compute(migraphx::context&, const migraphx::shape&, std::vector<migraphx::argument> args) const
    {
        if(args.empty())
            return {};
        return args.front();
    }

    migraphx::shape compute_shape(std::vector<migraphx::shape> inputs) const
    {
        if(inputs.empty())
            return {};
        return inputs.front();
    }
    int output_alias(const std::vector<migraphx::shape>&) const { return 0; }
};

struct nary_op
{
    std::string comment;
    template <class Self, class F>
    static auto reflect(Self& self, F f)
    {
        return migraphx::pack(f(self.comment, "comment"));
    }
    std::string name() const { return "nary"; }
    migraphx::argument
    compute(migraphx::context&, const migraphx::shape&, std::vector<migraphx::argument> args) const
    {
        if(args.empty())
            return {};
        return args.front();
    }

    migraphx::shape compute_shape(std::vector<migraphx::shape> inputs) const
    {
        if(inputs.empty())
            return {};
        return inputs.front();
    }
};

struct stream_free_op
{
    std::string comment;
    template <class Self, class F>
    static auto reflect(Self& self, F f)
    {
        return migraphx::pack(f(self.comment, "comment"));
    }
    std::string name() const { return "stream_free"; }
    migraphx::argument
    compute(migraphx::context&, const migraphx::shape&, std::vector<migraphx::argument> args) const
    {
        if(args.empty())
            return {};
        return args.front();
    }

    migraphx::shape compute_shape(std::vector<migraphx::shape> inputs) const
    {
        if(inputs.empty())
            return {};
        return inputs.front();
    }
};

struct wait_event
{
    std::shared_ptr<std::vector<int>> wait_for = std::make_shared<std::vector<int>>();
    template <class Self, class F>
    static auto reflect(Self& self, F f)
    {
        return migraphx::pack(f(*self.wait_for, "wait_for"));
    }
    std::string name() const { return "wait_event"; }
    migraphx::shape compute_shape(const std::vector<migraphx::shape>&) const { return {}; }

    migraphx::argument compute(migraphx::context&,
                               const migraphx::shape&,
                               const std::vector<migraphx::argument>&) const
    {
        assert(wait_for != nullptr);
        assert(not wait_for->empty());
        return {};
    }
};

using instruction_map = std::unordered_map<migraphx::instruction_ref, int>;
using int_map         = std::unordered_map<int, int>;
using wait_map = std::unordered_map<migraphx::instruction_ref, std::shared_ptr<std::vector<int>>>;

struct schedule_model_test
{
    std::shared_ptr<instruction_map> ins2stream = std::make_shared<instruction_map>();
    std::shared_ptr<int_map> wait2stream        = std::make_shared<int_map>();
    std::shared_ptr<wait_map> ins2wait_for      = std::make_shared<wait_map>();
    int concurrency() const { return 4; }
    void sched(migraphx::module&, migraphx::instruction_ref ins, int n) const
    {
        (*ins2stream)[ins] = n;
    }
    void wait(migraphx::module& m, migraphx::instruction_ref ins, int wait_id) const
    {
        if(ins2wait_for->count(ins) == 0)
        {
            auto event = wait_event{};
            m.insert_instruction(ins, event);
            (*ins2wait_for)[ins] = event.wait_for;
        }
        (*ins2wait_for)[ins]->push_back(wait2stream->at(wait_id));
    }
    void record(migraphx::module&, migraphx::instruction_ref ins, int wait_id) const
    {
        (*wait2stream)[wait_id] = ins2stream->at(ins);
    }
    int weight(const migraphx::operation& op) const
    {
        if(op.name() == "stream_free")
            return 0;
        else if(op.name() == "binary" or op.name() == "unary")
            return 4;
        else
            return 1;
    }
};

bool check_conflicts(migraphx::module& m, migraphx::instruction_ref x, migraphx::instruction_ref y)
{
    return migraphx::any_of(migraphx::iterator_for(m), [&](auto ins) {
        if(ins->name() != "identity")
            return false;
        if(not migraphx::contains(ins->inputs(), x))
            return false;
        if(not migraphx::contains(ins->inputs(), y))
            return false;
        return true;
    });
}

struct scheduler
{
    schedule_model_test model{};

    int get_stream(migraphx::instruction_ref ins) { return model.ins2stream->at(ins); }

    std::vector<int> get_streams(std::vector<migraphx::instruction_ref> inss)
    {
        std::vector<int> result;
        std::transform(inss.begin(), inss.end(), std::back_inserter(result), [&](auto ins) {
            return this->get_stream(ins);
        });
        return result;
    }

    void run_pass(migraphx::module& m) { migraphx::run_passes(m, {migraphx::schedule{model}}); }

    bool has_stream(migraphx::instruction_ref ins) { return model.ins2stream->count(ins) > 0; }

    void check_conflicts(migraphx::module& m,
                         std::vector<std::vector<migraphx::instruction_ref>> conflicts,
                         bool result = true)
    {
        migraphx::dfor(conflicts.size(), conflicts.size())([&](auto i, auto j) {
            if(i == j)
                return;
            for(auto ins1 : conflicts[i])
            {
                for(auto ins2 : conflicts[j])
                {
                    // If both instructions are on the same stream then dont check for a conflict
                    if(this->has_stream(ins1) and this->has_stream(ins2) and
                       this->get_stream(ins1) == this->get_stream(ins2))
                        continue;
                    CHECK(::check_conflicts(m, ins1, ins2) == result);
                }
            }
        });
    }
};

template <class T>
std::vector<T> sorted(std::vector<T> x)
{
    std::sort(x.begin(), x.end());
    return x;
}

template <class T>
std::vector<T> unique(std::vector<T> x)
{
    std::sort(x.begin(), x.end());
    x.erase(std::unique(x.begin(), x.end()), x.end());
    return x;
}

std::vector<int> get_wait_for(std::vector<int> wait_for) { return unique(std::move(wait_for)); }

std::vector<int> get_wait_for(int wait_on, std::vector<int> wait_for)
{
    wait_for.erase(std::find(wait_for.begin(), wait_for.end(), wait_on));
    return unique(wait_for);
}

std::vector<int> get_wait_for(migraphx::instruction_ref ins)
{
    auto wait_ins = std::prev(ins);
    // Skip identity operators
    while(wait_ins->name() == "identity")
        wait_ins = std::prev(wait_ins);
    if(wait_ins->name() != "wait_event")
        return {};
    auto wf = *migraphx::any_cast<wait_event>(wait_ins->get_operator()).wait_for;
    std::sort(wf.begin(), wf.end());
    return wf;
}

template <class T>
std::vector<migraphx::instruction_ref>
chain(migraphx::module& m, int n, T x, migraphx::instruction_ref input)
{
    std::vector<migraphx::instruction_ref> result;
    for(int i = 0; i < n; i++)
    {
        result.push_back(m.add_instruction(x, input));
        input = result.back();
    }
    return result;
}
TEST_CASE(single_entry)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto onem1  = m.add_instruction(unary_op{}, one);
    auto onem2  = m.add_instruction(unary_op{}, one);
    auto binary = m.add_instruction(nary_op{}, onem1, onem2);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(onem1) != t.get_stream(onem2));
    EXPECT(t.get_stream(binary) == 0);
    EXPECT(get_wait_for(binary) ==
           get_wait_for(t.get_stream(binary), {t.get_stream(onem1), t.get_stream(onem2)}));
    EXPECT(check_conflicts(m, onem1, onem2));
}

TEST_CASE(stream_free)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto onem1  = m.add_instruction(stream_free_op{}, one);
    auto onem2  = m.add_instruction(stream_free_op{}, one);
    auto binary = m.add_instruction(nary_op{}, onem1, onem2);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(not t.has_stream(onem1));
    EXPECT(not t.has_stream(onem2));
    EXPECT(not t.has_stream(binary));
}

TEST_CASE(zero_record)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto onem1  = m.add_instruction(unary_op{}, one);
    auto onem2  = m.add_instruction(unary_op{}, one);
    auto onei1  = m.add_instruction(migraphx::make_op("identity"), onem1);
    auto onei2  = m.add_instruction(migraphx::make_op("identity"), onem2);
    auto binary = m.add_instruction(nary_op{}, onei1, onei2);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(onem1) != t.get_stream(onem2));
    EXPECT(t.has_stream(binary));
    EXPECT(get_wait_for(binary) ==
           get_wait_for(t.get_stream(binary), {t.get_stream(onem1), t.get_stream(onem2)}));
    EXPECT(check_conflicts(m, onem1, onem2));
    t.check_conflicts(m, {{onem1, onei1}, {onem2, onei2}});
}

TEST_CASE(zero_merge1)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto onem1  = m.add_instruction(unary_op{}, one);
    auto onem2  = m.add_instruction(unary_op{}, one);
    auto binary = m.add_instruction(migraphx::make_op("identity"), onem1, onem2);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(onem1) != t.get_stream(onem2));
    // No stream assignment
    EXPECT(not t.has_stream(binary));
    // There is no wait
    EXPECT(get_wait_for(binary).empty());
    EXPECT(check_conflicts(m, onem1, onem2));
}

TEST_CASE(zero_merge2)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto onem1  = m.add_instruction(unary_op{}, one);
    auto onem2  = m.add_instruction(unary_op{}, one);
    auto binary = m.add_instruction(migraphx::make_op("identity"),
                                    m.add_instruction(migraphx::make_op("identity"), onem1),
                                    m.add_instruction(migraphx::make_op("identity"), onem2));
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(onem1) != t.get_stream(onem2));
    // No stream assignment
    EXPECT(not t.has_stream(binary));
    // There is no wait
    EXPECT(get_wait_for(binary).empty());
    EXPECT(check_conflicts(m, onem1, onem2));
}

TEST_CASE(zero_merge3)
{
    scheduler t{};
    migraphx::module m;

    auto one   = m.add_literal(1);
    auto onem1 = m.add_instruction(unary_op{}, one);
    auto onem2 = m.add_instruction(unary_op{}, one);
    auto id    = m.add_instruction(migraphx::make_op("identity"), onem1, onem2);
    auto final = m.add_instruction(unary_op{}, id);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(onem1) != t.get_stream(onem2));
    // No stream assignment
    EXPECT(not t.has_stream(id));
    // There is no wait
    EXPECT(get_wait_for(id).empty());
    // Stream assignment for final op
    EXPECT(t.get_stream(final) == 0);
    EXPECT(get_wait_for(final) ==
           get_wait_for(t.get_stream(final), {t.get_stream(onem1), t.get_stream(onem2)}));
    EXPECT(check_conflicts(m, onem1, onem2));
}

TEST_CASE(zero_merge4)
{
    scheduler t{};
    migraphx::module m;

    auto one   = m.add_literal(1);
    auto onem1 = m.add_instruction(unary_op{}, one);
    auto onem2 = m.add_instruction(unary_op{}, one);
    auto id    = m.add_instruction(migraphx::make_op("identity"),
                                m.add_instruction(migraphx::make_op("identity"), onem1),
                                m.add_instruction(migraphx::make_op("identity"), onem2));
    auto final = m.add_instruction(unary_op{}, id);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(onem1) != t.get_stream(onem2));
    // No stream assignment
    EXPECT(not t.has_stream(id));
    // There is no wait
    EXPECT(get_wait_for(id).empty());
    // Stream assignment for final op
    EXPECT(t.get_stream(final) == 0);
    EXPECT(get_wait_for(final) ==
           get_wait_for(t.get_stream(final), {t.get_stream(onem1), t.get_stream(onem2)}));
    EXPECT(check_conflicts(m, onem1, onem2));
}

TEST_CASE(double_entry)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_instruction(stream_free_op{}, m.add_literal(1));
    auto two    = m.add_instruction(stream_free_op{}, m.add_literal(2));
    auto onep   = m.add_instruction(unary_op{}, one);
    auto twop   = m.add_instruction(unary_op{}, two);
    auto binary = m.add_instruction(nary_op{}, onep, twop);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(not t.has_stream(two));
    EXPECT(t.get_stream(onep) != t.get_stream(twop));
    EXPECT(t.get_stream(binary) == 0);
    EXPECT(get_wait_for(binary) ==
           get_wait_for(t.get_stream(binary), {t.get_stream(onep), t.get_stream(twop)}));
    t.check_conflicts(m, {{onep, one}, {twop, two}});
}

TEST_CASE(two_branches)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto c1     = chain(m, 2, unary_op{}, one);
    auto i1     = m.add_instruction(unary_op{}, one);
    auto binary = m.add_instruction(nary_op{}, i1, c1.back());
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(i1) == 1);
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == 0);
    EXPECT(t.get_stream(binary) == 0);
    EXPECT(get_wait_for(binary) ==
           get_wait_for(t.get_stream(binary), {t.get_stream(c1.back()), t.get_stream(i1)}));
    t.check_conflicts(m, {c1, {i1}});
}

TEST_CASE(four_branches)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto c1     = chain(m, 4, unary_op{}, one);
    auto c2     = chain(m, 3, unary_op{}, one);
    auto c3     = chain(m, 2, unary_op{}, one);
    auto i1     = m.add_instruction(unary_op{}, one);
    auto binary = m.add_instruction(nary_op{}, i1, c1.back(), c2.back(), c3.back());
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(i1) == 3);
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == 0);
    for(auto ins : c2)
        EXPECT(t.get_stream(ins) == 1);
    for(auto ins : c3)
        EXPECT(t.get_stream(ins) == 2);
    EXPECT(t.get_stream(binary) == 0);
    EXPECT(get_wait_for(binary) == get_wait_for(t.get_stream(binary),
                                                {t.get_stream(c1.back()),
                                                 t.get_stream(c2.back()),
                                                 t.get_stream(c3.back()),
                                                 t.get_stream(i1)}));
    t.check_conflicts(m, {c1, c2, c3, {i1}});
}

TEST_CASE(five_branches)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto c1     = chain(m, 5, unary_op{}, one);
    auto c2     = chain(m, 4, unary_op{}, one);
    auto c3     = chain(m, 3, unary_op{}, one);
    auto c4     = chain(m, 2, unary_op{}, one);
    auto i1     = m.add_instruction(unary_op{}, one);
    auto binary = m.add_instruction(nary_op{}, i1, c1.back(), c2.back(), c3.back(), c4.back());
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(i1) == 3);
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == 0);
    for(auto ins : c2)
        EXPECT(t.get_stream(ins) == 1);
    for(auto ins : c3)
        EXPECT(t.get_stream(ins) == 2);
    for(auto ins : c4)
        EXPECT(t.get_stream(ins) == 3);
    EXPECT(t.get_stream(binary) == 0);
    EXPECT(get_wait_for(binary) == get_wait_for(t.get_stream(binary),
                                                {t.get_stream(c1.back()),
                                                 t.get_stream(c2.back()),
                                                 t.get_stream(c3.back()),
                                                 t.get_stream(i1)}));
    t.check_conflicts(m, {c1, c2, c3, c4});
    t.check_conflicts(m, {c1, c2, c3, {i1}});
}

TEST_CASE(four_branches_eq)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto onem1  = m.add_instruction(unary_op{}, one);
    auto onem2  = m.add_instruction(unary_op{}, one);
    auto onep3  = m.add_instruction(unary_op{}, one);
    auto onep4  = m.add_instruction(unary_op{}, one);
    auto binary = m.add_instruction(nary_op{}, onem1, onem2, onep3, onep4);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(
        sorted<int>(
            {t.get_stream(onem1), t.get_stream(onem2), t.get_stream(onep3), t.get_stream(onep4)}) ==
        unique<int>(
            {t.get_stream(onem1), t.get_stream(onem2), t.get_stream(onep3), t.get_stream(onep4)}));
    EXPECT(t.get_stream(binary) == 0);
    EXPECT(
        get_wait_for(binary) ==
        get_wait_for(
            t.get_stream(binary),
            {t.get_stream(onem1), t.get_stream(onem2), t.get_stream(onep3), t.get_stream(onep4)}));
    t.check_conflicts(m, {{onem1}, {onem2}, {onep3}, {onep4}});
}

TEST_CASE(seq_merge)
{
    scheduler t{};
    migraphx::module m;

    auto one     = m.add_literal(1);
    auto c1      = chain(m, 2, unary_op{}, one);
    auto i1      = m.add_instruction(unary_op{}, one);
    auto binary1 = m.add_instruction(nary_op{}, i1, c1.back());

    auto c2      = chain(m, 2, unary_op{}, binary1);
    auto i2      = m.add_instruction(unary_op{}, binary1);
    auto binary2 = m.add_instruction(nary_op{}, i2, c2.back());

    t.run_pass(m);
    EXPECT(not t.has_stream(one));

    EXPECT(t.get_stream(i1) != t.get_stream(c1.back()));
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == t.get_stream(c1.back()));
    EXPECT(t.get_stream(binary1) == t.get_stream(c1.back()));
    EXPECT(get_wait_for(binary1) ==
           get_wait_for(t.get_stream(binary1), {t.get_stream(c1.back()), t.get_stream(i1)}));
    t.check_conflicts(m, {c1, {i1}});

    EXPECT(t.get_stream(i2) != t.get_stream(c2.back()));
    for(auto ins : c2)
        EXPECT(t.get_stream(ins) == t.get_stream(c2.back()));
    EXPECT(t.get_stream(binary2) == 0);
    EXPECT(get_wait_for(binary2) ==
           get_wait_for(t.get_stream(binary2), {t.get_stream(c2.back()), t.get_stream(i2)}));
    t.check_conflicts(m, {c2, {i2}});
}

TEST_CASE(par_merge)
{
    scheduler t{};
    migraphx::module m;

    auto one     = m.add_literal(1);
    auto start1  = m.add_instruction(unary_op{}, one);
    auto c1      = chain(m, 3, unary_op{}, start1);
    auto i1      = m.add_instruction(unary_op{}, start1);
    auto binary1 = m.add_instruction(nary_op{}, i1, c1.back());

    auto start2  = m.add_instruction(unary_op{}, one);
    auto c2      = chain(m, 2, unary_op{}, start2);
    auto i2      = m.add_instruction(unary_op{}, start2);
    auto binary2 = m.add_instruction(nary_op{}, i2, c2.back());

    auto binary3 = m.add_instruction(nary_op{}, binary1, binary2);

    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(binary3) == 0);

    EXPECT(t.get_stream(i1) != t.get_stream(i2));
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == 0);
    EXPECT(t.get_stream(binary1) == 0);
    EXPECT(get_wait_for(binary1) ==
           get_wait_for(t.get_stream(binary1), {t.get_stream(c1.back()), t.get_stream(i1)}));
    t.check_conflicts(m, {c1, {i1}});

    for(auto ins : c2)
        EXPECT(t.get_stream(ins) == t.get_stream(binary2));
    EXPECT(t.get_stream(binary2) != t.get_stream(i1));
    EXPECT(t.get_stream(binary2) != t.get_stream(i2));
    EXPECT(get_wait_for(binary2) ==
           get_wait_for(t.get_stream(binary2), {t.get_stream(c2.back()), t.get_stream(i2)}));
    t.check_conflicts(m, {c2, {i2}});

    EXPECT(check_conflicts(m, binary1, binary2));
    t.check_conflicts(m, {c1, {i1}, c2, {i2}});
}

TEST_CASE(inner_par_merge)
{
    scheduler t{};
    migraphx::module m;

    auto one     = m.add_literal(1);
    auto start1  = m.add_instruction(unary_op{}, one);
    auto c1      = chain(m, 3, unary_op{}, start1);
    auto i1      = m.add_instruction(unary_op{}, start1);
    auto binary1 = m.add_instruction(nary_op{}, i1, c1.back());

    auto start2  = m.add_instruction(unary_op{}, one);
    auto c2      = chain(m, 2, unary_op{}, start2);
    auto i2      = m.add_instruction(unary_op{}, start2);
    auto binary2 = m.add_instruction(nary_op{}, i2, c2.back());

    auto outer1 = m.add_instruction(unary_op{}, one);
    auto outer2 = m.add_instruction(unary_op{}, one);

    auto output = m.add_instruction(nary_op{}, binary1, binary2, outer1, outer2);

    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(output) == 0);
    EXPECT(get_wait_for(output) == get_wait_for(t.get_stream(output),
                                                {t.get_stream(binary1),
                                                 t.get_stream(binary2),
                                                 t.get_stream(outer1),
                                                 t.get_stream(outer2)}));

    EXPECT(t.get_stream(outer1) != t.get_stream(outer2));
    EXPECT(migraphx::contains({1, 2}, t.get_stream(outer1)));
    EXPECT(migraphx::contains({1, 2}, t.get_stream(outer2)));

    EXPECT(t.get_stream(i1) != t.get_stream(i2));
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == 0);
    EXPECT(t.get_stream(binary1) == 0);
    EXPECT(get_wait_for(binary1) ==
           get_wait_for(t.get_stream(binary1), {t.get_stream(c1.back()), t.get_stream(i1)}));
    t.check_conflicts(m, {c1, {i1}});

    for(auto ins : c2)
        EXPECT(t.get_stream(ins) == t.get_stream(binary2));
    EXPECT(t.get_stream(binary2) != t.get_stream(i1));
    EXPECT(t.get_stream(binary2) != t.get_stream(i2));
    EXPECT(get_wait_for(binary2) ==
           get_wait_for(t.get_stream(binary2), {t.get_stream(c2.back()), t.get_stream(i2)}));
    t.check_conflicts(m, {c2, {i2}});

    EXPECT(check_conflicts(m, binary1, binary2));
    t.check_conflicts(m, {c1, {i1}, c2, {i2}, {outer1}, {outer2}});
}

TEST_CASE(par_merge_multi_entry)
{
    scheduler t{};
    migraphx::module m;

    auto one     = m.add_literal(1);
    auto start1  = m.add_instruction(unary_op{}, one);
    auto c1      = chain(m, 3, unary_op{}, start1);
    auto i1      = m.add_instruction(unary_op{}, start1);
    auto binary1 = m.add_instruction(nary_op{}, i1, c1.back());

    auto two     = m.add_literal(1);
    auto start2  = m.add_instruction(unary_op{}, two);
    auto c2      = chain(m, 2, unary_op{}, start2);
    auto i2      = m.add_instruction(unary_op{}, start2);
    auto binary2 = m.add_instruction(nary_op{}, i2, c2.back());

    auto binary3 = m.add_instruction(nary_op{}, binary1, binary2);

    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(not t.has_stream(two));
    EXPECT(t.get_stream(binary3) == 0);

    EXPECT(t.get_stream(i1) != t.get_stream(i2));
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == 0);
    EXPECT(t.get_stream(binary1) == 0);
    EXPECT(get_wait_for(binary1) ==
           get_wait_for(t.get_stream(binary1), {t.get_stream(c1.back()), t.get_stream(i1)}));
    t.check_conflicts(m, {c1, {i1}});

    for(auto ins : c2)
        EXPECT(t.get_stream(ins) == t.get_stream(binary2));
    EXPECT(t.get_stream(binary2) != t.get_stream(i1));
    EXPECT(t.get_stream(binary2) != t.get_stream(i2));
    EXPECT(get_wait_for(binary2) ==
           get_wait_for(t.get_stream(binary2), {t.get_stream(c2.back()), t.get_stream(i2)}));
    t.check_conflicts(m, {c2, {i2}});

    EXPECT(check_conflicts(m, binary1, binary2));
    t.check_conflicts(m, {c1, {i1}, c2, {i2}});
}

TEST_CASE(inner_split1)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto c1     = chain(m, 2, unary_op{}, one);
    auto i1     = m.add_instruction(unary_op{}, one);
    auto s1     = m.add_instruction(unary_op{}, c1);
    auto s2     = m.add_instruction(unary_op{}, c1);
    auto output = m.add_instruction(nary_op{}, i1, s1, s2);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(i1) != t.get_stream(s1));
    EXPECT(t.get_stream(i1) != t.get_stream(s2));
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) != t.get_stream(i1));
    EXPECT(t.get_stream(s1) != t.get_stream(s2));

    EXPECT(t.get_stream(output) == 0);
    EXPECT(
        get_wait_for(output) ==
        get_wait_for(t.get_stream(output), {t.get_stream(i1), t.get_stream(s1), t.get_stream(s2)}));
    // Either s1 or s2 has a wait depending on the sort order but not both
    EXPECT(get_wait_for(s1).empty() xor get_wait_for(s2).empty());
    t.check_conflicts(m, {c1, {i1}, {s1}, {s2}});
}

TEST_CASE(inner_split2)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto c1     = chain(m, 2, unary_op{}, one);
    auto i1     = m.add_instruction(unary_op{}, one);
    auto s1     = chain(m, 3, unary_op{}, c1.back());
    auto s2     = chain(m, 4, unary_op{}, c1.back());
    auto output = m.add_instruction(nary_op{}, i1, s1.back(), s2.back());
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(i1) != t.get_stream(s1.back()));
    EXPECT(t.get_stream(i1) != t.get_stream(s2.back()));
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) != t.get_stream(i1));
    EXPECT(t.get_stream(s1.back()) != t.get_stream(s2.back()));

    EXPECT(t.get_stream(output) == 0);
    EXPECT(get_wait_for(output) ==
           get_wait_for(t.get_stream(output),
                        {t.get_stream(i1), t.get_stream(s1.back()), t.get_stream(s2.back())}));
    EXPECT(get_wait_for(s1.front()) == get_wait_for({t.get_stream(c1.back())}));
    t.check_conflicts(m, {c1, {i1}, s1, s2});
}

TEST_CASE(inception_resnet)
{
    scheduler t{};
    migraphx::module m;

    auto one    = m.add_literal(1);
    auto input  = m.add_instruction(unary_op{}, one);
    auto c1     = chain(m, 2, unary_op{}, input);
    auto i1     = m.add_instruction(unary_op{}, input);
    auto binary = m.add_instruction(nary_op{}, i1, c1.back());
    auto output = m.add_instruction(nary_op{}, binary, input);
    t.run_pass(m);
    EXPECT(not t.has_stream(one));
    EXPECT(t.get_stream(i1) != 0);
    for(auto ins : c1)
        EXPECT(t.get_stream(ins) == 0);
    EXPECT(t.get_stream(binary) == 0);
    EXPECT(get_wait_for(binary) ==
           get_wait_for(t.get_stream(binary), {t.get_stream(c1.back()), t.get_stream(i1)}));
    EXPECT(t.get_stream(output) == 0);
    EXPECT(get_wait_for(output).empty());
    t.check_conflicts(m, {c1, {i1}});
}

TEST_CASE(dominate_conflicts)
{
    scheduler t{};
    migraphx::module m;

    auto one     = m.add_literal(1);
    auto onep1   = m.add_instruction(unary_op{}, one);
    auto onep2   = m.add_instruction(unary_op{}, one);
    auto binary1 = m.add_instruction(nary_op{}, onep1, onep2);
    auto onep3   = m.add_instruction(unary_op{}, binary1);
    auto onep4   = m.add_instruction(unary_op{}, binary1);
    auto binary2 = m.add_instruction(nary_op{}, onep3, onep4);
    t.run_pass(m);

    EXPECT(t.get_stream(onep1) != t.get_stream(onep2));
    EXPECT(t.get_stream(onep3) != t.get_stream(onep4));
    EXPECT(get_wait_for(binary1) ==
           get_wait_for(t.get_stream(binary1), {t.get_stream(onep1), t.get_stream(onep2)}));
    t.check_conflicts(m, {{onep1}, {onep2}});
    t.check_conflicts(m, {{onep3}, {onep4}});

    t.check_conflicts(m, {{onep1, onep2}, {onep3, onep4}}, false);
    t.check_conflicts(m, {{binary1}, {binary2}}, false);
}

TEST_CASE(inception1)
{
    scheduler t{};
    migraphx::module m;

    auto i1     = m.add_literal(0);
    auto i2     = m.add_literal(1);
    auto i3     = m.add_literal(1);
    auto i4     = m.add_literal(2);
    auto i7     = m.add_instruction(nary_op{"i7"}, i1, i4, i3, i2);
    auto i8     = m.add_literal(2);
    auto i9     = m.add_instruction(migraphx::make_op("identity"), i8);
    auto i10    = m.add_literal(1);
    auto i11    = m.add_instruction(nary_op{"i11"}, i7, i9, i10);
    auto i12    = m.add_literal(2);
    auto i13    = m.add_instruction(migraphx::make_op("identity"), i12);
    auto i14    = m.add_literal(1);
    auto i15    = m.add_literal(1);
    auto i16    = m.add_literal(2);
    auto i17    = m.add_instruction(nary_op{"i17"}, i11, i16, i15, i13, i14);
    auto i18    = m.add_literal(2);
    auto i19    = m.add_instruction(migraphx::make_op("identity"), i18);
    auto i20    = m.add_literal(1);
    auto i21    = m.add_literal(1);
    auto i22    = m.add_literal(2);
    auto i23    = m.add_instruction(nary_op{"i23"}, i17, i22, i21, i19, i20);
    auto i24    = m.add_literal(1);
    auto i25    = m.add_instruction(nary_op{"i25"}, i23, i24);
    auto i26    = m.add_literal(2);
    auto i27    = m.add_instruction(migraphx::make_op("identity"), i26);
    auto i28    = m.add_literal(1);
    auto i29    = m.add_literal(1);
    auto i30    = m.add_literal(2);
    auto i31    = m.add_instruction(nary_op{"i31"}, i25, i30, i29, i27, i28);
    auto i32    = m.add_literal(2);
    auto i33    = m.add_instruction(migraphx::make_op("identity"), i32);
    auto i34    = m.add_literal(1);
    auto i35    = m.add_literal(1);
    auto i36    = m.add_literal(2);
    auto i37    = m.add_instruction(nary_op{"i37"}, i31, i36, i35, i33, i34);
    auto i38    = m.add_literal(1);
    auto i39    = m.add_instruction(nary_op{"i39"}, i37, i38);
    auto i41    = m.add_literal(2);
    auto i42    = m.add_instruction(migraphx::make_op("identity"), i41);
    auto i43    = m.add_literal(1);
    auto i44    = m.add_literal(1);
    auto i45    = m.add_literal(2);
    auto i48    = m.add_instruction(nary_op{"i48"}, i39, i45, i44, i42, i43);
    auto i49    = m.add_literal(2);
    auto i50    = m.add_instruction(migraphx::make_op("identity"), i49);
    auto i51    = m.add_literal(1);
    auto i52    = m.add_literal(1);
    auto i53    = m.add_literal(2);
    auto i54    = m.add_instruction(nary_op{"i54"}, i48, i53, i52, i50, i51);
    auto i55    = m.add_literal(1);
    auto i56    = m.add_instruction(migraphx::make_op("identity"), i55);
    auto i57    = m.add_literal(2);
    auto i58    = m.add_instruction(migraphx::make_op("identity"), i57);
    auto i59    = m.add_literal(1);
    auto i60    = m.add_literal(2);
    auto i61    = m.add_instruction(nary_op{"i61"}, i54, i60, i59, i58, i56);
    auto i62    = m.add_literal(2);
    auto i63    = m.add_instruction(migraphx::make_op("identity"), i62);
    auto i64    = m.add_literal(1);
    auto i65    = m.add_literal(1);
    auto i66    = m.add_literal(2);
    auto i69    = m.add_instruction(nary_op{"i69"}, i39, i66, i65, i63, i64);
    auto i70    = m.add_instruction(migraphx::make_op("identity"), i55);
    auto i71    = m.add_literal(2);
    auto i72    = m.add_instruction(migraphx::make_op("identity"), i71);
    auto i73    = m.add_literal(1);
    auto i74    = m.add_literal(2);
    auto i75    = m.add_instruction(nary_op{"i75"}, i69, i74, i73, i72, i70);
    auto i77    = m.add_literal(1);
    auto i80    = m.add_instruction(nary_op{"i80"}, i39, i77);
    auto i81    = m.add_instruction(migraphx::make_op("identity"), i55);
    auto i82    = m.add_literal(2);
    auto i83    = m.add_instruction(migraphx::make_op("identity"), i82);
    auto i84    = m.add_literal(1);
    auto i85    = m.add_literal(2);
    auto i86    = m.add_instruction(nary_op{"i86"}, i80, i85, i84, i83, i81);
    auto i88    = m.add_instruction(migraphx::make_op("identity"), i55);
    auto i89    = m.add_literal(2);
    auto i90    = m.add_instruction(migraphx::make_op("identity"), i89);
    auto i91    = m.add_literal(1);
    auto i92    = m.add_literal(2);
    auto i94    = m.add_instruction(nary_op{"i94"}, i39, i92, i91, i90, i88);
    auto i96    = m.add_instruction(migraphx::make_op("identity"), i55, i94, i75, i61, i86);
    auto i97    = m.add_literal(2);
    auto i98    = m.add_instruction(migraphx::make_op("identity"), i97);
    auto i99    = m.add_literal(3);
    auto i100   = m.add_literal(1);
    auto i101   = m.add_literal(2);
    auto output = m.add_instruction(nary_op{"output"}, i96, i101, i100, i98, i99);

    t.run_pass(m);

    EXPECT(t.get_streams({i7, i11, i17, i23, i25, i31, i37, i39}) ==
           t.get_streams({i7, i7, i7, i7, i7, i7, i7, i7}));
    EXPECT(t.get_streams({i48, i54, i61, output}) ==
           t.get_streams({output, output, output, output}));
    EXPECT(t.get_streams({i80, i86}) == t.get_streams({i80, i80}));
    EXPECT(t.get_streams({i69, i75}) == t.get_streams({i69, i69}));

    EXPECT(t.get_stream(i7) != t.get_stream(i80));
    EXPECT(t.get_stream(i69) != t.get_stream(i80));
    EXPECT(t.get_stream(i69) != t.get_stream(i7));
    EXPECT(t.get_stream(output) != t.get_stream(i69));
    EXPECT(t.get_stream(output) != t.get_stream(i80));

    EXPECT(get_wait_for(i80) == get_wait_for({t.get_stream(i39)}));
    EXPECT(get_wait_for(i69) == get_wait_for({t.get_stream(i39)}));
    EXPECT(get_wait_for(i94) == get_wait_for({t.get_stream(i39)}));
    EXPECT(
        get_wait_for(output) ==
        get_wait_for(t.get_stream(output),
                     {t.get_stream(i94), t.get_stream(i75), t.get_stream(i61), t.get_stream(i86)}));

    t.check_conflicts(m, {{i80, i86}, {i69, i75}, {i48, i54, i61}, {i94}});
}

TEST_CASE(if_pl_test)
{
    migraphx::program p;
    auto* mm = p.get_main_module();
    migraphx::shape cond_s{migraphx::shape::bool_type};
    migraphx::shape xs{migraphx::shape::float_type, {2, 3}};
    migraphx::shape ys{migraphx::shape::float_type, {3, 3}};
    std::vector<float> datax = {1, 2, 3, 4, 5, 6};
    std::vector<float> datay = {8, 7, 6, 5, 4, 3, 2, 1, 0};

    auto lx   = mm->add_literal(migraphx::literal(xs, datax));
    auto ly   = mm->add_literal(migraphx::literal(ys, datay));
    auto cond = mm->add_parameter("cond", cond_s);
    auto x    = mm->add_parameter("x", xs);
    auto y    = mm->add_parameter("y", ys);

    auto* then_mod = p.create_module("If_5_if");
    auto l1        = then_mod->add_literal(migraphx::literal(ys, datay));
    auto a1        = then_mod->add_instruction(migraphx::make_op("add"), x, lx);
    then_mod->add_return({a1, l1});

    auto* else_mod = p.create_module("If_5_else");
    auto l2        = else_mod->add_literal(migraphx::literal(xs, datax));
    auto a2        = else_mod->add_instruction(migraphx::make_op("mul"), y, ly);
    else_mod->add_return({l2, a2});

    auto ret = mm->add_instruction(migraphx::make_op("if"), {cond}, {then_mod, else_mod});
    auto r2  = mm->add_return({ret});

    scheduler t{};
    auto sub_modules = p.get_modules();
    std::reverse(sub_modules.begin(), sub_modules.end());

    for(const auto& smod : sub_modules)
    {
        t.run_pass(*smod);
    }

    EXPECT(t.has_stream(ret) == false);
    EXPECT(t.has_stream(r2) == false);
}

TEST_CASE(unused_param_test)
{
    migraphx::module mm;
    migraphx::shape s{migraphx::shape::float_type, {2, 3}};

    auto x = mm.add_parameter("x", s);
    auto y = mm.add_parameter("y", s);
    auto z = mm.add_parameter("z", s);

    auto r = mm.add_instruction(migraphx::make_op("add"), x, y);
    mm.add_return({r});

    scheduler t{};
    t.run_pass(mm);

    EXPECT(t.has_stream(z) == false);
    EXPECT(t.has_stream(r) == false);
}

int main(int argc, const char* argv[]) { test::run(argc, argv); }