Method process_opr

src/core/impl/graph/operator_node.cpp:707–736

}

void PostExecActions::process_opr(
        OperatorNodeBase& opr, OperatorNodeBase::ExecEnv& env) {
    // PostExecActions should be empty most of the time; so we store the objects
    // directly in a SmallVector and copy them to a shared_ptr when non-empty
    SmallVector<PostExecActions> actions;
    for (auto i : opr.output()) {
        bool found = false;
        for (auto&& j : actions) {
            if (j.m_comp_node == i->comp_node()) {
                j.add(i);
                found = true;
                break;
            }
        }
        if (!found) {
            actions.emplace_back(i);
        }
    }

    for (auto&& i : actions) {
        if (!i.m_items.empty()) {
            auto cn = i.m_comp_node;
            MGB_IF_COND_EXEC(i.m_mask = ExecutionMask::get_from_opr(&opr));
            auto cb = [action = std::make_shared<PostExecActions>(std::move(i))]() {
                action->perform();
            };
            env.dispatch_on_comp_node_with_mask(cn, cb, nullptr);
        }
    }
}

// vim: syntax=cpp.doxygen foldmethod=marker foldmarker=f{{{,f}}}