Commit 2c8e3006 authored by xgqdut2016's avatar xgqdut2016
Browse files

issue/130: add omp cpu

parent 65df17f7
...@@ -42,31 +42,33 @@ void calculate( ...@@ -42,31 +42,33 @@ void calculate(
if (info.is_transed) { if (info.is_transed) {
std::swap(a, b); std::swap(a, b);
} }
#pragma omp parallel for
for (size_t i = 0; i < info.batch; ++i) { for(ptrdiff_t index = 0; index < ptrdiff_t(info.batch * info.m * info.n); ++index){
for (size_t m_ = 0; m_ < info.m; ++m_) { size_t ind = index;
for (size_t n_ = 0; n_ < info.n; ++n_) { size_t n_ = ind % info.n;
auto c_ = reinterpret_cast<Tdata *>(c) + i * info.c_matrix.stride + m_ * info.c_matrix.row_stride + n_ * info.c_matrix.col_stride; ind /= info.n;
float sum = 0; size_t m_ = ind % info.m;
for (size_t k_ = 0; k_ < info.k; ++k_) { ind /= info.m;
auto a_ = reinterpret_cast<const Tdata *>(a) + i * info.a_matrix.stride + m_ * info.a_matrix.row_stride + k_ * info.a_matrix.col_stride; size_t i = ind;
auto b_ = reinterpret_cast<const Tdata *>(b) + i * info.b_matrix.stride + n_ * info.b_matrix.col_stride + k_ * info.b_matrix.row_stride; auto c_ = reinterpret_cast<Tdata *>(c) + i * info.c_matrix.stride + m_ * info.c_matrix.row_stride + n_ * info.c_matrix.col_stride;
if constexpr (std::is_same<Tdata, fp16_t>::value) { float sum = 0;
sum += utils::cast<float>(*a_) * utils::cast<float>(*b_); for (size_t k_ = 0; k_ < info.k; ++k_) {
} else { auto a_ = reinterpret_cast<const Tdata *>(a) + i * info.a_matrix.stride + m_ * info.a_matrix.row_stride + k_ * info.a_matrix.col_stride;
sum += *a_ * (*b_); auto b_ = reinterpret_cast<const Tdata *>(b) + i * info.b_matrix.stride + n_ * info.b_matrix.col_stride + k_ * info.b_matrix.row_stride;
} if constexpr (std::is_same<Tdata, fp16_t>::value) {
} sum += utils::cast<float>(*a_) * utils::cast<float>(*b_);
if constexpr (std::is_same<Tdata, fp16_t>::value) { } else {
if (beta == 0) { sum += *a_ * (*b_);
*c_ = utils::cast<fp16_t>(alpha * sum); }
} else { }
*c_ = utils::cast<fp16_t>(beta * utils::cast<float>(*c_) + alpha * sum); if constexpr (std::is_same<Tdata, fp16_t>::value) {
} if (beta == 0) {
} else { *c_ = utils::cast<fp16_t>(alpha * sum);
*c_ = beta * (*c_) + alpha * sum; } else {
} *c_ = utils::cast<fp16_t>(beta * utils::cast<float>(*c_) + alpha * sum);
} }
} else {
*c_ = beta * (*c_) + alpha * sum;
} }
} }
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment