#include "gpu/intel/eltwise/ref.hpp"
namespace dnnl {
namespace impl {
namespace gpu {
namespace intel {
namespace eltwise {
static status_t init_conf_common(
conf_t &conf, const pd_t *pd, impl::engine_t *engine) {
alg_kind_t alg = pd->desc()->alg_kind;
const bool is_forward = pd->is_fwd();
const auto &src_md = pd->use_dst() ? pd->dst_md() : pd->src_md();
const memory_desc_wrapper src_d(src_md);
const memory_desc_wrapper diff_data_d(
is_forward ? &glob_zero_md : pd->diff_src_md());
conf.data_md_info = memory_desc_info_t::create(src_d);
if (!is_forward)
conf.data_diff_md_info = memory_desc_info_t::create(diff_data_d);
conf.require_stateless_addressing = pd->has_large_buffers();
const int ndims = src_d.ndims();
conf.ndims = ndims;
conf.data_type = src_d.data_type();
conf.alg = alg;
conf.is_forward = is_forward;
conf.attr_info = attr_info_t::create(pd->attr());
const auto &dims = src_d.padded_dims();
conf.with_zero_padding = src_d.nelems(false) != src_d.nelems(true);
int max_ndims = 6;
auto *intel_engine = utils::downcast<intel::engine_t *>(engine);
conf.dispatch = intel_engine->create_dispatch(
is_forward ? src_d.md_ : diff_data_d.md_);
for (int i = 0; i < max_ndims; ++i) {
if (i < ndims)
conf.dispatch.define_dim(utils::format("D%d", i), i, dims[i]);
else
conf.dispatch.define_dim(utils::format("D%d", i), 1);
}
conf.dispatch.generate(false);
return status::success;
}
static status_t init_kernel_ctx_common(compute::kernel_ctx_t &kernel_ctx,
const conf_t &conf, const post_ops_t &post_ops,
const dropout_t &dropout, const memory_desc_t *dst_md) {
kernel_ctx.set_data_type(conf.data_type);
kernel_ctx.require_stateless_addressing(conf.require_stateless_addressing);
kernel_ctx.define_int("ELTWISE_ALG", conf.alg);
kernel_ctx.define_int("NDIMS", conf.ndims);
kernel_ctx.define_int("GWS0", conf.dispatch.nd_range().global_range()[0]);
kernel_ctx.define_int("GWS1", conf.dispatch.nd_range().global_range()[1]);
kernel_ctx.define_int("GWS2", conf.dispatch.nd_range().global_range()[2]);
kernel_ctx.define_int("USE_CUSTOM_GWS_GET_ID", 1);
kernel_ctx.define_int("WITH_DROPOUT", !dropout.has_default_values());
kernel_ctx.define_int("USE_HOST_SCALARS", dropout.use_host_scalars_);
kernel_ctx.define_int("USE_OFFSET", dropout.use_offset_);
kernel_ctx.define_int("HAS_OUTPUT_MASK", dropout.has_output_mask());
bool with_binary_post_ops
= post_ops.find(primitive_kind_t::dnnl_binary) != -1;
kernel_ctx.define_int(
"USE_GWS_GET", conf.with_zero_padding || with_binary_post_ops);
def_data_type(kernel_ctx, conf.data_md_info.data_type, "SRC", false);
def_memory_desc_info(kernel_ctx, conf.data_md_info, "DST", false);
if (!conf.is_forward) {
def_memory_desc_info(kernel_ctx, conf.data_diff_md_info, "DIFF", false);
} else {
kernel_ctx.define_int("IS_FWD", 1);
}
CHECK(def_attr_info(kernel_ctx, conf.attr_info, post_ops, *dst_md));
def_dispatch(kernel_ctx, conf.dispatch);
return status::success;
}
status_t ref_fwd_t::pd_t::init_conf(impl::engine_t *engine) {
return init_conf_common(conf, this, engine);
}
status_t ref_fwd_t::pd_t::init_kernel_ctx(
compute::kernel_ctx_t &kernel_ctx) const {
return init_kernel_ctx_common(kernel_ctx, conf, attr()->post_ops_,
attr()->dropout_, invariant_dst_md());
}
status_t ref_fwd_t::execute_forward_dense(const exec_ctx_t &ctx) const {
auto &src = CTX_IN_STORAGE(DNNL_ARG_SRC);
auto &dst = CTX_OUT_STORAGE(DNNL_ARG_DST);
const float alpha = pd()->desc()->alpha;
const float beta = pd()->desc()->beta;
const auto &conf = pd()->conf;
compute::kernel_arg_list_t arg_list;
arg_list.set(0, src);
arg_list.set(1, dst);
arg_list.set(2, alpha);
arg_list.set(3, beta);
const bool with_dropout = !pd()->attr()->dropout_.has_default_values();
int arg_idx = 5;
if (with_dropout) {
const bool use_host_scalars = pd()->attr()->dropout_.use_host_scalars_;
const bool use_offset = pd()->attr()->dropout_.use_offset_;
const auto &dropout_p
= CTX_IN_STORAGE(DNNL_ARG_ATTR_DROPOUT_PROBABILITY);
const auto &dropout_seed = CTX_IN_STORAGE(DNNL_ARG_ATTR_DROPOUT_SEED);
const auto &dropout_offset
= CTX_IN_STORAGE(DNNL_ARG_ATTR_DROPOUT_OFFSET);
arg_list.set(arg_idx++, CTX_OUT_STORAGE(DNNL_ARG_ATTR_DROPOUT_MASK));
if (use_host_scalars) {
int64_t scalar_seed = 0;
int64_t scalar_offset = 0;
float scalar_prob = 0.f;
const host_scalar_memory_storage_t *seed_storage
= utils::downcast<const host_scalar_memory_storage_t *>(
&dropout_seed);
CHECK(seed_storage->get_scalar_value(
&scalar_seed, sizeof(scalar_seed)));
if (use_offset) {
const host_scalar_memory_storage_t *offset_storage
= utils::downcast<const host_scalar_memory_storage_t *>(
&dropout_offset);
CHECK(offset_storage->get_scalar_value(
&scalar_offset, sizeof(scalar_offset)));
}
const host_scalar_memory_storage_t *prob_storage
= utils::downcast<const host_scalar_memory_storage_t *>(
&dropout_p);
CHECK(prob_storage->get_scalar_value(
&scalar_prob, sizeof(scalar_prob)));
arg_list.set(arg_idx++, scalar_seed);
arg_list.set(arg_idx++, scalar_offset);
arg_list.set(arg_idx++, scalar_prob);
} else {
arg_list.set(arg_idx++, dropout_seed);
arg_list.set(arg_idx++, dropout_offset);
arg_list.set(arg_idx++, dropout_p);
}
}
append_post_ops_to_arg_list(
ctx, arg_list, arg_idx, pd()->attr()->post_ops_, *pd()->dst_md());
auto nd_range = conf.dispatch.nd_range();
return large_parallel_for(ctx, nd_range, kernel_, arg_list, 4);
}
status_t ref_bwd_t::pd_t::init_conf(impl::engine_t *engine) {
return init_conf_common(conf, this, engine);
}
status_t ref_bwd_t::pd_t::init_kernel_ctx(
compute::kernel_ctx_t &kernel_ctx) const {
return init_kernel_ctx_common(kernel_ctx, conf, attr()->post_ops_,
attr()->dropout_, invariant_dst_md());
}
status_t ref_bwd_t::execute_backward_dense(const exec_ctx_t &ctx) const {
auto &src = pd()->use_dst() ? CTX_IN_STORAGE(DNNL_ARG_DST)
: CTX_IN_STORAGE(DNNL_ARG_SRC);
auto &diff_dst = CTX_IN_STORAGE(DNNL_ARG_DIFF_DST);
auto &diff_src = CTX_OUT_STORAGE(DNNL_ARG_DIFF_SRC);
const float alpha = pd()->desc()->alpha;
const float beta = pd()->desc()->beta;
const auto &conf = pd()->conf;
compute::kernel_arg_list_t arg_list;
arg_list.set(0, src);
arg_list.set(1, diff_src);
arg_list.set(2, diff_dst);
arg_list.set(3, alpha);
arg_list.set(4, beta);
auto nd_range = conf.dispatch.nd_range();
return large_parallel_for(ctx, nd_range, kernel_, arg_list, 5);
}
} } } } }