pass_manager.cpp

// Copyright (C) 2018-2026 Intel Corporation
// SPDX-License-Identifier: Apache-2.0
//

#include <gtest/gtest.h>

#include <memory>
#include <sstream>
#include <string>
#include <vector>

#include "common_test_utils/test_tools.hpp"
#include "openvino/core/graph_util.hpp"
#include "openvino/core/model.hpp"
#include "openvino/op/add.hpp"
#include "openvino/op/matmul.hpp"
#include "openvino/op/multiply.hpp"
#include "openvino/op/parameter.hpp"
#include "openvino/pass/graph_rewrite.hpp"
#include "openvino/pass/manager.hpp"
#include "openvino/pass/pass.hpp"
#include "openvino/pass/validate.hpp"

using namespace ov;
using namespace std;

namespace {

std::shared_ptr<ov::Model> make_test_graph() {
    auto arg_0 = std::make_shared<ov::op::v0::Parameter>(ov::element::f32, ov::Shape{2, 2});
    auto arg_1 = std::make_shared<ov::op::v0::Parameter>(ov::element::f32, ov::Shape{2, 2});
    auto arg_2 = std::make_shared<ov::op::v0::Parameter>(ov::element::f32, ov::Shape{2, 2});
    auto arg_3 = std::make_shared<ov::op::v0::Parameter>(ov::element::f32, ov::Shape{2, 2});
    auto arg_4 = std::make_shared<ov::op::v0::Parameter>(ov::element::f32, ov::Shape{2, 2});
    auto arg_5 = std::make_shared<ov::op::v0::Parameter>(ov::element::f32, ov::Shape{2, 2});

    auto t0 = std::make_shared<ov::op::v1::Add>(arg_0, arg_1);
    auto t1 = std::make_shared<ov::op::v0::MatMul>(t0, arg_2);
    auto t2 = std::make_shared<ov::op::v1::Multiply>(t0, arg_3);

    auto t3 = std::make_shared<ov::op::v1::Add>(t1, arg_4);
    auto t4 = std::make_shared<ov::op::v1::Add>(t2, arg_5);

    auto r0 = std::make_shared<ov::op::v1::Add>(t3, t4);

    auto m = std::make_shared<ov::Model>(r0, ov::ParameterVector{arg_0, arg_1, arg_2, arg_3, arg_4, arg_5});

    return m;
}

// This function traverses the vector of ops and verifies that each op's dependencies (its inputs)
// is located earlier in the vector. That is enough to be valid
bool validate_list(const std::vector<std::shared_ptr<ov::Node>>& nodes) {
    bool rc = true;
    for (auto it = nodes.rbegin(); it != nodes.rend(); it++) {
        auto node_tmp = *it;
        ov::NodeVector dependencies_tmp;
        for (auto& val : node_tmp->input_values())
            dependencies_tmp.emplace_back(val.get_node_shared_ptr());
        std::vector<ov::Node*> dependencies;

        for (std::shared_ptr<ov::Node> n : dependencies_tmp) {
            dependencies.push_back(n.get());
        }
        auto tmp = it;
        for (tmp++; tmp != nodes.rend(); tmp++) {
            auto dep_tmp = *tmp;
            auto found = find(dependencies.begin(), dependencies.end(), dep_tmp.get());
            if (found != dependencies.end()) {
                dependencies.erase(found);
            }
        }
        if (dependencies.size() > 0) {
            rc = false;
        }
    }
    return rc;
}
class TestMatcherPassTrue : public ov::pass::MatcherPass {
public:
    TestMatcherPassTrue() : MatcherPass() {
        auto any_input = ov::pass::pattern::any_input();
        ov::matcher_pass_callback callback = [](ov::pass::pattern::Matcher&) {
            return true;
        };

        auto m = std::make_shared<ov::pass::pattern::Matcher>(any_input, "TestMatcherPassTrue");
        this->register_matcher(m, callback);
    }
};

class TestMatcherPassFalse : public ov::pass::MatcherPass {
public:
    TestMatcherPassFalse() : MatcherPass() {
        auto any_input = ov::pass::pattern::any_input();
        ov::matcher_pass_callback callback = [](ov::pass::pattern::Matcher&) {
            return false;
        };

        auto m = std::make_shared<ov::pass::pattern::Matcher>(any_input, "TestMatcherPassFalse");
        this->register_matcher(m, callback);
    }
};

class TestModelPassTrue : public pass::ModelPass {
public:
    bool run_on_model(const std::shared_ptr<ov::Model>&) override {
        return true;
    }
};

class TestModelPassFalse : public pass::ModelPass {
public:
    bool run_on_model(const std::shared_ptr<ov::Model>&) override {
        return false;
    }
};

class CountingValidate : public ov::pass::Validate {
public:
    bool run_on_model(const std::shared_ptr<ov::Model>& model) override {
        is_applied = true;
        return Validate::run_on_model(model);
    }

