use tract_hir::internal::*;
use tract_hir::ops::array;
use crate::model::ParsingContext;
use crate::pb::*;
pub fn unsqueeze(
ctx: &ParsingContext,
node: &NodeProto,
) -> TractResult<(Box<dyn InferenceOp>, Vec<String>)> {
if ctx.onnx_operator_set_version < 13 {
let axes = node.get_attr_vec::<i64>("axes")?.into_iter().map(|x| x as isize).collect();
Ok((expand(array::AddDims::new(axes)), vec![]))
} else {
Ok((expand(Unsqueeze13), vec![]))
}
}
#[derive(Debug, Clone, Hash)]
struct Unsqueeze13;
impl Expansion for Unsqueeze13 {
fn name(&self) -> StaticName {
"Unsqueeze13".into()
}
fn rules<'r, 'p: 'r, 's: 'r>(
&'s self,
s: &mut Solver<'r>,
inputs: &'p [TensorProxy],
outputs: &'p [TensorProxy],
) -> InferenceResult {
check_input_arity(inputs, 2)?;
check_output_arity(outputs, 1)?;
s.equals(&outputs[0].datum_type, &inputs[0].datum_type)?;
s.given_2(&inputs[0].shape, &inputs[1].value, move |s, shape, axes| {
let axes = axes
.cast_to::<i64>()?
.try_as_dense()?
.as_slice::<i64>()?
.iter()
.map(|i| *i as isize)
.collect();
let op = tract_hir::ops::array::AddDims::new(axes);
let out_shape = op.output_shape(&shape);
s.equals(&outputs[0].shape, out_shape)
})
}
fn wire(
&self,
prefix: &str,
model: &mut TypedModel,
inputs: &[OutletId],
) -> TractResult<TVec<OutletId>> {
if let Some(axes) = model.outlet_fact(inputs[1])?.konst.as_ref() {
let axes = axes
.cast_to::<i64>()?
.try_as_dense()?
.as_slice::<i64>()?
.iter()
.map(|i| *i as isize)
.collect();
let op = tract_hir::ops::array::AddDims::new(axes);
op.wire(prefix, model, &inputs[0..1])
} else {
bail!("Need axes to be a constant")
}
}
}