27956659323

Committed 22 Jun 2026 01:34PM UTC coverage: 61.757% (-0.03%) from 61.782%

Build # 27956659323

Build Type

Pull #802

github

Committed by

web-flow

Commit Message

Merge acd09dfa2 into fe87d162b

Pull Request Pull Request #802: adds reduce as new structured loop type

Coverage Stats

284 of 481 new or added lines in 14 files covered. (59.04%)

1 existing line in 1 file now uncovered.

37423 of 60597 relevant lines covered (61.76%)

1006.67 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

76.36

/sdfg/src/serializer/json_serializer.cpp

#include "sdfg/serializer/json_serializer.h"

#include <cassert>
#include <memory>
#include <sdfg/data_flow/library_nodes/load_const_node.h>
#include <utility>
#include <vector>

#include "sdfg/data_flow/library_nodes/barrier_local_node.h"
#include "sdfg/data_flow/library_nodes/call_node.h"
#include "sdfg/data_flow/library_nodes/invoke_node.h"
#include "sdfg/data_flow/library_nodes/math/math.h"
#include "sdfg/data_flow/library_nodes/math/tensor/elementwise_ops/cmath_node.h"
#include "sdfg/data_flow/library_nodes/math/tensor/elementwise_ops/tasklet_node.h"
#include "sdfg/data_flow/library_nodes/metadata_node.h"
#include "sdfg/data_flow/library_nodes/stdlib/stdlib.h"

#include "sdfg/analysis/users.h"
#include "sdfg/builder/structured_sdfg_builder.h"
#include "sdfg/data_flow/library_node.h"
#include "sdfg/data_flow/library_nodes/math/tensor/batchnorm_node.h"
#include "sdfg/element.h"
#include "sdfg/structured_control_flow/block.h"
#include "sdfg/structured_control_flow/for.h"
#include "sdfg/structured_control_flow/if_else.h"
#include "sdfg/structured_control_flow/map.h"
#include "sdfg/structured_control_flow/reduce.h"
#include "sdfg/structured_control_flow/return.h"
#include "sdfg/structured_control_flow/sequence.h"
#include "sdfg/structured_control_flow/while.h"
#include "sdfg/structured_sdfg.h"
#include "sdfg/symbolic/symbolic.h"
#include "sdfg/types/function.h"
#include "sdfg/types/scalar.h"
#include "sdfg/types/type.h"
#include "symengine/expression.h"
#include "symengine/logic.h"
#include "symengine/symengine_rcp.h"

namespace sdfg {
namespace serializer {

FunctionType function_type_from_string(const std::string& str) {
    if (str == FunctionType_CPU.value()) {
        return FunctionType_CPU;
    } else if (str == FunctionType_NV_GLOBAL.value()) {
        return FunctionType_NV_GLOBAL;
    }

    return FunctionType(str);
}

/*
 * * JSONSerializer class
 * * Serialization logic
 */

nlohmann::json JSONSerializer::serialize(
    const sdfg::StructuredSDFG& sdfg,
    analysis::AnalysisManager* analysis_manager,
    structured_control_flow::Sequence* root
) {
    nlohmann::json j;

    j["name"] = sdfg.name();
    j["element_counter"] = sdfg.element_counter();
    j["type"] = std::string(sdfg.type().value());

    nlohmann::json return_type_json;
    type_to_json(return_type_json, sdfg.return_type());
    j["return_type"] = return_type_json;

    j["structures"] = nlohmann::json::array();
    for (const auto& structure_name : sdfg.structures()) {
        const auto& structure = sdfg.structure(structure_name);
        nlohmann::json structure_json;
        structure_definition_to_json(structure_json, structure);
        j["structures"].push_back(structure_json);
    }

    j["containers"] = nlohmann::json::object();
    for (const auto& container : sdfg.containers()) {
        nlohmann::json desc;
        type_to_json(desc, sdfg.type(container));
        j["containers"][container] = desc;
    }

    j["arguments"] = nlohmann::json::array();
    for (const auto& argument : sdfg.arguments()) {
        j["arguments"].push_back(argument);
    }

    j["externals"] = nlohmann::json::array();
    for (const auto& external : sdfg.externals()) {
        nlohmann::json external_json;
        external_json["name"] = external;
        external_json["linkage_type"] = sdfg.linkage_type(external);
        j["externals"].push_back(external_json);
    }

    j["metadata"] = nlohmann::json::object();
    for (const auto& entry : sdfg.metadata()) {
        j["metadata"][entry.first] = entry.second;
    }

    // Walk the SDFG
    nlohmann::json root_json;
    sequence_to_json(root_json, sdfg.root());
    j["root"] = root_json;

    return j;
}

void JSONSerializer::dataflow_to_json(nlohmann::json& j, const data_flow::DataFlowGraph& dataflow) {
    j["type"] = "dataflow";
    j["nodes"] = nlohmann::json::array();
    j["edges"] = nlohmann::json::array();

    for (auto& node : dataflow.nodes()) {
        nlohmann::json node_json;
        node_json["element_id"] = node.element_id();

        node_json["debug_info"] = nlohmann::json::object();
        debug_info_to_json(node_json["debug_info"], node.debug_info());

        if (auto tasklet = dynamic_cast<const data_flow::Tasklet*>(&node)) {
            node_json["type"] = "tasklet";
            node_json["code"] = tasklet->code();
            node_json["inputs"] = nlohmann::json::array();
            for (auto& input : tasklet->inputs()) {
                node_json["inputs"].push_back(input);
            }
            node_json["output"] = tasklet->output();
        } else if (auto lib_node = dynamic_cast<const data_flow::LibraryNode*>(&node)) {
            node_json["type"] = "library_node";
            node_json["implementation_type"] = std::string(lib_node->implementation_type().value());
            auto serializer_fn =
                LibraryNodeSerializerRegistry::instance().get_library_node_serializer(lib_node->code().value());
            if (serializer_fn == nullptr) {
                throw std::runtime_error("Unknown library node code: " + std::string(lib_node->code().value()));
            }
            auto serializer = serializer_fn();
            auto lib_node_json = serializer->serialize(*lib_node);
            node_json.merge_patch(lib_node_json);
        } else if (auto code_node = dynamic_cast<const data_flow::ConstantNode*>(&node)) {
            node_json["type"] = "constant_node";
            node_json["data"] = code_node->data();

            nlohmann::json type_json;
            type_to_json(type_json, code_node->type());
            node_json["data_type"] = type_json;
        } else if (auto code_node = dynamic_cast<const data_flow::AccessNode*>(&node)) {
            node_json["type"] = "access_node";
            node_json["data"] = code_node->data();
        } else {
            throw std::runtime_error("Unknown node type");
        }

        j["nodes"].push_back(node_json);
    }

    for (auto& edge : dataflow.edges()) {
        nlohmann::json edge_json;
        edge_json["element_id"] = edge.element_id();

        edge_json["debug_info"] = nlohmann::json::object();
        debug_info_to_json(edge_json["debug_info"], edge.debug_info());

        edge_json["src"] = edge.src().element_id();
        edge_json["dst"] = edge.dst().element_id();

        edge_json["src_conn"] = edge.src_conn();
        edge_json["dst_conn"] = edge.dst_conn();

        edge_json["subset"] = nlohmann::json::array();
        for (auto& subset : edge.subset()) {
            edge_json["subset"].push_back(expression(subset));
        }

        nlohmann::json base_type_json;
        type_to_json(base_type_json, edge.base_type());
        edge_json["base_type"] = base_type_json;

        j["edges"].push_back(edge_json);
    }
}

void JSONSerializer::block_to_json(nlohmann::json& j, const structured_control_flow::Block& block) {
    j["type"] = "block";
    j["element_id"] = block.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], block.debug_info());

    nlohmann::json dataflow_json;
    dataflow_to_json(dataflow_json, block.dataflow());
    j["dataflow"] = dataflow_json;
}

void JSONSerializer::for_to_json(nlohmann::json& j, const structured_control_flow::For& for_node) {
    j["type"] = "for";
    j["element_id"] = for_node.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], for_node.debug_info());

    j["indvar"] = expression(for_node.indvar());
    j["init"] = expression(for_node.init());
    j["condition"] = expression(for_node.condition());
    j["update"] = expression(for_node.update());

    nlohmann::json body_json;
    sequence_to_json(body_json, for_node.root());
    j["root"] = body_json;
}

void JSONSerializer::if_else_to_json(nlohmann::json& j, const structured_control_flow::IfElse& if_else_node) {
    j["type"] = "if_else";
    j["element_id"] = if_else_node.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], if_else_node.debug_info());

    j["branches"] = nlohmann::json::array();
    for (size_t i = 0; i < if_else_node.size(); i++) {
        nlohmann::json branch_json;
        branch_json["condition"] = expression(if_else_node.at(i).second);
        nlohmann::json body_json;
        sequence_to_json(body_json, if_else_node.at(i).first);
        branch_json["root"] = body_json;
        j["branches"].push_back(branch_json);
    }
}

void JSONSerializer::while_node_to_json(nlohmann::json& j, const structured_control_flow::While& while_node) {
    j["type"] = "while";
    j["element_id"] = while_node.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], while_node.debug_info());

    nlohmann::json body_json;
    sequence_to_json(body_json, while_node.root());
    j["root"] = body_json;
}

void JSONSerializer::break_node_to_json(nlohmann::json& j, const structured_control_flow::Break& break_node) {
    j["type"] = "break";
    j["element_id"] = break_node.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], break_node.debug_info());
}

void JSONSerializer::continue_node_to_json(nlohmann::json& j, const structured_control_flow::Continue& continue_node) {
    j["type"] = "continue";
    j["element_id"] = continue_node.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], continue_node.debug_info());
}

void JSONSerializer::map_to_json(nlohmann::json& j, const structured_control_flow::Map& map_node) {
    j["type"] = "map";
    j["element_id"] = map_node.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], map_node.debug_info());

    j["indvar"] = expression(map_node.indvar());
    j["init"] = expression(map_node.init());
    j["condition"] = expression(map_node.condition());
    j["update"] = expression(map_node.update());

    j["schedule_type"] = nlohmann::json::object();
    schedule_type_to_json(j["schedule_type"], map_node.schedule_type());

    nlohmann::json body_json;
    sequence_to_json(body_json, map_node.root());
    j["root"] = body_json;
}

void JSONSerializer::reduce_to_json(nlohmann::json& j, const structured_control_flow::Reduce& reduce_node) {
    j["type"] = "reduce";
    j["element_id"] = reduce_node.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], reduce_node.debug_info());

    j["indvar"] = expression(reduce_node.indvar());
    j["init"] = expression(reduce_node.init());
    j["condition"] = expression(reduce_node.condition());
    j["update"] = expression(reduce_node.update());

    j["reductions"] = nlohmann::json::array();
    for (const auto& reduction : reduce_node.reductions()) {
        nlohmann::json reduction_json;
        reduction_json["op"] = structured_control_flow::reduction_operation_to_string(reduction.operation);
        reduction_json["container"] = reduction.container;
        j["reductions"].push_back(reduction_json);
    }

    j["schedule_type"] = nlohmann::json::object();
    schedule_type_to_json(j["schedule_type"], reduce_node.schedule_type());

    nlohmann::json body_json;
    sequence_to_json(body_json, reduce_node.root());
    j["root"] = body_json;
}

void JSONSerializer::return_node_to_json(nlohmann::json& j, const structured_control_flow::Return& return_node) {
    j["type"] = "return";
    j["element_id"] = return_node.element_id();
    j["data"] = return_node.data();

    if (return_node.is_constant()) {
        nlohmann::json type_json;
        type_to_json(type_json, return_node.type());
        j["data_type"] = type_json;
    }

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], return_node.debug_info());
}

void JSONSerializer::sequence_to_json(nlohmann::json& j, const structured_control_flow::Sequence& sequence) {
    j["type"] = "sequence";
    j["element_id"] = sequence.element_id();

    j["debug_info"] = nlohmann::json::object();
    debug_info_to_json(j["debug_info"], sequence.debug_info());

    j["children"] = nlohmann::json::array();
    j["transitions"] = nlohmann::json::array();

    for (size_t i = 0; i < sequence.size(); i++) {
        nlohmann::json child_json;
        auto& child = sequence.at(i).first;
        auto& transition = sequence.at(i).second;

        if (auto block = dynamic_cast<const structured_control_flow::Block*>(&child)) {
            block_to_json(child_json, *block);
        } else if (auto for_node = dynamic_cast<const structured_control_flow::For*>(&child)) {
            for_to_json(child_json, *for_node);
        } else if (auto sequence_node = dynamic_cast<const structured_control_flow::Sequence*>(&child)) {
            sequence_to_json(child_json, *sequence_node);
        } else if (auto condition_node = dynamic_cast<const structured_control_flow::IfElse*>(&child)) {
            if_else_to_json(child_json, *condition_node);
        } else if (auto while_node = dynamic_cast<const structured_control_flow::While*>(&child)) {
            while_node_to_json(child_json, *while_node);
        } else if (auto return_node = dynamic_cast<const structured_control_flow::Return*>(&child)) {
            return_node_to_json(child_json, *return_node);
        } else if (auto break_node = dynamic_cast<const structured_control_flow::Break*>(&child)) {
            break_node_to_json(child_json, *break_node);
        } else if (auto continue_node = dynamic_cast<const structured_control_flow::Continue*>(&child)) {
            continue_node_to_json(child_json, *continue_node);
        } else if (auto map_node = dynamic_cast<const structured_control_flow::Map*>(&child)) {
            map_to_json(child_json, *map_node);
        } else if (auto reduce_node = dynamic_cast<const structured_control_flow::Reduce*>(&child)) {
            reduce_to_json(child_json, *reduce_node);
        } else {
            throw std::runtime_error("Unknown child type");
        }

        j["children"].push_back(child_json);

        // Add transition information
        nlohmann::json transition_json;
        transition_json["type"] = "transition";
        transition_json["element_id"] = transition.element_id();

        transition_json["debug_info"] = nlohmann::json::object();
        debug_info_to_json(transition_json["debug_info"], transition.debug_info());

        transition_json["assignments"] = nlohmann::json::array();
        for (const auto& assignment : transition.assignments()) {
            nlohmann::json assignment_json;
            assignment_json["symbol"] = expression(assignment.first);
            assignment_json["expression"] = expression(assignment.second);
            transition_json["assignments"].push_back(assignment_json);
        }

        j["transitions"].push_back(transition_json);
    }
}

void JSONSerializer::type_to_json(nlohmann::json& j, const types::IType& type) {
    if (auto scalar_type = dynamic_cast<const types::Scalar*>(&type)) {
        j["type"] = "scalar";
        j["primitive_type"] = scalar_type->primitive_type();
        j["storage_type"] = nlohmann::json::object();
        storage_type_to_json(j["storage_type"], scalar_type->storage_type());
        j["initializer"] = scalar_type->initializer();
        j["alignment"] = scalar_type->alignment();
    } else if (auto array_type = dynamic_cast<const types::Array*>(&type)) {
        j["type"] = "array";
        nlohmann::json element_type_json;
        type_to_json(element_type_json, array_type->element_type());
        j["element_type"] = element_type_json;
        j["num_elements"] = expression(array_type->num_elements());
        j["storage_type"] = nlohmann::json::object();
        storage_type_to_json(j["storage_type"], array_type->storage_type());
        j["initializer"] = array_type->initializer();
        j["alignment"] = array_type->alignment();
    } else if (auto pointer_type = dynamic_cast<const types::Pointer*>(&type)) {
        j["type"] = "pointer";
        if (pointer_type->has_pointee_type()) {
            nlohmann::json pointee_type_json;
            type_to_json(pointee_type_json, pointer_type->pointee_type());
            j["pointee_type"] = pointee_type_json;
        }
        j["storage_type"] = nlohmann::json::object();
        storage_type_to_json(j["storage_type"], pointer_type->storage_type());
        j["initializer"] = pointer_type->initializer();
        j["alignment"] = pointer_type->alignment();
    } else if (auto structure_type = dynamic_cast<const types::Structure*>(&type)) {
        j["type"] = "structure";
        j["name"] = structure_type->name();
        j["storage_type"] = nlohmann::json::object();
        storage_type_to_json(j["storage_type"], structure_type->storage_type());
        j["initializer"] = structure_type->initializer();
        j["alignment"] = structure_type->alignment();
    } else if (auto function_type = dynamic_cast<const types::Function*>(&type)) {
        j["type"] = "function";
        nlohmann::json return_type_json;
        type_to_json(return_type_json, function_type->return_type());
        j["return_type"] = return_type_json;
        j["params"] = nlohmann::json::array();
        for (size_t i = 0; i < function_type->num_params(); i++) {
            nlohmann::json param_json;
            type_to_json(param_json, function_type->param_type(symbolic::integer(i)));
            j["params"].push_back(param_json);
        }
        j["is_var_arg"] = function_type->is_var_arg();
        j["storage_type"] = nlohmann::json::object();
        storage_type_to_json(j["storage_type"], function_type->storage_type());
        j["initializer"] = function_type->initializer();
        j["alignment"] = function_type->alignment();
    } else if (auto reference_type = dynamic_cast<const sdfg::codegen::Reference*>(&type)) {
        j["type"] = "reference";
        nlohmann::json reference_type_json;
        type_to_json(reference_type_json, reference_type->reference_type());
        j["reference_type"] = reference_type_json;
    } else if (auto tensor_type = dynamic_cast<const types::Tensor*>(&type)) {
        j["type"] = "tensor";
        nlohmann::json element_type_json;
        type_to_json(element_type_json, tensor_type->element_type());
        j["element_type"] = element_type_json;
        j["shape"] = nlohmann::json::array();
        for (const auto& dim : tensor_type->shape()) {
            j["shape"].push_back(expression(dim));
        }
        j["strides"] = nlohmann::json::array();
        for (const auto& stride : tensor_type->strides()) {
            j["strides"].push_back(expression(stride));
        }
        j["offset"] = expression(tensor_type->offset());
        j["storage_type"] = nlohmann::json::object();
        storage_type_to_json(j["storage_type"], tensor_type->storage_type());
        j["initializer"] = tensor_type->initializer();
        j["alignment"] = tensor_type->alignment();
    } else {
        throw std::runtime_error("Unknown type");
    }
}

void JSONSerializer::structure_definition_to_json(nlohmann::json& j, const types::StructureDefinition& definition) {
    j["name"] = definition.name();
    j["members"] = nlohmann::json::array();
    for (size_t i = 0; i < definition.num_members(); i++) {
        nlohmann::json member_json;
        type_to_json(member_json, definition.member_type(symbolic::integer(i)));
        j["members"].push_back(member_json);
    }
    j["is_packed"] = definition.is_packed();
}

void JSONSerializer::debug_info_to_json(nlohmann::json& j, const DebugInfo& debug_info) {
    j["has"] = debug_info.has();
    j["filename"] = debug_info.filename();
    j["function"] = debug_info.function();
    j["start_line"] = debug_info.start_line();
    j["start_column"] = debug_info.start_column();
    j["end_line"] = debug_info.end_line();
    j["end_column"] = debug_info.end_column();
}


void JSONSerializer::schedule_type_to_json(nlohmann::json& j, const ScheduleType& schedule_type) {
    j["value"] = schedule_type.value();
    j["category"] = static_cast<int>(schedule_type.category());
    j["properties"] = nlohmann::json::object();
    for (const auto& prop : schedule_type.properties()) {
        j["properties"][prop.first] = prop.second;
    }
}

void JSONSerializer::storage_type_to_json(nlohmann::json& j, const types::StorageType& storage_type) {
    j["value"] = storage_type.value();
    j["allocation"] = storage_type.allocation();
    j["deallocation"] = storage_type.deallocation();
    if (!storage_type.allocation_size().is_null()) {
        j["allocation_size"] = expression(storage_type.allocation_size());
    }
    const symbolic::Expression& arg1 = storage_type.arg1();
    if (!arg1.is_null()) {
        auto args = nlohmann::json::array();
        args.push_back(expression(arg1));
        j["args"] = args;
    }
}


/*
 * * Deserialization logic
 */

std::unique_ptr<StructuredSDFG> JSONSerializer::deserialize(nlohmann::json& j) {
    assert(j.contains("name"));
    assert(j["name"].is_string());
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j.contains("element_counter"));
    assert(j["element_counter"].is_number_integer());

    std::unique_ptr<types::IType> return_type;
    if (j.contains("return_type")) {
        return_type = json_to_type(j["return_type"]);
    } else {
        return_type = std::make_unique<types::Scalar>(types::PrimitiveType::Void);
    }

    FunctionType function_type = function_type_from_string(j["type"].get<std::string>());
    builder::StructuredSDFGBuilder builder(j["name"], function_type, *return_type);

    size_t element_counter = j["element_counter"];
    builder.set_element_counter(element_counter);

    // deserialize structures
    assert(j.contains("structures"));
    assert(j["structures"].is_array());
    for (const auto& structure : j["structures"]) {
        assert(structure.contains("name"));
        assert(structure["name"].is_string());
        json_to_structure_definition(structure, builder);
    }

    nlohmann::json& containers = j["containers"];

    // deserialize externals
    for (const auto& external : j["externals"]) {
        assert(external.contains("name"));
        assert(external["name"].is_string());
        assert(external.contains("linkage_type"));
        assert(external["linkage_type"].is_number_integer());
        auto& type_desc = containers.at(external["name"].get<std::string>());
        auto type = json_to_type(type_desc);
        builder.add_external(external["name"], *type, LinkageType(external["linkage_type"]));
    }

    // deserialize arguments
    for (const auto& name : j["arguments"]) {
        auto& type_desc = containers.at(name.get<std::string>());
        auto type = json_to_type(type_desc);
        builder.add_container(name, *type, true, false);
    }

    // deserialize transients
    for (const auto& entry : containers.items()) {
        if (builder.subject().is_argument(entry.key())) {
            continue;
        }
        if (builder.subject().is_external(entry.key())) {
            continue;
        }
        auto type = json_to_type(entry.value());
        builder.add_container(entry.key(), *type, false, false);
    }

    // deserialize root node
    assert(j.contains("root"));
    auto& root = builder.subject().root();
    json_to_sequence(j["root"], builder, root);

    // deserialize metadata
    assert(j.contains("metadata"));
    assert(j["metadata"].is_object());
    for (const auto& entry : j["metadata"].items()) {
        builder.subject().add_metadata(entry.key(), entry.value());
    }

    builder.set_element_counter(element_counter);

    return builder.move();
}

void JSONSerializer::json_to_structure_definition(const nlohmann::json& j, builder::StructuredSDFGBuilder& builder) {
    assert(j.contains("name"));
    assert(j["name"].is_string());
    assert(j.contains("members"));
    assert(j["members"].is_array());
    assert(j.contains("is_packed"));
    assert(j["is_packed"].is_boolean());
    auto is_packed = j["is_packed"];
    auto& definition = builder.add_structure(j["name"], is_packed);
    for (const auto& member : j["members"]) {
        nlohmann::json member_json;
        auto member_type = json_to_type(member);
        definition.add_member(*member_type);
    }
}

std::vector<std::pair<std::string, types::Scalar>> JSONSerializer::json_to_arguments(const nlohmann::json& j) {
    std::vector<std::pair<std::string, types::Scalar>> arguments;
    for (const auto& argument : j) {
        assert(argument.contains("name"));
        assert(argument["name"].is_string());
        assert(argument.contains("type"));
        assert(argument["type"].is_object());
        std::string name = argument["name"];
        auto type = json_to_type(argument["type"]);
        arguments.emplace_back(name, *dynamic_cast<types::Scalar*>(type.get()));
    }
    return arguments;
}

void JSONSerializer::json_to_dataflow(
    const nlohmann::json& j, builder::StructuredSDFGBuilder& builder, structured_control_flow::Block& parent
) {
    std::map<size_t, data_flow::DataFlowNode&> nodes_map;

    assert(j.contains("nodes"));
    assert(j["nodes"].is_array());
    for (const auto& node : j["nodes"]) {
        assert(node.contains("type"));
        assert(node["type"].is_string());
        assert(node.contains("element_id"));
        assert(node["element_id"].is_number_integer());
        std::string type = node["type"];
        if (type == "tasklet") {
            assert(node.contains("code"));
            assert(node["code"].is_number_integer());
            assert(node.contains("inputs"));
            assert(node["inputs"].is_array());
            assert(node.contains("output"));
            assert(node["output"].is_string());
            auto inputs = node["inputs"].get<std::vector<std::string>>();

            auto& tasklet =
                builder
                    .add_tasklet(parent, node["code"], node["output"], inputs, json_to_debug_info(node["debug_info"]));
            tasklet.element_id_ = node["element_id"];
            nodes_map.insert({node["element_id"], tasklet});
        } else if (type == "library_node") {
            assert(node.contains("code"));
            data_flow::LibraryNodeCode code(node["code"].get<std::string>());

            auto serializer_fn = LibraryNodeSerializerRegistry::instance().get_library_node_serializer(code.value());
            if (serializer_fn == nullptr) {
                throw std::runtime_error("Unknown library node code: " + std::string(code.value()));
            }
            auto serializer = serializer_fn();
            auto& lib_node = serializer->deserialize(node, builder, parent);
            lib_node.implementation_type() =
                data_flow::ImplementationType(node["implementation_type"].get<std::string>());
            lib_node.element_id_ = node["element_id"];
            nodes_map.insert({node["element_id"], lib_node});
        } else if (type == "access_node") {
            assert(node.contains("data"));
            auto& access_node = builder.add_access(parent, node["data"], json_to_debug_info(node["debug_info"]));
            access_node.element_id_ = node["element_id"];
            nodes_map.insert({node["element_id"], access_node});
        } else if (type == "constant_node") {
            assert(node.contains("data"));
            assert(node.contains("data_type"));

            auto type = json_to_type(node["data_type"]);

            auto& constant_node =
                builder.add_constant(parent, node["data"], *type, json_to_debug_info(node["debug_info"]));
            constant_node.element_id_ = node["element_id"];
            nodes_map.insert({node["element_id"], constant_node});
        } else {
            throw std::runtime_error("Unknown node type");
        }
    }

    assert(j.contains("edges"));
    assert(j["edges"].is_array());
    for (const auto& edge : j["edges"]) {
        assert(edge.contains("src"));
        assert(edge["src"].is_number_integer());
        assert(edge.contains("dst"));
        assert(edge["dst"].is_number_integer());
        assert(edge.contains("src_conn"));
        assert(edge["src_conn"].is_string());
        assert(edge.contains("dst_conn"));
        assert(edge["dst_conn"].is_string());
        assert(edge.contains("subset"));
        assert(edge["subset"].is_array());

        assert(nodes_map.find(edge["src"]) != nodes_map.end());
        assert(nodes_map.find(edge["dst"]) != nodes_map.end());
        auto& source = nodes_map.at(edge["src"]);
        auto& target = nodes_map.at(edge["dst"]);

        auto base_type = json_to_type(edge["base_type"]);

        assert(edge.contains("subset"));
        assert(edge["subset"].is_array());
        std::vector<symbolic::Expression> subset;
        for (const auto& subset_ : edge["subset"]) {
            assert(subset_.is_string());
            std::string subset_str = subset_;
            auto expr = symbolic::parse(subset_str);
            subset.push_back(expr);
        }
        auto& memlet = builder.add_memlet(
            parent,
            source,
            edge["src_conn"],
            target,
            edge["dst_conn"],
            subset,
            *base_type,
            json_to_debug_info(edge["debug_info"])
        );
        memlet.element_id_ = edge["element_id"];
    }
}

void JSONSerializer::json_to_sequence(
    const nlohmann::json& j, builder::StructuredSDFGBuilder& builder, structured_control_flow::Sequence& sequence
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j.contains("children"));
    assert(j["children"].is_array());
    assert(j.contains("transitions"));
    assert(j["transitions"].is_array());
    assert(j["transitions"].size() == j["children"].size());

    sequence.element_id_ = j["element_id"];
    sequence.debug_info_ = json_to_debug_info(j["debug_info"]);

    std::string type = j["type"];
    if (type == "sequence") {
        for (size_t i = 0; i < j["children"].size(); i++) {
            auto& child = j["children"][i];
            auto& transition = j["transitions"][i];
            assert(child.contains("type"));
            assert(child["type"].is_string());

            assert(transition.contains("type"));
            assert(transition["type"].is_string());
            assert(transition.contains("assignments"));
            assert(transition["assignments"].is_array());
            control_flow::Assignments assignments;
            for (const auto& assignment : transition["assignments"]) {
                assert(assignment.contains("symbol"));
                assert(assignment["symbol"].is_string());
                assert(assignment.contains("expression"));
                assert(assignment["expression"].is_string());
                auto expr = symbolic::parse(assignment["expression"].get<std::string>());
                assignments.insert({symbolic::symbol(assignment["symbol"]), expr});
            }

            if (child["type"] == "block") {
                json_to_block_node(child, builder, sequence, assignments);
            } else if (child["type"] == "for") {
                json_to_for_node(child, builder, sequence, assignments);
            } else if (child["type"] == "if_else") {
                json_to_if_else_node(child, builder, sequence, assignments);
            } else if (child["type"] == "while") {
                json_to_while_node(child, builder, sequence, assignments);
            } else if (child["type"] == "break") {
                json_to_break_node(child, builder, sequence, assignments);
            } else if (child["type"] == "continue") {
                json_to_continue_node(child, builder, sequence, assignments);
            } else if (child["type"] == "return") {
                json_to_return_node(child, builder, sequence, assignments);
            } else if (child["type"] == "map") {
                json_to_map_node(child, builder, sequence, assignments);
            } else if (child["type"] == "reduce") {
                json_to_reduce_node(child, builder, sequence, assignments);
            } else if (child["type"] == "sequence") {
                auto& subseq = builder.add_sequence(sequence, assignments, json_to_debug_info(child["debug_info"]));
                json_to_sequence(child, builder, subseq);
            } else {
                throw std::runtime_error("Unknown child type");
            }

            sequence.at(i).second.debug_info_ = json_to_debug_info(transition["debug_info"]);
            sequence.at(i).second.element_id_ = transition["element_id"];
        }
    } else {
        throw std::runtime_error("expected sequence type");
    }
}

void JSONSerializer::json_to_block_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j.contains("dataflow"));
    assert(j["dataflow"].is_object());
    auto& block = builder.add_block(parent, assignments, json_to_debug_info(j["debug_info"]));
    block.element_id_ = j["element_id"];
    assert(j["dataflow"].contains("type"));
    assert(j["dataflow"]["type"].is_string());
    std::string type = j["dataflow"]["type"];
    if (type == "dataflow") {
        json_to_dataflow(j["dataflow"], builder, block);
    } else {
        throw std::runtime_error("Unknown dataflow type");
    }
}

void JSONSerializer::json_to_for_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j.contains("indvar"));
    assert(j["indvar"].is_string());
    assert(j.contains("init"));
    assert(j["init"].is_string());
    assert(j.contains("condition"));
    assert(j["condition"].is_string());
    assert(j.contains("update"));
    assert(j["update"].is_string());
    assert(j.contains("root"));
    assert(j["root"].is_object());

    symbolic::Symbol indvar = symbolic::symbol(j["indvar"]);
    auto init = symbolic::parse(j["init"].get<std::string>());
    auto update = symbolic::parse(j["update"].get<std::string>());

    auto condition_expr = symbolic::parse(j["condition"].get<std::string>());
    symbolic::Condition condition = SymEngine::rcp_dynamic_cast<const SymEngine::Boolean>(condition_expr);
    if (condition.is_null()) {
        throw InvalidSDFGException("For loop condition is not a boolean expression");
    }

    auto& for_node =
        builder.add_for(parent, indvar, condition, init, update, assignments, json_to_debug_info(j["debug_info"]));
    for_node.element_id_ = j["element_id"];

    assert(j["root"].contains("type"));
    assert(j["root"]["type"].is_string());
    assert(j["root"]["type"] == "sequence");
    json_to_sequence(j["root"], builder, for_node.root());
}

void JSONSerializer::json_to_if_else_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j["type"] == "if_else");
    assert(j.contains("branches"));
    assert(j["branches"].is_array());
    auto& if_else_node = builder.add_if_else(parent, assignments, json_to_debug_info(j["debug_info"]));
    if_else_node.element_id_ = j["element_id"];
    for (const auto& branch : j["branches"]) {
        assert(branch.contains("condition"));
        assert(branch["condition"].is_string());
        assert(branch.contains("root"));
        assert(branch["root"].is_object());

        auto condition_expr = symbolic::parse(branch["condition"].get<std::string>());
        symbolic::Condition condition = SymEngine::rcp_dynamic_cast<const SymEngine::Boolean>(condition_expr);
        if (condition.is_null()) {
            throw InvalidSDFGException("If condition is not a boolean expression");
        }
        auto& branch_node = builder.add_case(if_else_node, condition);
        assert(branch["root"].contains("type"));
        assert(branch["root"]["type"].is_string());
        std::string type = branch["root"]["type"];
        if (type == "sequence") {
            json_to_sequence(branch["root"], builder, branch_node);
        } else {
            throw std::runtime_error("Unknown child type");
        }
    }
}

void JSONSerializer::json_to_while_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j["type"] == "while");
    assert(j.contains("root"));
    assert(j["root"].is_object());

    auto& while_node = builder.add_while(parent, assignments, json_to_debug_info(j["debug_info"]));
    while_node.element_id_ = j["element_id"];

    assert(j["root"]["type"] == "sequence");
    json_to_sequence(j["root"], builder, while_node.root());
}

void JSONSerializer::json_to_break_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j["type"] == "break");
    auto& node = builder.add_break(parent, assignments, json_to_debug_info(j["debug_info"]));
    node.element_id_ = j["element_id"];
}

void JSONSerializer::json_to_continue_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j["type"] == "continue");
    auto& node = builder.add_continue(parent, assignments, json_to_debug_info(j["debug_info"]));
    node.element_id_ = j["element_id"];
}

void JSONSerializer::json_to_map_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j["type"] == "map");
    assert(j.contains("indvar"));
    assert(j["indvar"].is_string());
    assert(j.contains("init"));
    assert(j["init"].is_string());
    assert(j.contains("condition"));
    assert(j["condition"].is_string());
    assert(j.contains("update"));
    assert(j["update"].is_string());
    assert(j.contains("root"));
    assert(j["root"].is_object());
    assert(j.contains("schedule_type"));
    assert(j["schedule_type"].is_object());

    structured_control_flow::ScheduleType schedule_type = json_to_schedule_type(j["schedule_type"]);

    symbolic::Symbol indvar = symbolic::symbol(j["indvar"]);
    auto init = symbolic::parse(j["init"].get<std::string>());
    auto update = symbolic::parse(j["update"].get<std::string>());
    auto condition_expr = symbolic::parse(j["condition"].get<std::string>());
    symbolic::Condition condition = SymEngine::rcp_dynamic_cast<const SymEngine::Boolean>(condition_expr);
    if (condition.is_null()) {
        throw InvalidSDFGException("Map condition is not a boolean expression");
    }

    auto& map_node = builder.add_map(
        parent, indvar, condition, init, update, schedule_type, assignments, json_to_debug_info(j["debug_info"])
    );
    map_node.element_id_ = j["element_id"];

    assert(j["root"].contains("type"));
    assert(j["root"]["type"].is_string());
    assert(j["root"]["type"] == "sequence");
    json_to_sequence(j["root"], builder, map_node.root());
}

void JSONSerializer::json_to_reduce_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j["type"] == "reduce");
    assert(j.contains("indvar"));
    assert(j["indvar"].is_string());
    assert(j.contains("init"));
    assert(j["init"].is_string());
    assert(j.contains("condition"));
    assert(j["condition"].is_string());
    assert(j.contains("update"));
    assert(j["update"].is_string());
    assert(j.contains("root"));
    assert(j["root"].is_object());
    assert(j.contains("reductions"));
    assert(j["reductions"].is_array());
    assert(j.contains("schedule_type"));
    assert(j["schedule_type"].is_object());

    std::vector<structured_control_flow::ReductionInfo> reductions;
    for (const auto& reduction_json : j["reductions"]) {
        assert(reduction_json.contains("op"));
        assert(reduction_json["op"].is_string());
        assert(reduction_json.contains("container"));
        assert(reduction_json["container"].is_string());
        reductions.push_back(structured_control_flow::ReductionInfo{
            structured_control_flow::reduction_operation_from_string(reduction_json["op"].get<std::string>()),
            reduction_json["container"].get<std::string>()
        });
    }

    structured_control_flow::ScheduleType schedule_type = json_to_schedule_type(j["schedule_type"]);

    symbolic::Symbol indvar = symbolic::symbol(j["indvar"]);
    auto init = symbolic::parse(j["init"].get<std::string>());
    auto update = symbolic::parse(j["update"].get<std::string>());
    auto condition_expr = symbolic::parse(j["condition"].get<std::string>());
    symbolic::Condition condition = SymEngine::rcp_dynamic_cast<const SymEngine::Boolean>(condition_expr);
    if (condition.is_null()) {
        throw InvalidSDFGException("Reduce condition is not a boolean expression");
    }

    auto& reduce_node = builder.add_reduce(
        parent,
        indvar,
        condition,
        init,
        update,
        reductions,
        schedule_type,
        assignments,
        json_to_debug_info(j["debug_info"])
    );
    reduce_node.element_id_ = j["element_id"];

    assert(j["root"].contains("type"));
    assert(j["root"]["type"].is_string());
    assert(j["root"]["type"] == "sequence");
    json_to_sequence(j["root"], builder, reduce_node.root());
}

void JSONSerializer::json_to_return_node(
    const nlohmann::json& j,
    builder::StructuredSDFGBuilder& builder,
    structured_control_flow::Sequence& parent,
    control_flow::Assignments& assignments
) {
    assert(j.contains("type"));
    assert(j["type"].is_string());
    assert(j["type"] == "return");

    std::string data = j["data"];
    std::unique_ptr<types::IType> data_type = nullptr;
    if (j.contains("data_type")) {
        data_type = json_to_type(j["data_type"]);
    }

    if (data_type == nullptr) {
        auto& node = builder.add_return(parent, data, assignments, json_to_debug_info(j["debug_info"]));
        node.element_id_ = j["element_id"];
    } else {
        auto& node =
            builder.add_constant_return(parent, data, *data_type, assignments, json_to_debug_info(j["debug_info"]));
        node.element_id_ = j["element_id"];
    }
}

std::unique_ptr<types::IType> JSONSerializer::json_to_type(const nlohmann::json& j) {
    if (j.contains("type")) {
        if (j["type"] == "scalar") {
            // Deserialize scalar type
            assert(j.contains("primitive_type"));
            types::PrimitiveType primitive_type = j["primitive_type"];
            assert(j.contains("storage_type"));
            types::StorageType storage_type = json_to_storage_type(j["storage_type"]);
            assert(j.contains("initializer"));
            std::string initializer = j["initializer"];
            assert(j.contains("alignment"));
            size_t alignment = j["alignment"];
            return std::make_unique<types::Scalar>(storage_type, alignment, initializer, primitive_type);
        } else if (j["type"] == "array") {
            // Deserialize array type
            assert(j.contains("element_type"));
            std::unique_ptr<types::IType> member_type = json_to_type(j["element_type"]);
            assert(j.contains("num_elements"));
            std::string num_elements_str = j["num_elements"];
            // Convert num_elements_str to symbolic::Expression
            auto num_elements = symbolic::parse(num_elements_str);
            assert(j.contains("storage_type"));
            types::StorageType storage_type = json_to_storage_type(j["storage_type"]);
            assert(j.contains("initializer"));
            std::string initializer = j["initializer"];
            assert(j.contains("alignment"));
            size_t alignment = j["alignment"];
            return std::make_unique<types::Array>(storage_type, alignment, initializer, *member_type, num_elements);
        } else if (j["type"] == "pointer") {
            // Deserialize pointer type
            std::optional<std::unique_ptr<types::IType>> pointee_type;
            if (j.contains("pointee_type")) {
                assert(j.contains("pointee_type"));
                pointee_type = json_to_type(j["pointee_type"]);
            } else {
                pointee_type = std::nullopt;
            }
            assert(j.contains("storage_type"));
            types::StorageType storage_type = json_to_storage_type(j["storage_type"]);
            assert(j.contains("initializer"));
            std::string initializer = j["initializer"];
            assert(j.contains("alignment"));
            size_t alignment = j["alignment"];
            if (pointee_type.has_value()) {
                return std::make_unique<types::Pointer>(storage_type, alignment, initializer, *pointee_type.value());
            } else {
                return std::make_unique<types::Pointer>(storage_type, alignment, initializer);
            }
        } else if (j["type"] == "structure") {
            // Deserialize structure type
            assert(j.contains("name"));
            std::string name = j["name"];
            assert(j.contains("storage_type"));
            types::StorageType storage_type = json_to_storage_type(j["storage_type"]);
            assert(j.contains("initializer"));
            std::string initializer = j["initializer"];
            assert(j.contains("alignment"));
            size_t alignment = j["alignment"];
            return std::make_unique<types::Structure>(storage_type, alignment, initializer, name);
        } else if (j["type"] == "function") {
            // Deserialize function type
            assert(j.contains("return_type"));
            std::unique_ptr<types::IType> return_type = json_to_type(j["return_type"]);
            assert(j.contains("params"));
            std::vector<std::unique_ptr<types::IType>> params;
            for (const auto& param : j["params"]) {
                params.push_back(json_to_type(param));
            }
            assert(j.contains("is_var_arg"));
            bool is_var_arg = j["is_var_arg"];
            assert(j.contains("storage_type"));
            types::StorageType storage_type = json_to_storage_type(j["storage_type"]);
            assert(j.contains("initializer"));
            std::string initializer = j["initializer"];
            assert(j.contains("alignment"));
            size_t alignment = j["alignment"];
            auto function =
                std::make_unique<types::Function>(storage_type, alignment, initializer, *return_type, is_var_arg);
            for (const auto& param : params) {
                function->add_param(*param);
            }
            return function->clone();
        } else if (j["type"] == "reference") {
            // Deserialize reference type
            assert(j.contains("reference_type"));
            std::unique_ptr<types::IType> reference_type = json_to_type(j["reference_type"]);
            return std::make_unique<sdfg::codegen::Reference>(*reference_type);
        } else if (j["type"] == "tensor") {
            // Deserialize tensor type
            assert(j.contains("element_type"));
            std::unique_ptr<types::IType> element_type = json_to_type(j["element_type"]);
            assert(j.contains("shape"));
            std::vector<symbolic::Expression> shape;
            for (const auto& dim : j["shape"]) {
                assert(dim.is_string());
                std::string dim_str = dim;
                auto expr = symbolic::parse(dim_str);
                shape.push_back(expr);
            }
            assert(j.contains("strides"));
            std::vector<symbolic::Expression> strides;
            for (const auto& stride : j["strides"]) {
                assert(stride.is_string());
                std::string stride_str = stride;
                auto expr = symbolic::parse(stride_str);
                strides.push_back(expr);
            }
            assert(j.contains("offset"));
            symbolic::Expression offset = symbolic::parse(j["offset"].get<std::string>());
            assert(j.contains("storage_type"));
            types::StorageType storage_type = json_to_storage_type(j["storage_type"]);
            assert(j.contains("initializer"));
            std::string initializer = j["initializer"];
            assert(j.contains("alignment"));
            size_t alignment = j["alignment"];
            return std::make_unique<types::Tensor>(
                storage_type, alignment, initializer, dynamic_cast<types::Scalar&>(*element_type), shape, strides, offset
            );
        } else {
            throw std::runtime_error("Unknown type");
        }
    } else {
        throw std::runtime_error("Type not found");
    }
}

DebugInfo JSONSerializer::json_to_debug_info(const nlohmann::json& j) {
    assert(j.contains("has"));
    assert(j["has"].is_boolean());
    if (!j["has"]) {
        return DebugInfo();
    }
    assert(j.contains("filename"));
    assert(j["filename"].is_string());
    std::string filename = j["filename"];
    assert(j.contains("function"));
    assert(j["function"].is_string());
    std::string function = j["function"];
    assert(j.contains("start_line"));
    assert(j["start_line"].is_number_integer());
    size_t start_line = j["start_line"];
    assert(j.contains("start_column"));
    assert(j["start_column"].is_number_integer());
    size_t start_column = j["start_column"];
    assert(j.contains("end_line"));
    assert(j["end_line"].is_number_integer());
    size_t end_line = j["end_line"];
    assert(j.contains("end_column"));
    assert(j["end_column"].is_number_integer());
    size_t end_column = j["end_column"];
    return DebugInfo(filename, function, start_line, start_column, end_line, end_column);
}

ScheduleType JSONSerializer::json_to_schedule_type(const nlohmann::json& j) {
    assert(j.contains("value"));
    assert(j["value"].is_string());
    // assert(j.contains("category"));
    // assert(j["category"].is_number_integer());
    assert(j.contains("properties"));
    assert(j["properties"].is_object());
    ScheduleTypeCategory category = ScheduleTypeCategory::None;
    if (j.contains("category")) {
        category = static_cast<ScheduleTypeCategory>(j["category"].get<int>());
    }
    ScheduleType schedule_type(j["value"].get<std::string>(), category);
    for (const auto& [key, value] : j["properties"].items()) {
        assert(value.is_string());
        schedule_type.set_property(key, value.get<std::string>());
    }
    return schedule_type;
}

types::StorageType JSONSerializer::json_to_storage_type(const nlohmann::json& j) {
    if (!j.contains("value")) {
        return types::StorageType::CPU_Stack();
    }
    std::string value = j["value"].get<std::string>();

    symbolic::Expression allocation_size = SymEngine::null;
    if (j.contains("allocation_size")) {
        allocation_size = symbolic::parse(j["allocation_size"].get<std::string>());
    }

    types::StorageType::AllocationType allocation = j["allocation"];
    types::StorageType::AllocationType deallocation = j["deallocation"];

    auto storageType = types::StorageType(j["value"].get<std::string>(), allocation_size, allocation, deallocation);

    if (j.contains("args")) {
        nlohmann::json::array_t args = j["args"];
        if (args.size() > 0) {
            storageType.arg1(symbolic::parse(args[0].get<std::string>()));
        }
    }
    return storageType;
}

std::string JSONSerializer::expression(const symbolic::Expression expr) {
    JSONSymbolicPrinter printer;
    return printer.apply(expr);
};

symbolic::Expression JSONSerializer::json_to_expr(const nlohmann::json& j) {
    return symbolic::parse(j.get<std::string>());
}

void JSONSerializer::writeToFile(const StructuredSDFG& sdfg, const std::filesystem::path& file) {
    JSONSerializer ser;
    auto json = ser.serialize(sdfg);

    auto parent_path = file.parent_path();
    if (!parent_path.empty()) {
        std::filesystem::create_directories(file.parent_path());
    }

    std::ofstream out(file, std::ofstream::out);
    if (!out.is_open()) {
        std::cerr << "Could not open file " << file << " for writing JSON output." << std::endl;
    }
    out << json << std::endl;
    out.close();
}

void JSONSymbolicPrinter::bvisit(const SymEngine::Equality& x) {
    str_ = apply(x.get_args()[0]) + " == " + apply(x.get_args()[1]);
    str_ = parenthesize(str_);
};

void JSONSymbolicPrinter::bvisit(const SymEngine::Unequality& x) {
    str_ = apply(x.get_args()[0]) + " != " + apply(x.get_args()[1]);
    str_ = parenthesize(str_);
};

void JSONSymbolicPrinter::bvisit(const SymEngine::LessThan& x) {
    str_ = apply(x.get_args()[0]) + " <= " + apply(x.get_args()[1]);
    str_ = parenthesize(str_);
};

void JSONSymbolicPrinter::bvisit(const SymEngine::StrictLessThan& x) {
    str_ = apply(x.get_args()[0]) + " < " + apply(x.get_args()[1]);
    str_ = parenthesize(str_);
};

void JSONSymbolicPrinter::bvisit(const SymEngine::Min& x) {
    std::ostringstream s;
    auto container = x.get_args();
    if (container.size() == 1) {
        s << apply(*container.begin());
    } else {
        s << "min(";
        s << apply(*container.begin());

        // Recursively apply __daisy_min to the arguments
        SymEngine::vec_basic subargs;
        for (auto it = ++(container.begin()); it != container.end(); ++it) {
            subargs.push_back(*it);
        }
        auto submin = SymEngine::min(subargs);
        s << ", " << apply(submin);

        s << ")";
    }

    str_ = s.str();
};

