// Tencent is pleased to support the open source community by making ncnn available. // // Copyright (C) 2021 THL A29 Limited, a Tencent company. All rights reserved. // // Licensed under the BSD 3-Clause License (the "License"); you may not use this file except // in compliance with the License. You may obtain a copy of the License at // // https://opensource.org/licenses/BSD-3-Clause // // Unless required by applicable law or agreed to in writing, software distributed // under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR // CONDITIONS OF ANY KIND, either express or implied. See the License for the // specific language governing permissions and limitations under the License. #include "convolution1d_riscv.h" #if __riscv_vector #include #endif // __riscv_vector #include "riscv_activation.h" #include "riscv_usability.h" #include "cpu.h" #include "layer_type.h" namespace ncnn { Convolution1D_riscv::Convolution1D_riscv() { #if __riscv_vector support_packing = true; #if __riscv_zfh support_fp16_storage = true; #endif #endif // __riscv_vector } int Convolution1D_riscv::create_pipeline(const Option& opt) { if (dynamic_weight) return 0; #if __riscv_vector && __riscv_zfh if (opt.use_fp16_storage) { return create_pipeline_fp16s(opt); } #endif #if __riscv_vector const int packn = csrr_vlenb() / 4; #endif const int num_input = weight_data_size / kernel_w / num_output; int elempack = 1; int out_elempack = 1; #if __riscv_vector if (opt.use_packing_layout) { elempack = num_input % packn == 0 ? packn : 1; out_elempack = num_output % packn == 0 ? packn : 1; } #endif // src = kw-inch-outch // dst = pb-pa-kw-inch/pa-outch/pb { Mat weight_data_r2 = weight_data.reshape(kernel_w, num_input, num_output); weight_data_packed.create(kernel_w, num_input / elempack, num_output / out_elempack, (size_t)4u * elempack * out_elempack, elempack * out_elempack); for (int q = 0; q + (out_elempack - 1) < num_output; q += out_elempack) { float* g00 = weight_data_packed.channel(q / out_elempack); for (int p = 0; p + (elempack - 1) < num_input; p += elempack) { for (int k = 0; k < kernel_w; k++) { for (int i = 0; i < elempack; i++) { for (int j = 0; j < out_elempack; j++) { const float* k00 = weight_data_r2.channel(q + j).row(p + i); g00[0] = k00[k]; g00++; } } } } } } return 0; } int Convolution1D_riscv::destroy_pipeline(const Option& /*opt*/) { return 0; } int Convolution1D_riscv::forward(const Mat& bottom_blob, Mat& top_blob, const Option& opt) const { int elembits = bottom_blob.elembits(); #if __riscv_vector && __riscv_zfh if (opt.use_fp16_storage && elembits == 16) { if (opt.use_fp16_arithmetic) return forward_fp16sa(bottom_blob, top_blob, opt); else return forward_fp16s(bottom_blob, top_blob, opt); } #endif #if __riscv_vector const int packn = csrr_vlenb() / 4; const size_t vl = vsetvl_e32m1(packn); #endif int w = bottom_blob.w; int h = bottom_blob.h; size_t elemsize = bottom_blob.elemsize; int elempack = bottom_blob.elempack; const int kernel_extent_w = dilation_w * (kernel_w - 1) + 1; Mat bottom_blob_bordered; make_padding(bottom_blob, bottom_blob_bordered, opt); if (bottom_blob_bordered.empty()) return -100; w = bottom_blob_bordered.w; h = bottom_blob_bordered.h; int out_elempack = 1; #if __riscv_vector if (opt.use_packing_layout) { out_elempack = num_output % packn == 0 ? packn : 1; } #endif size_t out_elemsize = elemsize / elempack * out_elempack; const int outw = (w - kernel_extent_w) / stride_w + 1; const int outh = num_output / out_elempack; top_blob.create(outw, outh, out_elemsize, out_elempack, opt.blob_allocator); if (top_blob.empty()) return -100; #if __riscv_vector if (elempack == packn && out_elempack == packn) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { float* outptr = top_blob.row(p); for (int j = 0; j < outw; j++) { vfloat32m1_t _sum = vfmv_v_f_f32m1(0.f, vl); if (bias_term) { _sum = vle32_v_f32m1((const float*)bias_data + p * packn, vl); } const float* kptr = weight_data_packed.channel(p); for (int q = 0; q < h; q++) { const float* sptr = bottom_blob_bordered.row(q) + j * stride_w * packn; for (int k = 0; k < kernel_w; k++) { const float* slptr = sptr + k * dilation_w * packn; for (int l = 0; l < packn; l++) { float val = *slptr++; vfloat32m1_t _w0 = vle32_v_f32m1(kptr, vl); _sum = vfmacc_vf_f32m1(_sum, val, _w0, vl); kptr += packn; } } } _sum = activation_ps(_sum, activation_type, activation_params, vl); vse32_v_f32m1(outptr, _sum, vl); outptr += packn; } } } } if (elempack == 1 && out_elempack == packn) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { float* outptr = top_blob.row(p); for (int j = 0; j < outw; j++) { vfloat32m1_t _sum = vfmv_v_f_f32m1(0.f, vl); if (bias_term) { _sum = vle32_v_f32m1((const float*)bias_data + p * packn, vl); } const float* kptr = weight_data_packed.channel(p); for (int q = 0; q < h; q++) { const float* sptr = bottom_blob_bordered.row(q) + j * stride_w; for (int k = 0; k < kernel_w; k++) { float val = sptr[0]; vfloat32m1_t _w = vle32_v_f32m1(kptr, vl); _sum = vfmacc_vf_f32m1(_sum, val, _w, vl); sptr += dilation_w; kptr += packn; } } _sum = activation_ps(_sum, activation_type, activation_params, vl); vse32_v_f32m1(outptr, _sum, vl); outptr += packn; } } } } if (elempack == packn && out_elempack == 1) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { float* outptr = top_blob.row(p); for (int j = 0; j < outw; j++) { float sum = 0.f; if (bias_term) { sum = bias_data[p]; } vfloat32m1_t _sum = vfmv_v_f_f32m1(0.f, vl); const float* kptr = weight_data_packed.channel(p); for (int q = 0; q < h; q++) { const float* sptr = bottom_blob_bordered.row(q) + j * stride_w * packn; for (int k = 0; k < kernel_w; k++) { vfloat32m1_t _val = vle32_v_f32m1(sptr, vl); vfloat32m1_t _w = vle32_v_f32m1(kptr, vl); _sum = vfmacc_vv_f32m1(_sum, _val, _w, vl); sptr += dilation_w * packn; kptr += packn; } } sum = vfmv_f_s_f32m1_f32(vfredusum_vs_f32m1_f32m1(vfloat32m1_t(), _sum, vfmv_s_f_f32m1(vfloat32m1_t(), sum, vl), vl)); sum = activation_ss(sum, activation_type, activation_params); outptr[j] = sum; } } } } #endif // __riscv_vector if (elempack == 1 && out_elempack == 1) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { float* outptr = top_blob.row(p); for (int j = 0; j < outw; j++) { float sum = 0.f; if (bias_term) { sum = bias_data[p]; } const float* kptr = (const float*)weight_data + kernel_w * h * p; for (int q = 0; q < h; q++) { const float* sptr = bottom_blob_bordered.row(q) + j * stride_w; for (int k = 0; k < kernel_w; k++) { float val = sptr[0]; float wt = kptr[0]; sum += val * wt; sptr += dilation_w; kptr += 1; } } sum = activation_ss(sum, activation_type, activation_params); outptr[j] = sum; } } } } return 0; } int Convolution1D_riscv::forward(const std::vector& bottom_blobs, std::vector& top_blobs, const Option& opt) const { const Mat& bottom_blob = bottom_blobs[0]; const Mat& _weight_data = bottom_blobs[1]; Mat& top_blob = top_blobs[0]; const int _kernel_w = _weight_data.w; const int _num_output = _weight_data.c * _weight_data.elempack; Mat weight_data_flattened; flatten(_weight_data, weight_data_flattened, opt); if (weight_data_flattened.empty()) return -100; #if NCNN_RVV if (opt.use_fp16_storage && cpu_support_riscv_v() && cpu_support_riscv_zfh() && weight_data_flattened.elembits() == 16) { Mat weight_data_flattened_fp32; cast_float16_to_float32(weight_data_flattened, weight_data_flattened_fp32, opt); weight_data_flattened = weight_data_flattened_fp32; } #endif // NCNN_RVV // weight_data_flattened as pack1 weight_data_flattened.w *= weight_data_flattened.elempack; weight_data_flattened.elemsize /= weight_data_flattened.elempack; weight_data_flattened.elempack = 1; Mat bias_data_flattened; if (bias_term) { const Mat& _bias_data = bottom_blobs[2]; flatten(_bias_data, bias_data_flattened, opt); if (bias_data_flattened.empty()) return -100; #if NCNN_RVV if (opt.use_fp16_storage && cpu_support_riscv_v() && cpu_support_riscv_zfh() && bias_data_flattened.elembits() == 16) { Mat bias_data_flattened_fp32; cast_float16_to_float32(bias_data_flattened, bias_data_flattened_fp32, opt); bias_data_flattened = bias_data_flattened_fp32; } #endif // NCNN_RVV // bias_data_flattened as pack1 bias_data_flattened.w *= bias_data_flattened.elempack; bias_data_flattened.elemsize /= bias_data_flattened.elempack; bias_data_flattened.elempack = 1; } ncnn::Layer* op = ncnn::create_layer(ncnn::LayerType::Convolution1D); ncnn::ParamDict pd; pd.set(0, _num_output); pd.set(1, _kernel_w); pd.set(2, dilation_w); pd.set(3, stride_w); pd.set(4, pad_left); pd.set(15, pad_right); pd.set(18, pad_value); pd.set(5, bias_term); pd.set(6, weight_data_flattened.w); pd.set(9, activation_type); pd.set(10, activation_params); op->load_param(pd); ncnn::Mat weights[2]; weights[0] = weight_data_flattened; weights[1] = bias_data_flattened; op->load_model(ncnn::ModelBinFromMatArray(weights)); op->create_pipeline(opt); op->forward(bottom_blob, top_blob, opt); op->destroy_pipeline(opt); delete op; return 0; } #if __riscv_vector && __riscv_zfh int Convolution1D_riscv::create_pipeline_fp16s(const Option& opt) { const int packn = csrr_vlenb() / 2; const int num_input = weight_data_size / kernel_w / num_output; int elempack = 1; int out_elempack = 1; if (opt.use_packing_layout) { elempack = num_input % packn == 0 ? packn : 1; out_elempack = num_output % packn == 0 ? packn : 1; } // src = kw-inch-outch // dst = pb-pa-kw-inch/pa-outch/pb { Mat weight_data_r2 = weight_data.reshape(kernel_w, num_input, num_output); weight_data_fp16.create(kernel_w, num_input / elempack, num_output / out_elempack, (size_t)2u * elempack * out_elempack, elempack * out_elempack); for (int q = 0; q + (out_elempack - 1) < num_output; q += out_elempack) { __fp16* g00 = weight_data_fp16.channel(q / out_elempack); for (int p = 0; p + (elempack - 1) < num_input; p += elempack) { for (int k = 0; k < kernel_w; k++) { for (int i = 0; i < elempack; i++) { for (int j = 0; j < out_elempack; j++) { const float* k00 = weight_data_r2.channel(q + j).row(p + i); g00[0] = (__fp16)k00[k]; g00++; } } } } } } ncnn::cast_float32_to_float16(bias_data, bias_data_fp16, opt); return 0; } int Convolution1D_riscv::forward_fp16s(const Mat& bottom_blob, Mat& top_blob, const Option& opt) const { const int packn = csrr_vlenb() / 2; const size_t vl = vsetvl_e16m1(packn); int w = bottom_blob.w; int h = bottom_blob.h; size_t elemsize = bottom_blob.elemsize; int elempack = bottom_blob.elempack; const int kernel_extent_w = dilation_w * (kernel_w - 1) + 1; Mat bottom_blob_bordered; make_padding(bottom_blob, bottom_blob_bordered, opt); if (bottom_blob_bordered.empty()) return -100; w = bottom_blob_bordered.w; h = bottom_blob_bordered.h; int out_elempack = (opt.use_packing_layout && num_output % packn == 0) ? packn : 1; size_t out_elemsize = elemsize / elempack * out_elempack; const int outw = (w - kernel_extent_w) / stride_w + 1; const int outh = num_output / out_elempack; top_blob.create(outw, outh, out_elemsize, out_elempack, opt.blob_allocator); if (top_blob.empty()) return -100; if (elempack == packn && out_elempack == packn) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { vfloat32m2_t _sum = vfmv_v_f_f32m2(0.f, vl); if (bias_term) { _sum = vle32_v_f32m2((const float*)bias_data + p * packn, vl); } const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row(q) + j * stride_w * packn; for (int k = 0; k < kernel_w; k++) { const __fp16* slptr = sptr + k * dilation_w * packn; for (int l = 0; l < packn; l++) { float val = (float)*slptr++; vfloat16m1_t _w0 = vle16_v_f16m1(kptr, vl); _sum = vfwmacc_vf_f32m2(_sum, val, _w0, vl); kptr += packn; } } } _sum = activation_ps(_sum, activation_type, activation_params, vl); vse16_v_f16m1(outptr, vfncvt_f_f_w_f16m1(_sum, vl), vl); outptr += packn; } } } } if (elempack == 1 && out_elempack == packn) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { vfloat32m2_t _sum = vfmv_v_f_f32m2(0.f, vl); if (bias_term) { _sum = vle32_v_f32m2((const float*)bias_data + p * packn, vl); } const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row(q) + j * stride_w; for (int k = 0; k < kernel_w; k++) { float val = (float)sptr[0]; vfloat16m1_t _w = vle16_v_f16m1(kptr, vl); _sum = vfwmacc_vf_f32m2(_sum, val, _w, vl); sptr += dilation_w; kptr += packn; } } _sum = activation_ps(_sum, activation_type, activation_params, vl); vse16_v_f16m1(outptr, vfncvt_f_f_w_f16m1(_sum, vl), vl); outptr += packn; } } } } if (elempack == packn && out_elempack == 1) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { float sum = 0.f; if (bias_term) { sum = bias_data[p]; } vfloat32m2_t _sum = vfmv_v_f_f32m2(0.f, vl); const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row(q) + j * stride_w * packn; for (int k = 0; k < kernel_w; k++) { vfloat16m1_t _val = vle16_v_f16m1(sptr, vl); vfloat16m1_t _w = vle16_v_f16m1(kptr, vl); _sum = vfwmacc_vv_f32m2(_sum, _val, _w, vl); sptr += dilation_w * packn; kptr += packn; } } #if C906 // TODO std::vector ss(packn); vse32_v_f32m2((float*)ss.data(), _sum, vl); for (int i = 0; i < packn; i++) { sum += ss[i]; } #else sum = vfmv_f_s_f32m1_f32(vfredusum_vs_f32m2_f32m1(vfloat32m1_t(), _sum, vfmv_s_f_f32m1(vfloat32m1_t(), sum, vl), vl)); #endif sum = activation_ss(sum, activation_type, activation_params); outptr[j] = (__fp16)sum; } } } } if (elempack == 1 && out_elempack == 1) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { float sum = 0.f; if (bias_term) { sum = bias_data[p]; } const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row<__fp16>(q) + j * stride_w; for (int k = 0; k < kernel_w; k++) { float val = (float)sptr[0]; float w = (float)kptr[0]; sum += val * w; sptr += dilation_w; kptr += 1; } } sum = activation_ss(sum, activation_type, activation_params); outptr[j] = (__fp16)sum; } } } } return 0; } int Convolution1D_riscv::forward_fp16sa(const Mat& bottom_blob, Mat& top_blob, const Option& opt) const { const int packn = csrr_vlenb() / 2; const size_t vl = vsetvl_e16m1(packn); int w = bottom_blob.w; int h = bottom_blob.h; size_t elemsize = bottom_blob.elemsize; int elempack = bottom_blob.elempack; const int kernel_extent_w = dilation_w * (kernel_w - 1) + 1; Mat bottom_blob_bordered; make_padding(bottom_blob, bottom_blob_bordered, opt); if (bottom_blob_bordered.empty()) return -100; w = bottom_blob_bordered.w; h = bottom_blob_bordered.h; int out_elempack = (opt.use_packing_layout && num_output % packn == 0) ? packn : 1; size_t out_elemsize = elemsize / elempack * out_elempack; const int outw = (w - kernel_extent_w) / stride_w + 1; const int outh = num_output / out_elempack; top_blob.create(outw, outh, out_elemsize, out_elempack, opt.blob_allocator); if (top_blob.empty()) return -100; if (elempack == packn && out_elempack == packn) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { vfloat16m1_t _sum = vfmv_v_f_f16m1(0.f, vl); if (bias_term) { _sum = vle16_v_f16m1((const __fp16*)bias_data_fp16 + p * packn, vl); } const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row(q) + j * stride_w * packn; for (int k = 0; k < kernel_w; k++) { const __fp16* slptr = sptr + k * dilation_w * packn; for (int l = 0; l < packn; l++) { __fp16 val = *slptr++; vfloat16m1_t _w0 = vle16_v_f16m1(kptr, vl); _sum = vfmacc_vf_f16m1(_sum, val, _w0, vl); kptr += packn; } } } _sum = activation_ps(_sum, activation_type, activation_params, vl); vse16_v_f16m1(outptr, _sum, vl); outptr += packn; } } } } if (elempack == 1 && out_elempack == packn) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { vfloat16m1_t _sum = vfmv_v_f_f16m1(0.f, vl); if (bias_term) { _sum = vle16_v_f16m1((const __fp16*)bias_data_fp16 + p * packn, vl); } const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row(q) + j * stride_w; for (int k = 0; k < kernel_w; k++) { __fp16 val = sptr[0]; vfloat16m1_t _w = vle16_v_f16m1(kptr, vl); _sum = vfmacc_vf_f16m1(_sum, val, _w, vl); sptr += dilation_w; kptr += packn; } } _sum = activation_ps(_sum, activation_type, activation_params, vl); vse16_v_f16m1(outptr, _sum, vl); outptr += packn; } } } } if (elempack == packn && out_elempack == 1) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { __fp16 sum = 0.f; if (bias_term) { sum = ((const __fp16*)bias_data_fp16)[p]; } vfloat16m1_t _sum = vfmv_v_f_f16m1(0.f, vl); const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row(q) + j * stride_w * packn; for (int k = 0; k < kernel_w; k++) { vfloat16m1_t _val = vle16_v_f16m1(sptr, vl); vfloat16m1_t _w = vle16_v_f16m1(kptr, vl); _sum = vfmacc_vv_f16m1(_sum, _val, _w, vl); sptr += dilation_w * packn; kptr += packn; } } sum = vfmv_f_s_f16m1_f16(vfredusum_vs_f16m1_f16m1(vfloat16m1_t(), _sum, vfmv_s_f_f16m1(vfloat16m1_t(), sum, vl), vl)); sum = activation_ss(sum, activation_type, activation_params); outptr[j] = sum; } } } } if (elempack == 1 && out_elempack == 1) { { #pragma omp parallel for num_threads(opt.num_threads) for (int p = 0; p < outh; p++) { __fp16* outptr = top_blob.row<__fp16>(p); for (int j = 0; j < outw; j++) { float sum = 0.f; if (bias_term) { sum = bias_data[p]; } const __fp16* kptr = weight_data_fp16.channel(p); for (int q = 0; q < h; q++) { const __fp16* sptr = bottom_blob_bordered.row<__fp16>(q) + j * stride_w; for (int k = 0; k < kernel_w; k++) { float val = (float)sptr[0]; float w = (float)kptr[0]; sum += val * w; sptr += dilation_w; kptr += 1; } } sum = activation_ss(sum, activation_type, activation_params); outptr[j] = (__fp16)sum; } } } } return 0; } #endif // __riscv_vector && __riscv_zfh } // namespace ncnn