Method check_single_input

src/plugin/impl/var_sanity_check.cpp:225–283

}

void VarSanityCheck::check_single_input(
        bool add_debug_log, cg::OperatorNodeBase* recv_opr, VarNode* var) {
    if (var->contain_flag(VarNode::Flag::DISALLOW_VAR_SANITY_CHECK))
        return;

    auto checksum = calc_checksum(var);

    ChecksumResult checksum_expect;
    {
        MGB_LOCK_GUARD(m_id2chksum_mtx);
        auto&& node_prop = recv_opr->node_prop();
        if (node_prop.contain(
                    cg::OperatorNodeBase::NodeProp::Flag::FORCE_UPDATE_INPUT_VAR)) {
            m_modified_vars.insert(var);
        }
        auto chk_iter = m_var2chksum.find(var);
        if (chk_iter == m_var2chksum.end()) {
            // PERSISTENT_DEVICE_VALUE vars can be read by oprs on other comp
            // nodes without being waited on
            mgb_assert(
                    var->contain_flag(VarNode::Flag::PERSISTENT_DEVICE_VALUE),
                    "var checksum uncomputed, and its owner opr is not "
                    "PERSISTENT_DEVICE_VALUE: %s",
                    cg::dump_var_info({var}).c_str());
            auto rst = m_var2chksum.emplace(var, checksum);
            mgb_assert(rst.second);
            return;
        } else {
            checksum_expect = chk_iter->second;
        }
    }

    if (add_debug_log) {
        m_debug_log.on_var_received(var);
    }

    if (checksum != checksum_expect) {
#if MGB_ENABLE_GETENV
        mgb_throw(
                Error,
                "var sanity check failed: var: %s"
                " (checksum: expect=%s got=%s); receiver: %s{%s}(%zu);"
                " you can set " LOG_DETAILS_ENV_VAR_NAME
                "=%zu to get more details; pass=%d",
                cg::dump_var_info({var}).c_str(), str(checksum_expect).c_str(),
                str(checksum).c_str(), recv_opr->cname(),
                recv_opr->dyn_typeinfo()->name, recv_opr->id(), var->id(),
                !add_debug_log);
#else
        mgb_throw(
                Error,
                "var sanity check failed: var: %s"
                " (checksum: expect=%s got=%s); receiver: %s{%s}(%zu);",
                cg::dump_var_info({var}).c_str(), str(checksum_expect).c_str(),
                str(checksum).c_str(), recv_opr->cname(),
                recv_opr->dyn_typeinfo()->name, recv_opr->id());
#endif
    }