Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion core/inc/SOFIE/ROperator.hxx
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,8 @@ enum class OperatorKind {
UNARY_ABS=23,
CLIP=24,
NOT=25,
POOL=26
POOL=26,
SELU=27
};

inline const char* toString(OperatorKind kind) {
Expand Down
53 changes: 49 additions & 4 deletions core/inc/SOFIE/ROperator_Selu.hxx
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,6 @@
#include "SOFIE/ROperator.hxx"
#include "SOFIE/RModel.hxx"

#include <sstream>

namespace SOFIE{

template <typename T>
Expand All @@ -15,16 +13,20 @@ class ROperator_Selu final : public ROperator

private:

float falpha = 1.67326319217681884765625f;
float fgamma = 1.05070102214813232421875f;
std::string fNX;
std::string fNY;
std::vector<Dim> fShape;

public:
ROperator_Selu(){}
ROperator_Selu(std::string nameX, std::string nameY):
ROperator_Selu(float alpha, float gamma, std::string nameX, std::string nameY):
falpha(alpha), fgamma(gamma),
fNX(UTILITY::Clean_name(nameX)), fNY(UTILITY::Clean_name(nameY)){
fInputTensorNames = { fNX };
fOutputTensorNames = { fNY };
fKind = OperatorKind::SELU;
}

std::vector<ETensorType> TypeInference(std::vector<ETensorType> input) override {
Expand Down Expand Up @@ -52,13 +54,56 @@ public:
}
std::stringstream out;
std::string length = ConvertDimShapeToLength(fShape);
out << "\t" << "constexpr float " << OpName << "_alpha = " << std::setprecision(std::numeric_limits<float>::max_digits10) << falpha << ";\n";
out << "\t" << "constexpr float " << OpName << "_gamma = " << std::setprecision(std::numeric_limits<float>::max_digits10) << fgamma << ";\n";
out << "\t" << "for (int id = 0; id < " << length << " ; id++){\n";
out << "\t\t" << "tensor_" << fNY << "[id] = 1.0507009873554804934193349852946 * (std::max(float(0.0), tensor_" << fNX << "[id]) + std::min(0.0, 1.6732632423543772848170429916717 * (std::exp(" << "tensor_" << fNX << "[id]" <<")-1)));\n";
out << "\t\t" << "tensor_" << fNY << "[id] = " << OpName << "_gamma * (std::max(0.0f, tensor_" << fNX << "[id]) + std::min(0.0f, " << OpName << "_alpha * (std::exp(" << "tensor_" << fNX << "[id]" <<")-1)));\n";
out << "\t}\n";
return out.str();
}

std::vector<std::string> GetStdLibs() override { return { std::string("cmath") };}

std::string Generate_GPU_Kernel_ALPAKA(std::string /*opName*/) override {
std::string op;
op = "\n//---- SELU_KERNEL_ALPAKA//\n";
op += "struct SeluKernel {\n";
op += SP + "template<typename TAcc, typename T>\n";
op += SP + "ALPAKA_FN_ACC void operator()(TAcc const& acc, T const* __restrict__ data, T* __restrict__ out, std::size_t numElements, T alpha, T gamma) const {\n";
op += SP + SP + "const auto idx = alpaka::getIdx<alpaka::Grid, alpaka::Threads>(acc)[0];\n";
op += SP + SP + "if (idx < numElements) {\n";
op += SP + SP + SP + "T x = data[idx];\n";
op += SP + SP + SP + "T inner = alpha * (exp(x) - T(1));\n";
op += SP + SP + SP + "out[idx] = gamma * ((x > T(0) ? x : T(0)) + (inner < T(0) ? inner : T(0)));\n";
op += SP + SP + "}\n";
op += SP + "}\n";
op += "};\n";
return op;
}

std::string Generate_GPU_Kernel_Definitions_ALPAKA(std::string /*opName*/) override {
return SP + "SeluKernel seluKernel;\n";
}

std::string Generate_GPU_ALPAKA(std::string OpName) override {
OpName = "op_" + OpName;
if (fShape.empty()) {
throw std::runtime_error("SOFIE Selu called to Generate_GPU_ALPAKA without being initialized");
}
std::stringstream out;
std::string length = ConvertDimShapeToLength(fShape);
out << "\n//------ SELU_GPU_ALPAKA\n";
out << SP << "auto const elementsPerThread_" << fNX << " = Vec::all(static_cast<Idx>(1));\n";
out << SP << "auto const elementsPerGrid_" << fNX << " = Vec::all(Idx{" << length << "});\n";
out << SP << "auto const workDiv_" << fNX << " = sofie_workdiv(elementsPerGrid_" << fNX << ");\n";
out << SP << "auto task_" << OpName << " = alpaka::createTaskKernel<Acc>(workDiv_" << fNX
<< ", seluKernel, alpaka::getPtrNative(deviceBuf_" << fNX
<< "), alpaka::getPtrNative(deviceBuf_" << fNY << "), static_cast<Idx>(" << length << "), static_cast<float>("
<< std::setprecision(std::numeric_limits<float>::max_digits10) << falpha << "), static_cast<float>("
<< std::setprecision(std::numeric_limits<float>::max_digits10) << fgamma << "));\n";
out << SP << "alpaka::enqueue(queue, task_" << OpName << ");\n";
return out.str();
}
};

}//SOFIE
Expand Down
3 changes: 2 additions & 1 deletion core/src/RModel_ALPAKA.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -576,7 +576,8 @@ void RModel::GenerateSessionCode_GPU_ALPAKA() {
SOFIE::OperatorKind::UNARY_SIN,
SOFIE::OperatorKind::UNARY_COS,
SOFIE::OperatorKind::UNARY_ABS,
SOFIE::OperatorKind::NOT
SOFIE::OperatorKind::NOT,
SOFIE::OperatorKind::SELU
};