void JSONSymbolicPrinter::bvisit(const SymEngine::Max& x) {
    std::ostringstream s;
    auto container = x.get_args();
    if (container.size() == 1) {
        s << apply(*container.begin());
    } else {
        s << "max(";
        s << apply(*container.begin());

        // Recursively apply __daisy_max to the arguments
        SymEngine::vec_basic subargs;
        for (auto it = ++(container.begin()); it != container.end(); ++it) {
            subargs.push_back(*it);
        }
        auto submax = SymEngine::max(subargs);
        s << ", " << apply(submax);

        s << ")";
    }

    str_ = s.str();
};

void LibraryNodeSerializerRegistry::
    register_library_node_serializer(std::string library_node_code, LibraryNodeSerializerFn fn) {
    std::lock_guard<std::mutex> lock(mutex_);
    if (factory_map_.find(library_node_code) != factory_map_.end()) {
        return;
    }
    factory_map_[library_node_code] = std::move(fn);
}

LibraryNodeSerializerFn LibraryNodeSerializerRegistry::get_library_node_serializer(std::string library_node_code) {
    auto it = factory_map_.find(library_node_code);
    if (it != factory_map_.end()) {
        return it->second;
    }
    return nullptr;
}

size_t LibraryNodeSerializerRegistry::size() const { return factory_map_.size(); }

void register_default_serializers() {
    // stdlib
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Alloca.value(), []() {
            return std::make_unique<stdlib::AllocaNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Assert.value(), []() {
            return std::make_unique<stdlib::AssertNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Calloc.value(), []() {
            return std::make_unique<stdlib::CallocNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Free.value(), []() {
            return std::make_unique<stdlib::FreeNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Malloc.value(), []() {
            return std::make_unique<stdlib::MallocNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Memcpy.value(), []() {
            return std::make_unique<stdlib::MemcpyNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Memmove.value(), []() {
            return std::make_unique<stdlib::MemmoveNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Memset.value(), []() {
            return std::make_unique<stdlib::MemsetNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Trap.value(), []() {
            return std::make_unique<stdlib::TrapNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(stdlib::LibraryNodeType_Unreachable.value(), []() {
            return std::make_unique<stdlib::UnreachableNodeSerializer>();
        });

    // Metadata
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(data_flow::LibraryNodeType_Metadata.value(), []() {
            return std::make_unique<data_flow::MetadataNodeSerializer>();
        });

    // Barrier
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(data_flow::LibraryNodeType_BarrierLocal.value(), []() {
            return std::make_unique<data_flow::BarrierLocalNodeSerializer>();
        });

    // Call Node
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(data_flow::LibraryNodeType_Call.value(), []() {
            return std::make_unique<data_flow::CallNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(data_flow::LibraryNodeType_Invoke.value(), []() {
            return std::make_unique<data_flow::InvokeNodeSerializer>();
        });

    // LoadConst
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(data_flow::LibraryNodeType_LoadConst.value(), []() {
            return std::make_unique<data_flow::LoadConstNodeSerializer>();
        });

    // CMath
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::cmath::LibraryNodeType_CMath.value(), []() {
            return std::make_unique<math::cmath::CMathNodeSerializer>();
        });
    // Backward compatibility
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::cmath::LibraryNodeType_CMath_Deprecated.value(), []() {
            return std::make_unique<math::cmath::CMathNodeSerializer>();
        });

    // BLAS
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::blas::LibraryNodeType_DOT.value(), []() {
            return std::make_unique<math::blas::DotNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::blas::LibraryNodeType_GEMM.value(), []() {
            return std::make_unique<math::blas::GEMMNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::blas::LibraryNodeType_BatchedGEMM.value(), []() {
            return std::make_unique<math::blas::BatchedGEMMNodeSerializer>();
        });

    // Tensor

    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Broadcast.value(), []() {
            return std::make_unique<math::tensor::BroadcastNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Conv.value(), []() {
            return std::make_unique<math::tensor::ConvNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Pooling.value(), []() {
            return std::make_unique<math::tensor::PoolingNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Transpose.value(), []() {
            return std::make_unique<math::tensor::TransposeNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_MatMul.value(), []() {
            return std::make_unique<math::tensor::MatMulNodeSerializer>();
        });

    // Elementwise
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Abs.value(), []() {
            return std::make_unique<math::tensor::AbsNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Add.value(), []() {
            return std::make_unique<math::tensor::AddNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Div.value(), []() {
            return std::make_unique<math::tensor::DivNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Elu.value(), []() {
            return std::make_unique<math::tensor::EluNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Exp.value(), []() {
            return std::make_unique<math::tensor::ExpNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Erf.value(), []() {
            return std::make_unique<math::tensor::ErfNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_HardSigmoid.value(), []() {
            return std::make_unique<math::tensor::HardSigmoidNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_LeakyReLU.value(), []() {
            return std::make_unique<math::tensor::LeakyReLUNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Mul.value(), []() {
            return std::make_unique<math::tensor::MulNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Pow.value(), []() {
            return std::make_unique<math::tensor::PowNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_ReLU.value(), []() {
            return std::make_unique<math::tensor::ReLUNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Sigmoid.value(), []() {
            return std::make_unique<math::tensor::SigmoidNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Sqrt.value(), []() {
            return std::make_unique<math::tensor::SqrtNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Sub.value(), []() {
            return std::make_unique<math::tensor::SubNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Tanh.value(), []() {
            return std::make_unique<math::tensor::TanhNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Minimum.value(), []() {
            return std::make_unique<math::tensor::MinimumNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Maximum.value(), []() {
            return std::make_unique<math::tensor::MaximumNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Fill.value(), []() {
            return std::make_unique<math::tensor::FillNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_TensorTasklet.value(), []() {
            return std::make_unique<math::tensor::TaskletTensorNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_TensorCMath.value(), []() {
            return std::make_unique<math::tensor::CMathTensorNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Cast.value(), []() {
            return std::make_unique<math::tensor::CastNodeSerializer>();
        });

    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_BatchNorm.value(), [] {
            return std::make_unique<math::tensor::BatchNormNodeSerializer>();
        });

    // Reduce
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Sum.value(), []() {
            return std::make_unique<math::tensor::SumNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Max.value(), []() {
            return std::make_unique<math::tensor::MaxNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Min.value(), []() {
            return std::make_unique<math::tensor::MinNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Softmax.value(), []() {
            return std::make_unique<math::tensor::SoftmaxNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Mean.value(), []() {
            return std::make_unique<math::tensor::MeanNodeSerializer>();
        });
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Std.value(), []() {
            return std::make_unique<math::tensor::StdNodeSerializer>();
        });

    // Einsum
    LibraryNodeSerializerRegistry::instance()
        .register_library_node_serializer(math::tensor::LibraryNodeType_Einsum.value(), []() {
            return std::make_unique<math::tensor::EinsumSerializer>();
        });
}

} // namespace serializer
} // namespace sdfg

daisytuner / docc / 27956659323

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous