openinfer-dsl 0.1.0

Rust-embedded DSL for defining OpenInfer graphs with explicit control flow and memory semantics.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

use std::collections::HashMap;

use proc_macro2::TokenStream;
use quote::quote;
use syn::Ident;

use crate::codegen::memory::match_dtype;
use crate::types::{OpAttrValue, OpSetting};

pub(crate) fn op_attrs_expr(_op: &Ident, settings: &[OpSetting]) -> syn::Result<TokenStream> {
    let mut map = SettingsMap::new(settings)?;
    let mut items = Vec::new();
    for (name, setting) in map.settings.drain() {
        let name_literal = name.clone();
        let value_expr = attr_value_expr(&setting)?;
        items.push(quote! {
            ::openinfer::OpAttr {
                name: #name_literal.to_string(),
                value: #value_expr,
            }
        });
    }
    Ok(quote! {
        ::openinfer::OpAttrs { items: vec![#(#items),*] }
    })
}

struct SettingsMap {
    settings: HashMap<String, OpSetting>,
}

impl SettingsMap {
    fn new(settings: &[OpSetting]) -> syn::Result<Self> {
        let mut map = HashMap::new();
        for setting in settings {
            let key = setting.name.to_string();
            if map.contains_key(&key) {
                return Err(syn::Error::new(
                    setting.name.span(),
                    format!("duplicate setting: {}", key),
                ));
            }
            map.insert(key, setting.clone());
        }
        Ok(Self { settings: map })
    }
}

fn attr_value_expr(setting: &OpSetting) -> syn::Result<TokenStream> {
    if setting.name == "acc" || setting.name == "to" {
        match &setting.value {
            OpAttrValue::Var(ident) => {
                let dtype = match_dtype(ident)?;
                return Ok(quote! { ::openinfer::AttrValue::DType(#dtype) });
            }
            _ => {
                return Err(syn::Error::new(
                    setting.name.span(),
                    "acc must be a dtype identifier",
                ));
            }
        }
    }

    let value = &setting.value;
    Ok(match value {
        OpAttrValue::Float(val) => {
            if val.is_infinite() {
                if val.is_sign_negative() {
                    quote! { ::openinfer::AttrValue::Float(::std::f32::NEG_INFINITY) }
                } else {
                    quote! { ::openinfer::AttrValue::Float(::std::f32::INFINITY) }
                }
            } else {
                let lit = proc_macro2::Literal::f32_unsuffixed(*val);
                quote! { ::openinfer::AttrValue::Float(#lit) }
            }
        }
        OpAttrValue::Double(val) => {
            if val.is_infinite() {
                if val.is_sign_negative() {
                    quote! { ::openinfer::AttrValue::Double(::std::f64::NEG_INFINITY) }
                } else {
                    quote! { ::openinfer::AttrValue::Double(::std::f64::INFINITY) }
                }
            } else {
                let lit = proc_macro2::Literal::f64_unsuffixed(*val);
                quote! { ::openinfer::AttrValue::Double(#lit) }
            }
        }
        OpAttrValue::Int(val) => {
            let lit = proc_macro2::Literal::i64_unsuffixed(*val);
            quote! { ::openinfer::AttrValue::Int(#lit) }
        }
        OpAttrValue::Bool(val) => {
            quote! { ::openinfer::AttrValue::Bool(#val) }
        }
        OpAttrValue::String(val) => {
            quote! { ::openinfer::AttrValue::Str(#val.to_string()) }
        }
        OpAttrValue::IntList(values) => {
            quote! { ::openinfer::AttrValue::IntList(vec![#(#values),*]) }
        }
        OpAttrValue::Var(ident) => {
            let s = ident.to_string();
            quote! { ::openinfer::AttrValue::Var(#s.to_string()) }
        }
    })
}