#pragma once
#include "src/common/algo_base.h"
#include "src/common/metahelper.h"
#include "src/common/utils.h"
#include "src/rocm/convolution/helper.h"
#include <unordered_map>
namespace megdnn {
namespace rocm {
class ConvolutionBackwardDataImpl::AlgoBase : public Algorithm {
protected:
~AlgoBase() = default;
public:
enum class AlgoType : uint32_t { ROCM_MIOPEN, ROCM_MATMUL, ROCM_CHANWISE };
using Mapper = std::unordered_map<AlgorithmDesc, AlgoBase*>;
AlgoBase() : Algorithm() { m_handle_type = Handle::HandleType::ROCM; }
struct SizeArgs {
HandleImpl* handle;
CanonizedFilterMeta filter_meta;
const TensorLayout *diff_layout, *grad_layout;
ConvolutionBackwardDataImpl* opr;
std::string to_string() const;
convolution::MIOpenCacheKey to_miopen_algo_cache_key() const;
void init_desc(convolution::MIOpenBwdDataDescs& desc) const {
desc.set(filter_meta, *diff_layout, *grad_layout, opr->param());
}
SizeArgs(
ConvolutionBackwardDataImpl* opr, const TensorLayout& filter,
const TensorLayout& diff, const TensorLayout& grad);
SizeArgs(
ConvolutionBackwardDataImpl* opr, const CanonizedFilterMeta& filter,
const TensorLayout& diff, const TensorLayout& grad);
convolution::ForwardSizeArgs as_fwd_args() const {
return {handle, grad_layout, filter_meta, diff_layout};
}
};
struct ExecArgs : public SizeArgs {
const TensorND *filter_tensor, *diff_tensor, *grad_tensor;
Workspace workspace;
ExecArgs(
ConvolutionBackwardDataImpl* opr, _megdnn_tensor_in filter,
_megdnn_tensor_in diff, _megdnn_tensor_out grad,
_megdnn_workspace workspace);
};
virtual bool is_available(const SizeArgs& args) const = 0;
virtual size_t get_workspace_in_bytes(const SizeArgs& args) const = 0;
virtual void exec(const ExecArgs& args) const = 0;
bool is_available_wk(const SizeArgs& args, size_t limit) {
return is_available(args) && get_workspace_in_bytes(args) <= limit;
}
bool is_available_attribute(
const SizeArgs& args,
const AlgoAttribute& positive_attr = AlgoAttribute::REPRODUCIBLE,
const AlgoAttribute& negative_attr = AlgoAttribute::DEFAULT,
size_t limit = std::numeric_limits<size_t>::max()) {
return contain_attribute_all(positive_attr) &&
!contain_attribute_any(negative_attr) && is_available_wk(args, limit);
}
AlgoBase& check_workspace(const SizeArgs& args, const Workspace& workspace) {
auto req = get_workspace_in_bytes(args);
megdnn_assert(
req <= workspace.size,
"conv bwd data algo %s: "
"required workspace %zu bytes, got %zu",
name(), req, workspace.size);
return *this;
}
virtual bool is_miopen() const { return false; }
};
class ConvolutionBackwardDataImpl::AlgoMIOpen final : public AlgoBase {
AlgoAttribute m_algo_attribute;
const char* m_name;
miopenConvBwdDataAlgorithm_t find_best_algo(const ExecArgs& args);
public:
AlgoMIOpen() = delete;
AlgoMIOpen(AlgoAttribute attr) : m_algo_attribute(attr) {}
bool is_available(const SizeArgs& args) const override;
size_t get_workspace_in_bytes(const SizeArgs& args) const override;
void exec(const ExecArgs& args) const override;
AlgoAttribute attribute() const override { return m_algo_attribute; }
const char* name() const override { return "MIOpenConvolutionBackwardData"; }
bool is_miopen() const override { return true; }
MEGDNN_DECL_ALGO_TYPE(ROCM_MIOPEN)
std::string param() const override {
std::string ret;
serialize_write_pod(m_algo_attribute, ret);
return ret;
}
static convolution::MIOpenCache<SizeArgs, miopenConvBwdDataAlgorithm_t>
sm_miopen_algo_cache;
static convolution::MIOpenCache<SizeArgs, size_t> sm_miopen_ws_cache;
};
class ConvolutionBackwardDataImpl::AlgoMatmul final : public AlgoBase {
template <typename T>
static void exec_internal(const ExecArgs& args);
public:
bool is_available(const SizeArgs& args) const override;
size_t get_workspace_in_bytes(const SizeArgs& args) const override;
void exec(const ExecArgs& args) const override;
const char* name() const override { return "MATMUL"; }
MEGDNN_DECL_ALGO_TYPE(ROCM_MATMUL)
AlgoAttribute attribute() const override { return AlgoAttribute::REPRODUCIBLE; }
};
class ConvolutionBackwardDataImpl::AlgoChanwise final : public AlgoBase {
public:
bool is_available(const SizeArgs& args) const override;
size_t get_workspace_in_bytes(const SizeArgs& args) const override;
void exec(const ExecArgs& args) const override;
const char* name() const override { return "CHANNEL_WISE"; }
MEGDNN_DECL_ALGO_TYPE(ROCM_CHANWISE)
AlgoAttribute attribute() const override { return AlgoAttribute::REPRODUCIBLE; }
};
class ConvolutionBackwardDataImpl::AlgoPack : NonCopyableObj {
void fill_miopen_algos();
AlgoBase::Mapper m_all_algos_map;
public:
AlgoPack();
AlgoMIOpen miopen{AlgoAttribute::REPRODUCIBLE};
AlgoMatmul matmul;
AlgoChanwise chanwise;
std::vector<AlgoBase*>
all_algos, miopen_algos, non_miopen_algos;
const AlgoBase::Mapper& all_algos_map() const { return m_all_algos_map; }
};
} }