    bool is_applied = false;
};

class ValidateTestManager : public pass::Manager {
protected:
    void push_validate_pass() override {
        push_pass<CountingValidate>();
    }

public:
    int get_num_validate_executed() {
        int total = 0;

        for (const auto& pass : m_pass_list) {
            if (auto counting_validate = ov::as_type_ptr<CountingValidate>(pass)) {
                total += counting_validate->is_applied;
            }
        }

        return total;
    }
};

TEST(pass_manager, Validate_passes_not_applied) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(false);

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    auto validate = manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    EXPECT_FALSE(res);
    EXPECT_FALSE(validate->is_applied);
}

TEST(pass_manager, Validate_model_pass_applied) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(false);

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassTrue>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    auto validate = manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    EXPECT_TRUE(res);
    EXPECT_TRUE(validate->is_applied);
}

TEST(pass_manager, Validate_matcher_pass_applied) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(false);

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassTrue>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    auto validate = manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    EXPECT_TRUE(res);
    EXPECT_TRUE(validate->is_applied);
}

TEST(pass_manager, Validate_three_validations) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(false);

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassTrue>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    auto validate_1 = manager.register_pass<CountingValidate>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    auto validate_2 = manager.register_pass<CountingValidate>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassTrue>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassTrue>();
    manager.register_pass<TestModelPassFalse>();
    auto validate_3 = manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    EXPECT_TRUE(res);
    EXPECT_TRUE(validate_1->is_applied);
    EXPECT_FALSE(validate_2->is_applied);
    EXPECT_TRUE(validate_3->is_applied);
}

TEST(pass_manager, Validate_per_pass) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(true);  // by default true

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassTrue>();
    auto validate_1 = manager.register_pass<CountingValidate>();
    auto validate_2 = manager.register_pass<CountingValidate>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassTrue>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassTrue>();
    manager.register_pass<TestModelPassFalse>();
    auto validate_3 = manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    const auto num_true_passes = 3;

    EXPECT_TRUE(res);
    EXPECT_FALSE(validate_1->is_applied);
    EXPECT_FALSE(validate_2->is_applied);
    EXPECT_FALSE(validate_3->is_applied);
    EXPECT_EQ(manager.get_num_validate_executed(), num_true_passes);
}

TEST(pass_manager, Validate_single_validate) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(false);

    auto graph = make_test_graph();

    auto validate = manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    EXPECT_FALSE(res);
    EXPECT_FALSE(validate->is_applied);
}

TEST(pass_manager, Validate_single_validate_per_pass) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(true);  // by default true

    auto graph = make_test_graph();

    auto validate = manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    const auto num_true_passes = 0;

    EXPECT_FALSE(res);
    EXPECT_FALSE(validate->is_applied);
    EXPECT_EQ(manager.get_num_validate_executed(), num_true_passes);
}

TEST(pass_manager, Validate_counter) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(true);  // by default true

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassTrue>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassTrue>();
    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassTrue>();
    manager.register_pass<TestModelPassFalse>();
    manager.register_pass<CountingValidate>();
    const auto res = manager.run_passes(graph);

    const auto num_true_passes = 3;

    EXPECT_TRUE(res);
    EXPECT_EQ(manager.get_num_validate_executed(), num_true_passes);
}

TEST(pass_manager, Validate_counter_0) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(false);

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassFalse>();
    manager.register_pass<TestModelPassFalse>();

    const auto res = manager.run_passes(graph);

    const auto num_true_passes = 0;

    EXPECT_FALSE(res);
    EXPECT_EQ(manager.get_num_validate_executed(), num_true_passes);
}

TEST(pass_manager, Validate_counter_1) {
    ValidateTestManager manager;
    manager.set_per_pass_validation(false);

    auto graph = make_test_graph();

    manager.register_pass<TestMatcherPassTrue>();
    manager.register_pass<TestModelPassTrue>();

    const auto res = manager.run_passes(graph);

    EXPECT_TRUE(res);
    EXPECT_EQ(manager.get_num_validate_executed(), /*no Validate inserted*/ 0);
}

}  // namespace

TEST(pass_manager, add) {
    pass::Manager pass_manager;

    auto graph = make_test_graph();
    size_t node_count = 0;
    ov::traverse_nodes(graph, [&](shared_ptr<Node> /* node */) {
        node_count++;
    });
    pass_manager.run_passes(graph);
    auto sorted = graph->get_ordered_ops();
    EXPECT_EQ(node_count, sorted.size());
    EXPECT_TRUE(validate_list(sorted));
}