bool OpNeedsBlas = false;
Expand Down
15 changes: 14 additions & 1 deletion parsers/src/ParseSelu.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,22 @@ ParserFuncSignature ParseSelu = [](RModelParser_ONNX &parser, const onnx::NodePr

std::unique_ptr<ROperator> op;

float attr_alpha = 1.67326319217681884765625f;
float attr_gamma = 1.05070102214813232421875f;

for (int_t i = 0; i < nodeproto.attribute_size(); i++) {
std::string attribute_name = nodeproto.attribute(i).name();
if (attribute_name == "alpha")
attr_alpha = nodeproto.attribute(i).f();
else if (attribute_name == "gamma")
attr_gamma = nodeproto.attribute(i).f();
}

std::string output_name = nodeproto.output(0);
switch (input_type) {
case ETensorType::FLOAT: op.reset(new ROperator_Selu<float>(input_name, output_name)); break;
case ETensorType::FLOAT:
op.reset(new ROperator_Selu<float>(attr_alpha, attr_gamma, input_name, output_name));
break;
default:
throw std::runtime_error("TMVA::SOFIE - Unsupported - Operator Selu does not yet support input type " +
std::to_string(static_cast<int>(input_type)));
Expand Down
35 changes: 35 additions & 0 deletions test/alpaka/TestAlpakaElementwiseUnary.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,8 @@
#include "Softplus_FromONNX_GPU_ALPAKA.hxx"
#include "Elu_FromONNX_GPU_ALPAKA.hxx"
#include "input_models/references/Elu.ref.hxx"
#include "SeluNonDefaultCoeffs_FromONNX_GPU_ALPAKA.hxx"
#include "input_models/references/SeluNonDefaultCoeffs.ref.hxx"

TEST_F(SofieAlpakaTest, Sin)
{
Expand Down Expand Up @@ -357,3 +359,36 @@ TEST_F(SofieAlpakaTest, Elu)
}
}

TEST_F(SofieAlpakaTest, SeluNonDefaultCoeffs)
{
constexpr float TOLERANCE = DEFAULT_TOLERANCE;

std::vector<float> input({1.0f, -2.0f, 3.0f, 0.5f, -1.0f, 2.0f});

auto input_h = alpaka::allocBuf<float, Idx>(host, Ext1D::all(Idx{input.size()}));
float* input_ptr = reinterpret_cast<float*>(alpaka::getPtrNative(input_h));
for (Idx i = 0; i < input.size(); ++i) input_ptr[i] = input[i];

auto input_d = alpaka::allocBuf<float, Idx>(device, Ext1D::all(Idx{input.size()}));
alpaka::memcpy(queue, input_d, input_h);
alpaka::wait(queue);

constexpr size_t nOut = sizeof(SeluNonDefaultCoeffs_ExpectedOutput::outputs) / sizeof(float);
auto result_h = alpaka::allocBuf<float, Idx>(host, Ext1D::all(Idx{nOut}));

{
SOFIE_SeluNonDefaultCoeffs::Session<alpaka::TagGpuCudaRt> session;
auto result = session.infer(input_d);
Comment thread
sanjibansg marked this conversation as resolved.
alpaka::wait(queue);
cudaDeviceSynchronize();
alpaka::memcpy(queue, result_h, result);
alpaka::wait(queue);
}

float* res_ptr = reinterpret_cast<float*>(alpaka::getPtrNative(result_h));
float* correct = SeluNonDefaultCoeffs_ExpectedOutput::outputs;
for (size_t i = 0; i < nOut; ++i) {
EXPECT_LE(std::abs(res_ptr[i] - correct[i]), TOLERANCE) << "i=" << i;
}
}

Binary file added test/input_models/SeluNonDefaultCoeffs.onnx
Binary file not shown.
4 changes: 4 additions & 0 deletions test/input_models/references/SeluNonDefaultCoeffs.ref.hxx
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
#pragma once
namespace SeluNonDefaultCoeffs_ExpectedOutput {
float outputs[] = {3.00000000f, -5.18798828f, 9.00000000f, 1.50000000f, -3.79272366f, 6.00000000f};
} // namespace SeluNonDefaultCoeffs_ExpectedOutput