use super::prelude::*;
impl NodeCodegen for onnx_ir::node::xor::XorNode {
fn inputs(&self) -> &[Argument] {
&self.inputs
}
fn outputs(&self) -> &[Argument] {
&self.outputs
}
fn forward(&self, scope: &mut ScopeAtPosition<'_>) -> TokenStream {
let lhs = self.inputs.first().unwrap();
let rhs = self.inputs.get(1).unwrap();
let output = arg_to_ident(self.outputs.first().unwrap());
let lhs_value = scope.arg(lhs);
let rhs_value = scope.arg(rhs);
let function = match (&lhs.ty, &rhs.ty) {
(ArgType::Tensor(lhs_tensor), ArgType::Tensor(rhs_tensor)) => {
let lhs_rank = lhs_tensor.rank;
let rhs_rank = rhs_tensor.rank;
if lhs_rank == rhs_rank {
quote! { #lhs_value.not_equal(#rhs_value) }
} else if lhs_rank > rhs_rank {
let num_dims = lhs_rank - rhs_rank;
let dims: Vec<isize> = (0..num_dims).map(|i| i as isize).collect();
quote! { #lhs_value.not_equal(#rhs_value.unsqueeze_dims(&[#(#dims),*])) }
} else {
let num_dims = rhs_rank - lhs_rank;
let dims: Vec<isize> = (0..num_dims).map(|i| i as isize).collect();
quote! { #lhs_value.unsqueeze_dims(&[#(#dims),*]).not_equal(#rhs_value) }
}
}
(ArgType::Scalar(_), ArgType::Scalar(_)) => {
quote! { #lhs_value ^ #rhs_value }
}
_ => panic!("Xor operation requires tensor or scalar inputs"),
};
quote! {
let #output = #function;
}
}
}
#[cfg(test)]
mod tests {
use super::super::test_helpers::*;
use burn::tensor::DType;
use insta::assert_snapshot;
use onnx_ir::node::xor::XorNodeBuilder;
#[test]
fn test_xor_forward() {
let node = XorNodeBuilder::new("xor1")
.input_tensor("lhs", 2, DType::Bool)
.input_tensor("rhs", 2, DType::Bool)
.output_tensor("output", 2, DType::Bool)
.build();
let code = codegen_forward_default(&node);
assert_snapshot!(code, @r"
pub fn forward(
&self,
lhs: Tensor<B, 2, Bool>,
rhs: Tensor<B, 2, Bool>,
) -> Tensor<B, 2, Bool> {
let output = lhs.not_equal(rhs);
output
}
");
}
}