Method execute

cactus/graph/graph_execute.cpp:251–716

}

void CactusGraph::execute(const std::string& profile_file) {
    std::vector<size_t> last_use(nodes_.size(), 0);
    for (size_t i = 0; i < nodes_.size(); ++i) {
        for (size_t input_id : nodes_[i]->input_ids) {
            auto it = node_index_map_.find(input_id);
            if (it != node_index_map_.end()) {
                last_use[it->second] = std::max(last_use[it->second], i);
            }
        }
    }

    BufferPool& pool = buffer_pool_;

    auto get_env_int = [](const char* name, int fallback) -> int {
        const char* val = std::getenv(name);
        return val ? std::atoi(val) : fallback;
    };

    auto get_env_str = [](const char* name) -> std::string {
        const char* val = std::getenv(name);
        return val ? std::string(val) : std::string();
    };

    bool capture_to_stdout = get_env_int("CACTUS_CAPTURE_STDOUT", 0) != 0;
    std::string capture_file_path = get_env_str("CACTUS_CAPTURE_FILE");
    bool capture_requested = get_env_int("CACTUS_CAPTURE_ENABLE", 0) != 0;
    std::string capture_dir = get_env_str("CACTUS_CAPTURE_DIR");

    if (!capture_requested) {
        capture_requested = capture_to_stdout || !capture_file_path.empty() || !capture_dir.empty();
    } else if (capture_file_path.empty() && !capture_to_stdout && capture_dir.empty()) {
        capture_to_stdout = true;
    }

    size_t capture_preview_count = static_cast<size_t>(get_env_int("CACTUS_CAPTURE_PREVIEW_COUNT", 8));
    size_t capture_max_elements = static_cast<size_t>(get_env_int("CACTUS_CAPTURE_MAX_ELEMENTS", 65536));

    std::string env_profile = get_env_str("CACTUS_PROFILE_FILE");
    if (env_profile.empty()) env_profile = get_env_str("CACTUS_PROFILE");

    std::string target_profile = profile_file;
    if (target_profile.empty() && !env_profile.empty()) {
        target_profile = env_profile;
    }

    bool enable_profiling = !target_profile.empty();
    bool to_stdout = (target_profile == "stdout" || target_profile == "-");

    std::ofstream profile_out;
    std::ostream* out = &std::cout;

    if (enable_profiling && !to_stdout) {
        profile_out.open(target_profile, std::ios::app);
        if (profile_out.is_open()) {
            out = &profile_out;
        }
    }