use crate::from_onnx::element_type_from_proto;
use crate::ir::{ArgType, AttributeValue, ElementType, Node, TensorType};
#[derive(Debug, Clone)]
pub struct CastConfig {
pub to: ElementType,
}
impl CastConfig {
pub fn new(to: ElementType) -> Self {
Self { to }
}
}
pub fn cast_config(node: &Node) -> CastConfig {
let elem_type = match node.attrs.get("to") {
Some(AttributeValue::Int64(type_id)) => {
element_type_from_proto(*type_id as i32).expect("Cast: unsupported 'to' dtype")
}
_ => panic!("Cast node must have an Int64 'to' attribute"),
};
CastConfig::new(elem_type)
}
pub fn cast_update_outputs(node: &mut Node) {
if node.inputs.len() != 1 {
panic!("Cast: multiple inputs are not supported");
}
let config = cast_config(node);
let elem_type = config.to;
let input = &mut node.inputs[0];
let output = &mut node.outputs[0];
match input.ty.clone() {
ArgType::Tensor(tensor) => {
if tensor.rank == 0 {
output.ty = ArgType::Scalar(elem_type);
input.ty = ArgType::Scalar(tensor.elem_type);
} else {
output.ty = ArgType::Tensor(TensorType {
elem_type,
rank: tensor.rank,
static_shape: tensor.static_shape, });
}
}
ArgType::Scalar(_) => output.ty = ArgType::Scalar(elem_type),
ArgType::Shape(rank) => {
match elem_type {
ElementType::Float32
| ElementType::Float64
| ElementType::Float16
| ElementType::Bool => {
output.ty = ArgType::Tensor(TensorType {
elem_type: elem_type.clone(),
rank: 1,
static_shape: Some(vec![rank]),
});
log::debug!(
"Cast converting Shape({}) to rank-1 tensor of {:?}",
rank,
elem_type
);
}
_ => {
output.ty = ArgType::Shape(rank);
}
}
}
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::ir::{Argument, NodeType, TensorType};
use crate::node::test_utils::NodeBuilder;
use crate::protos::tensor_proto::DataType;
use protobuf::Enum;
fn create_test_node(input_rank: usize, to_type: i64) -> Node {
NodeBuilder::new(NodeType::Cast, "test_cast")
.input_tensor_f32("X", input_rank, None)
.output_tensor_f32("Y", input_rank, None) .attr_int("to", to_type)
.build()
}
fn create_scalar_test_node(to_type: i64) -> Node {
NodeBuilder::new(NodeType::Cast, "test_cast")
.input_scalar_f32("X")
.output_scalar_f32("Y") .attr_int("to", to_type)
.build()
}
#[test]
fn test_cast_config() {
let node = create_test_node(2, DataType::INT64.value() as i64);
let config = cast_config(&node);
assert_eq!(config.to, ElementType::Int64);
let node = create_test_node(2, DataType::FLOAT.value() as i64);
let config = cast_config(&node);
assert_eq!(config.to, ElementType::Float32);
let node = create_test_node(2, DataType::BOOL.value() as i64);
let config = cast_config(&node);
assert_eq!(config.to, ElementType::Bool);
}
#[test]
fn test_cast_float_to_int64() {
let mut node = create_test_node(2, DataType::INT64.value() as i64);
cast_update_outputs(&mut node);
match &node.outputs[0].ty {
ArgType::Tensor(tensor) => {
assert_eq!(tensor.elem_type, ElementType::Int64);
assert_eq!(tensor.rank, 2);
}
_ => panic!("Expected tensor output"),
}
}
#[test]
fn test_cast_scalar_handling() {
let mut node = create_test_node(0, DataType::BOOL.value() as i64);
cast_update_outputs(&mut node);
match &node.outputs[0].ty {
ArgType::Scalar(elem_type) => {
assert_eq!(*elem_type, ElementType::Bool);
}
_ => panic!("Expected scalar output for 0-rank tensor"),
}
match &node.inputs[0].ty {
ArgType::Scalar(elem_type) => {
assert_eq!(*elem_type, ElementType::Float32);
}
_ => panic!("Input should have been converted to scalar"),
}
}
#[test]
#[should_panic(expected = "Cast: multiple inputs are not supported")]
fn test_cast_multiple_inputs() {
let mut node = create_test_node(2, DataType::INT64.value() as i64);
node.inputs.push(Argument {
name: "extra".to_string(),
ty: ArgType::Tensor(TensorType {
elem_type: ElementType::Float32,
rank: 1,
static_shape: None,
}),
value: None,
passed: true,
});
cast_update_outputs(&mut node);
}
#[test]
fn test_cast_scalar_to_bool() {
let mut node = create_scalar_test_node(DataType::BOOL.value() as i64);
cast_update_outputs(&mut node);
match &node.outputs[0].ty {
ArgType::Scalar(elem_type) => {
assert_eq!(*elem_type, ElementType::Bool);
}
_ => panic!("Expected scalar output"),
}
}
#[test]
fn test_cast_shape_to_float32() {
let mut node = NodeBuilder::new(NodeType::Cast, "test_cast")
.input_shape("shape_input", 3)
.output_shape("output", 3) .attr_int("to", DataType::FLOAT.value() as i64)
.build();
cast_update_outputs(&mut node);
match &node.outputs[0].ty {
ArgType::Tensor(tensor) => {
assert_eq!(tensor.elem_type, ElementType::Float32);
assert_eq!(tensor.rank, 1);
assert_eq!(tensor.static_shape, Some(vec![3]));
}
_ => panic!("Expected rank-1 tensor output when casting Shape to float"),
}
}
#[test]
fn test_cast_shape_to_int64_remains_shape() {
let mut node = NodeBuilder::new(NodeType::Cast, "test_cast")
.input_shape("shape_input", 4)
.output_shape("output", 4) .attr_int("to", DataType::INT64.value() as i64)
.build();
cast_update_outputs(&mut node);
match &node.outputs[0].ty {
ArgType::Shape(rank) => {
assert_eq!(*rank, 4);
}
_ => panic!("Expected Shape output when casting Shape to int64"),
}
}
#[test]
fn test_cast_shape_to_bool() {
let mut node = NodeBuilder::new(NodeType::Cast, "test_cast")
.input_shape("shape_input", 3)
.output_shape("output", 3) .attr_int("to", DataType::BOOL.value() as i64)
.build();
cast_update_outputs(&mut node);
match &node.outputs[0].ty {
ArgType::Tensor(tensor) => {
assert_eq!(tensor.elem_type, ElementType::Bool);
assert_eq!(tensor.rank, 1);
assert_eq!(tensor.static_shape, Some(vec![3]));
}
_ => panic!("Expected rank-1 bool tensor output when casting Shape to bool"),
}
}
}