#include "op_plugin/AclOpsInterface.h"
#include "op_plugin/utils/OpAdapter.h"
namespace acl_op {
using npu_preparation = at_npu::native::OpPreparation;
using npu_utils = at_npu::native::NpuUtils;
namespace {
at::Tensor& take_out_nocheck(at::Tensor& result, const at::Tensor& self, const at::Tensor& index)
{
at::Tensor input_tensor = self.reshape(-1);
at::Tensor contiguous_self = npu_utils::format_contiguous(input_tensor);
at::Tensor contiguous_index = npu_utils::format_contiguous(index);
at_npu::native::OpCommand cmd;
cmd.Name("Gather")
.Input(contiguous_self)
.Input(contiguous_index)
.Output(result)
.Attr("validate_indices", false)
.Run();
return result;
}
}
at::Tensor& take_out(const at::Tensor& self, const at::Tensor& index, at::Tensor& out)
{
auto output_size = op_infer::input_same_output_size(index);
npu_preparation::CheckOut(
{self, index},
out,
self,
output_size);
if (!npu_utils::check_match(&out)) {
at::Tensor contiguous_result = npu_utils::format_contiguous(out);
take_out_nocheck(contiguous_result, self, index);
npu_utils::format_fresh_view(out, contiguous_result);
} else {
take_out_nocheck(out, self, index);
}
return out;
}
at::Tensor take(const at::Tensor& self, const at::Tensor& index)
{
at::Tensor result = npu_preparation::apply_tensor(self, index.sizes());
take_out_nocheck(result, self, index);
return result;
}
}