ContinuousConvTransposeSYCL.h

Go to the documentation of this file.

// ----------------------------------------------------------------------------
// -                        Open3D: www.open3d.org                            -
// ----------------------------------------------------------------------------
// Copyright (c) 2018-2026 www.open3d.org
// SPDX-License-Identifier: MIT
// ----------------------------------------------------------------------------
 
// SYCL port of ContinuousConvTranspose.cuh. See ContinuousConvSYCL.h's file
// header for the general porting notes. Uses FillColumnTransposeSYCL, the
// <ColumnMajor, ColumnMajor> GEMM layout combo (same as the forward op), and
// MultiplyColumnsSYCL for the optional output-importance scaling.
#pragma once
 
#include "open3d/ml/impl/GemmSYCL.h"
#include "open3d/ml/impl/continuous_conv/ContinuousConvSYCLKernels.h"
#include "open3d/ml/impl/misc/MemoryAllocation.h"
#include "open3d/utility/Helper.h"
 
using open3d::utility::DivUp;
 
namespace open3d {
namespace ml {
namespace impl {
 
template <class TFeat, class TOut, class TReal, class TIndex>
void CConvTransposeComputeFeaturesSYCL(
        sycl::queue& queue,
        void* temp,
        size_t& temp_size,
        size_t& max_temp_size,
        int texture_alignment,
        TOut* out_features,
        const std::vector<int>& filter_dims,
        const TFeat* filter,
        TIndex num_out,
        const TReal* out_positions,
        const TFeat* out_importance,
        TIndex num_inp,
        const TReal* inp_positions,
        const TFeat* inp_features,
        const TFeat* inp_neighbors_importance_sum,
        const int64_t* inp_neighbors_prefix_sum,
        size_t neighbors_index_size,
        const TIndex* neighbors_index,
        const TFeat* neighbors_importance,
        const int64_t* neighbors_row_splits,
        const TReal* extents,
        const TReal* offsets,
        InterpolationMode interpolation,
        CoordinateMapping coordinate_mapping,
        bool align_corners,
        bool individual_extent,
        bool isotropic_extent,
        bool normalize,
        bool allow_tf32) {
    const bool get_temp_size = !temp;
 
    if (get_temp_size) {
        temp = (char*)1;  // worst case alignment
        temp_size = std::numeric_limits<int64_t>::max();
    }
 
    MemoryAllocation mem_temp(temp, temp_size, texture_alignment);
 
    const int in_channels = filter_dims[filter_dims.size() - 2];
    const int out_channels = filter_dims[filter_dims.size() - 1];
 
    int spatial_filter_size = 1;
    for (int i = 0; i < 3; ++i) spatial_filter_size *= filter_dims[i];
 
    // this defines how much temporary storage we need at least.
    // we want to allocate memory for at least 32 output points.
    const size_t min_num_cols_per_run = std::min(size_t(num_out), size_t(32));
    const size_t max_num_cols_per_run = num_out;
    const size_t bytes_per_column =
            sizeof(TFeat) * (spatial_filter_size * in_channels);
    const size_t min_temp_size_bytes = min_num_cols_per_run * bytes_per_column;
    const size_t max_temp_size_bytes = max_num_cols_per_run * bytes_per_column;
 
    if (get_temp_size) {
        std::pair<char*, size_t> tmp =
                mem_temp.Alloc<char>(min_temp_size_bytes);
        temp_size = mem_temp.MaxUsed();
        mem_temp.Free(tmp);
        mem_temp.Alloc<char>(max_temp_size_bytes);
        max_temp_size = mem_temp.MaxUsed();
        return;
    }
 
    // Request segment using all of the temporary memory
    std::pair<void*, size_t> mem_columns = mem_temp.AllocLargestSegment();
 
    if (mem_columns.second < min_temp_size_bytes) {
        std::stringstream ss;
        ss << "temp is too small " << mem_columns.second
           << " bytes. Expected at least " << min_temp_size_bytes << " bytes\n";
        throw std::runtime_error(ss.str());
    }
 
    // init output
    sycl::event out_features_fill_event =
            queue.fill(out_features, TOut(0), size_t(num_out) * out_channels);
 
    size_t num_cols_per_run =
            std::min(mem_columns.second / bytes_per_column, size_t(num_out));
 
    TFeat* columns = (TFeat*)mem_columns.first;
 
    // if we cannot process all data at once we need multiple runs. See
    // ContinuousConvSYCL.h for the event-dependency reasoning.
    size_t num_runs = DivUp(num_out, num_cols_per_run);
    sycl::event prev_gemm_event;
    for (size_t run_i = 0; run_i < num_runs; ++run_i) {
        const TIndex begin_idx = TIndex(run_i * num_cols_per_run);
        const TIndex end_idx = TIndex(
                std::min(size_t(num_out), (run_i + 1) * num_cols_per_run));
        const size_t num_cols_this_run = end_idx - begin_idx;
 
        sycl::event fill_column_event = FillColumnTransposeSYCL<TFeat, TReal,
                                                                TIndex>(
                queue, columns, in_channels, begin_idx, end_idx, num_out,
                out_positions, num_inp, inp_positions, inp_features,
                inp_neighbors_importance_sum, inp_neighbors_prefix_sum,
                neighbors_index_size, neighbors_index, neighbors_importance,
                neighbors_row_splits, extents, offsets, filter_dims,
                interpolation, coordinate_mapping, align_corners,
                individual_extent, isotropic_extent, normalize,
                run_i == 0 ? std::vector<sycl::event>{out_features_fill_event}
                           : std::vector<sycl::event>{prev_gemm_event});
 
        // C is MxN
        // B is KxN
        // A is MxK
        const int m = out_channels;
        const int k = spatial_filter_size * in_channels;
        const int n = static_cast<int>(num_cols_this_run);
        const float alpha = 1;
        const float* const A = filter;
        const int lda = m;
        const float* const B = columns;
        const int ldb = k;
        const float beta = 1;
        float* C = out_features + (run_i * num_cols_per_run * out_channels);
        const int ldc = m;
 
        prev_gemm_event = GemmColumnMajorSYCL<cutlass::layout::ColumnMajor,
                                              cutlass::layout::ColumnMajor>(
                queue, m, n, k, alpha, A, lda, B, ldb, beta, C, ldc, allow_tf32,
                {fill_column_event});
    }
 
    if (out_importance) {
        // Must depend on the last chunk's GEMM: GemmColumnMajorSYCL no
        // longer blocks (see GemmSYCL.h), and this in-place scale reads/
        // writes the same out_features region that GEMM just wrote.
        MultiplyColumnsSYCL(queue, out_channels, num_out, out_features,
                            out_importance, {prev_gemm_event});
    }
}
 
}  // namespace impl
}  // namespace ml
}  // namespace open3d