use onnx_ir_derive::NodeBuilder;
use crate::ir::{ArgType, Argument, DType, Node, RawNode};
use crate::processor::{
InputSpec, NodeProcessor, NodeSpec, OutputPreferences, OutputSpec, ProcessError,
};
#[derive(Debug, Clone, NodeBuilder)]
pub struct SizeNode {
pub name: String,
pub inputs: Vec<Argument>,
pub outputs: Vec<Argument>,
}
pub(crate) struct SizeProcessor;
impl NodeProcessor for SizeProcessor {
type Config = ();
fn spec(&self) -> NodeSpec {
NodeSpec {
min_opset: 1,
max_opset: None,
inputs: InputSpec::Exact(1),
outputs: OutputSpec::Exact(1),
}
}
fn infer_types(
&self,
node: &mut RawNode,
_opset: usize,
_output_preferences: &OutputPreferences,
) -> Result<(), ProcessError> {
node.outputs[0].ty = ArgType::ScalarNative(DType::I64);
Ok(())
}
fn build_node(&self, builder: RawNode, _opset: usize) -> Node {
Node::Size(SizeNode {
name: builder.name,
inputs: builder.inputs,
outputs: builder.outputs,
})
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::ir::NodeType;
use crate::node::test_utils::TestNodeBuilder;
fn create_test_node(rank: usize) -> RawNode {
let builder = TestNodeBuilder::new(NodeType::Size, "test_size")
.input_tensor_f32("data", rank, None)
.output_scalar_i64("size");
builder.build()
}
#[test]
fn test_size_update_outputs() {
let mut node = create_test_node(4);
let processor = SizeProcessor;
let prefs = OutputPreferences::new();
processor.infer_types(&mut node, 16, &prefs).unwrap();
assert!(matches!(
&node.outputs[0].ty,
ArgType::ScalarNative(DType::I64)
));
}
}