Files
derek.holloway 7502bf64a4
CodeQL / Analyze (actions) (push) Canceled after 0s
CodeQL / Analyze (python) (push) Canceled after 0s
pre-commit / pre-commit (push) Canceled after 0s
Multi-Arch CI / setup (push) Canceled after 0s
Publish build_manylinux_x86_64 images / publish_build_manylinux_x86_64 (push) Canceled after 0s
Setup (Multi-Arch) / setup (push) Canceled after 0s
Multi-Arch CI / Linux::${{ fromJSON(needs.setup.outputs.linux_build_config || '{}').build_variant_label || 'skip' }} (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Publish no_rocm_image_ubi10 image / publish_no_rocm_image_ubi10 (push) Canceled after 0s
Multi-Arch CI / Windows::${{ fromJSON(needs.setup.outputs.windows_build_config || '{}').build_variant_label || 'skip' }} (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Multi-Arch CI / Manifest Diff (push) Canceled after 0s
TheRock Manifest Diff Report / Generate Manifest Diff Report (push) Canceled after 0s
Multi-Arch CI / CI Summary (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04 (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04_ocl_rt images / publish_no_rocm_image_ubuntu24_04_ocl_rt (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_rocgdb (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04_rocgdb images / publish_no_rocm_image_ubuntu24_04_rocgdb (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_ocl_rt (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Unit Tests / Unit Tests :: ubuntu-24.04 (push) Canceled after 0s
Unit Tests / Unit Tests :: windows-2022 (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_media (push) Canceled after 0s
Unit Tests / Unit Tests Summary (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_openmpi (push) Canceled after 0s
Flatten subprojects into a single base monorepo
2026-09-02 16:34:47 -07:00

550 lines
22 KiB
C++

// Copyright Advanced Micro Devices, Inc., or its affiliates.
// SPDX-License-Identifier: MIT
#ifdef ROCROLLER_USE_HIP
#include <hip/hip_ext.h>
#include <hip/hip_runtime.h>
#endif /* ROCROLLER_USE_HIP */
#include "GEMMF8F6F4.hpp"
#include "GEMMTestBase.hpp"
namespace GEMMTests
{
using namespace rocRoller;
namespace SolutionParams = rocRoller::Parameters::Solution;
static void CheckNumDwordx4(std::string generatedCode,
const int numBitsPerElementAB,
const int macM,
const int macN,
const int macK,
const int workgroupSizeTotal)
{
auto const numBitsPerDwordx4 = 4 * 4 * 8;
auto const numBitsPerElementC = 32;
auto const numBufferLoadsForAB = ((macM * macK + macN * macK) * numBitsPerElementAB)
/ workgroupSizeTotal / numBitsPerDwordx4;
auto const numBufferLoadsForC
= ((macM * macN) * numBitsPerElementC) / workgroupSizeTotal / numBitsPerDwordx4;
EXPECT_EQ(countSubstring(generatedCode, "buffer_load_dwordx4"),
numBufferLoadsForAB + numBufferLoadsForC);
}
// ========================================================================
// GEMMDirectLDSF8F6F4TestSuite
// ========================================================================
// Params are: A & B type, K tile size, (transA, transB), DirectLDS A & B
class GEMMDirectLDSF8F6F4TestSuite
: public BaseGEMMContextFixture<
std::tuple<rocRoller::DataType, int, std::pair<std::string, std::string>, bool, bool>>
{
};
TEST_P(GEMMDirectLDSF8F6F4TestSuite, GPU_GEMM_LoadPath_Direct2LDS_F8F6F4)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA_f8f6f4);
auto [typeAB, MFMAK, transOp, directLDSA, directLDSB] = std::get<1>(GetParam());
int waveM = (MFMAK == 128) ? 16 : 32;
int waveN = (MFMAK == 128) ? 16 : 32;
int waveK = MFMAK;
auto problem = GEMMProblemF8F6F4{waveM, waveN, waveK};
std::tie(problem.transA, problem.transB) = transOp;
problem.loadPathA = directLDSA ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.loadPathB = directLDSB ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
std::string modifiers{"cbsz:0b000 blgp:0b000"};
auto const numBitsPerElementAB = DataTypeInfo::Get(typeAB).elementBits;
switch(typeAB)
{
case DataType::FP8:
basicGEMM<FP8, FP8, float>(problem);
break;
case DataType::BF8:
basicGEMM<BF8, BF8, float>(problem);
modifiers = "cbsz:0b001 blgp:0b001";
break;
case DataType::FP6:
GTEST_SKIP() << "Test not yet supported for FP6" << std::endl;
break;
case DataType::BF6:
GTEST_SKIP() << "Test not yet supported for BF6" << std::endl;
break;
case DataType::FP4:
basicGEMM<FP4, FP4, float>(problem);
modifiers = "cbsz:0b100 blgp:0b100";
break;
default:
Throw<FatalError>(
fmt::format("Unexpected data type: {}. (Allowed FP8, BF8, FP6, BF6, and FP4)",
toString(typeAB)));
}
auto generatedCode = m_context->instructions()->toString();
if(directLDSA && directLDSB)
{
EXPECT_EQ(generatedCode.find("ds_write"), std::string::npos);
}
CheckNumDwordx4(generatedCode,
numBitsPerElementAB,
problem.macM,
problem.macN,
problem.macK,
problem.workgroupSizeX * problem.workgroupSizeY);
}
TEST_P(GEMMDirectLDSF8F6F4TestSuite, GPU_GEMM_LoadPath_Direct2LDS_F8F6F4_Scaled)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA_scale_f8f6f4);
REQUIRE_ARCH_CAP(GPUCapability::HasBlockScaling32);
auto [typeAB, MFMAK, transOp, directLDSA, directLDSB] = std::get<1>(GetParam());
int waveM = (MFMAK == 128) ? 16 : 32;
int waveN = (MFMAK == 128) ? 16 : 32;
int waveK = MFMAK;
auto problem = GEMMProblemF8F6F4{waveM, waveN, waveK};
std::tie(problem.transA, problem.transB) = transOp;
problem.scaleAMode = Operations::ScaleMode::Separate;
problem.scaleBMode = Operations::ScaleMode::Separate;
problem.scaleTypeA = DataType::E8M0;
problem.scaleTypeB = DataType::E8M0;
problem.loadPathA = directLDSA ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.loadPathB = directLDSB ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
problem.scaleBlockSize
= m_context->targetArchitecture().GetCapability(GPUCapability::DefaultScaleBlockSize);
std::string modifiers{"cbsz:0b000 blgp:0b000"};
auto const numBitsPerElementAB = DataTypeInfo::Get(typeAB).elementBits;
switch(typeAB)
{
case DataType::FP8:
basicGEMM<FP8, FP8, float>(problem);
break;
case DataType::BF8:
basicGEMM<BF8, BF8, float>(problem);
modifiers = "cbsz:0b001 blgp:0b001";
break;
case DataType::FP6:
GTEST_SKIP() << "Test not yet supported for FP6" << std::endl;
break;
case DataType::BF6:
GTEST_SKIP() << "Test not yet supported for BF6" << std::endl;
break;
case DataType::FP4:
basicGEMM<FP4, FP4, float>(problem);
modifiers = "cbsz:0b100 blgp:0b100";
break;
default:
Throw<FatalError>(
fmt::format("Unexpected data type: {}. (Allowed FP8, BF8, FP6, BF6, and FP4)",
toString(typeAB)));
}
std::string generatedCode = m_context->instructions()->toString();
if(directLDSA && directLDSB)
{
EXPECT_EQ(generatedCode.find("ds_write"), std::string::npos);
}
CheckNumDwordx4(generatedCode,
numBitsPerElementAB,
problem.macM,
problem.macN,
problem.macK,
problem.workgroupSizeX * problem.workgroupSizeY);
}
TEST_P(GEMMDirectLDSF8F6F4TestSuite, GPU_GEMM_LoadPath_Direct2LDS_F8F6F4_Scaled_Prefetch2)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA_scale_f8f6f4);
REQUIRE_ARCH_CAP(GPUCapability::HasBlockScaling32);
auto [typeAB, MFMAK, transOp, directLDSA, directLDSB] = std::get<1>(GetParam());
int waveM = (MFMAK == 128) ? 16 : 32;
int waveN = (MFMAK == 128) ? 16 : 32;
int waveK = MFMAK;
auto problem = GEMMProblemF8F6F4{waveM, waveN, waveK};
std::tie(problem.transA, problem.transB) = transOp;
problem.scaleAMode = Operations::ScaleMode::Separate;
problem.scaleBMode = Operations::ScaleMode::Separate;
problem.scaleTypeA = DataType::E8M0;
problem.scaleTypeB = DataType::E8M0;
problem.loadPathA = directLDSA ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.loadPathB = directLDSB ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
problem.scaleBlockSize
= m_context->targetArchitecture().GetCapability(GPUCapability::DefaultScaleBlockSize);
problem.prefetch = true;
problem.prefetchInFlight = 2;
problem.unrollK = 2;
std::string modifiers{"cbsz:0b000 blgp:0b000"};
auto const numBitsPerElementAB = DataTypeInfo::Get(typeAB).elementBits;
switch(typeAB)
{
case DataType::FP8:
basicGEMM<FP8, FP8, float>(problem);
break;
case DataType::BF8:
basicGEMM<BF8, BF8, float>(problem);
modifiers = "cbsz:0b001 blgp:0b001";
break;
case DataType::FP6:
GTEST_SKIP() << "Test not yet supported for FP6" << std::endl;
break;
case DataType::BF6:
GTEST_SKIP() << "Test not yet supported for BF6" << std::endl;
break;
case DataType::FP4:
basicGEMM<FP4, FP4, float>(problem);
modifiers = "cbsz:0b100 blgp:0b100";
break;
default:
Throw<FatalError>(
fmt::format("Unexpected data type: {}. (Allowed FP8, BF8, FP6, BF6, and FP4)",
toString(typeAB)));
}
if(directLDSA && directLDSB)
{
auto generatedCode = m_context->instructions()->toString();
EXPECT_EQ(generatedCode.find("ds_write"), std::string::npos);
}
}
TEST_P(GEMMDirectLDSF8F6F4TestSuite, GPU_GEMM_LoadPath_Direct2LDS_F8F6F4_Prefetch2)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA_f8f6f4);
auto [typeAB, MFMAK, transOp, directLDSA, directLDSB] = std::get<1>(GetParam());
int waveM = (MFMAK == 128) ? 16 : 32;
int waveN = (MFMAK == 128) ? 16 : 32;
int waveK = MFMAK;
auto problem = GEMMProblemF8F6F4{waveM, waveN, waveK};
std::tie(problem.transA, problem.transB) = transOp;
problem.loadPathA = directLDSA ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.loadPathB = directLDSB ? SolutionParams::LoadPath::BufferToLDS
: SolutionParams::LoadPath::BufferToLDSViaVGPR;
problem.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
problem.prefetch = true;
problem.prefetchInFlight = 2;
problem.unrollK = 2;
std::string modifiers{"cbsz:0b000 blgp:0b000"};
auto const numBitsPerElementAB = DataTypeInfo::Get(typeAB).elementBits;
switch(typeAB)
{
case DataType::FP8:
basicGEMM<FP8, FP8, float>(problem);
break;
case DataType::BF8:
basicGEMM<BF8, BF8, float>(problem);
modifiers = "cbsz:0b001 blgp:0b001";
break;
case DataType::FP6:
GTEST_SKIP() << "Test not yet supported for FP6" << std::endl;
break;
case DataType::BF6:
GTEST_SKIP() << "Test not yet supported for BF6" << std::endl;
break;
case DataType::FP4:
basicGEMM<FP4, FP4, float>(problem);
modifiers = "cbsz:0b100 blgp:0b100";
break;
default:
Throw<FatalError>(
fmt::format("Unexpected data type: {}. (Allowed FP8, BF8, FP6, BF6, and FP4)",
toString(typeAB)));
}
if(directLDSA && directLDSB)
{
auto generatedCode = m_context->instructions()->toString();
EXPECT_EQ(generatedCode.find("ds_write"), std::string::npos);
}
}
INSTANTIATE_TEST_SUITE_P(
GEMMDirectLDSTest,
GEMMDirectLDSF8F6F4TestSuite,
::testing::Combine(
currentGPUISA(),
::testing::Combine(::testing::Values(rocRoller::DataType::FP8,
rocRoller::DataType::BF8,
rocRoller::DataType::FP6,
rocRoller::DataType::BF6,
rocRoller::DataType::FP4),
::testing::Values(64, 128),
::testing::Values(std::pair<std::string, std::string>("N", "N"),
std::pair<std::string, std::string>("N", "T"),
std::pair<std::string, std::string>("T", "N"),
std::pair<std::string, std::string>("T", "T")),
::testing::Values(true, false),
::testing::Values(true, false))));
// ========================================================================
// GEMMDirectLDSBasicTestSuite
// ========================================================================
// Params are: GPU architecture
class GEMMDirectLDSBasicTestSuite : public BaseGEMMContextFixture<>
{
};
TEST_P(GEMMDirectLDSBasicTestSuite, GPU_BasicGEMMFP32D2L)
{
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA);
GEMMProblem gemm;
gemm.loadPathA = SolutionParams::LoadPath::BufferToLDS;
gemm.loadPathB = SolutionParams::LoadPath::BufferToLDS;
gemm.transA = "T";
gemm.transB = "N";
gemm.m = 3072;
gemm.n = 4096;
gemm.k = 4096;
basicGEMM<float>(gemm);
}
TEST_P(GEMMDirectLDSBasicTestSuite, GPU_BasicGEMMFP32D2LPadded)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA);
GEMMProblem gemm;
gemm.loadPathA = SolutionParams::LoadPath::BufferToLDS;
gemm.loadPathB = SolutionParams::LoadPath::BufferToLDS;
gemm.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
gemm.transA = "T";
gemm.transB = "N";
gemm.m = 3072;
gemm.n = 4096;
gemm.k = 4096;
// This kernel uses 32bit buffer_load instructions; and
// therefore each workgroup loads 1024 bytes per instruction
gemm.padA = {1024, 64};
gemm.padB = {1024, 96};
basicGEMM<float>(gemm);
auto instructions = m_context->instructions()->toString();
auto ldsWriteStrides = Direct2LDSWriteStrides(instructions);
std::set<int> expectedLDSWriteStrides;
if(m_context->targetArchitecture().HasCapability(GPUCapability::HasWiderDirectToLds))
{
expectedLDSWriteStrides = {4 * (1024 + 64), 4 * (1024 + 96)};
}
else
{
expectedLDSWriteStrides = {1024 + 64, 1024 + 96};
}
EXPECT_EQ(ldsWriteStrides, expectedLDSWriteStrides);
}
TEST_P(GEMMDirectLDSBasicTestSuite, GPU_GEMM_LoadPath_Direct2LDS_FP32)
{
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA);
GEMMProblem gemm;
gemm.loadPathA = SolutionParams::LoadPath::BufferToLDS;
gemm.loadPathB = SolutionParams::LoadPath::BufferToLDS;
gemm.transA = "T";
gemm.transB = "N";
gemm.m = 3072;
gemm.n = 4096;
gemm.k = 4096;
basicGEMM<float>(gemm);
}
TEST_P(GEMMDirectLDSBasicTestSuite, GPU_GEMM_LoadPath_Direct2LDS_FP32_Padded)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
REQUIRE_ARCH_CAP(GPUCapability::HasMFMA);
GEMMProblem gemm;
gemm.loadPathA = SolutionParams::LoadPath::BufferToLDS;
gemm.loadPathB = SolutionParams::LoadPath::BufferToLDS;
gemm.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
gemm.transA = "T";
gemm.transB = "N";
gemm.m = 3072;
gemm.n = 4096;
gemm.k = 4096;
// This kernel uses 32bit buffer_load instructions; and
// therefore each workgroup loads 1024 bytes per instruction
gemm.padA = {1024, 64};
gemm.padB = {1024, 96};
basicGEMM<float>(gemm);
auto instructions = m_context->instructions()->toString();
auto ldsWriteStrides = Direct2LDSWriteStrides(instructions);
std::set<int> expectedLDSWriteStrides;
if(m_context->targetArchitecture().HasCapability(GPUCapability::HasWiderDirectToLds))
{
expectedLDSWriteStrides = {4 * (1024 + 64), 4 * (1024 + 96)};
}
else
{
expectedLDSWriteStrides = {1024 + 64, 1024 + 96};
}
EXPECT_EQ(ldsWriteStrides, expectedLDSWriteStrides);
}
INSTANTIATE_TEST_SUITE_P(GEMMDirectLDSTest, GEMMDirectLDSBasicTestSuite, currentGPUISA());
// ========================================================================
// GEMMDirectLDSTestSuite
// ========================================================================
// Params are: A & B type, tile size M, (transA, transB), load path A, load path B
class GEMMDirectLDSTestSuite
: public BaseGEMMContextFixture<std::tuple<rocRoller::DataType,
int,
std::pair<std::string, std::string>,
SolutionParams::LoadPath,
SolutionParams::LoadPath>>
{
};
TEST_P(GEMMDirectLDSTestSuite, GPU_BasicGEMMFP32)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
auto [typeAB, tileSizeM, transOp, loadPathA, loadPathB] = std::get<1>(GetParam());
AssertFatal(typeAB == DataType::Float,
fmt::format("Expected A & B type to be Float but got {}.", toString(typeAB)));
GEMMProblem gemm;
gemm.macM = tileSizeM;
gemm.transA = transOp.first;
gemm.transB = transOp.second;
gemm.loadPathA = loadPathA;
gemm.loadPathB = loadPathB;
gemm.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
basicGEMM<float>(gemm);
if(SolutionParams::IsBufferToLDS(loadPathA) && SolutionParams::IsBufferToLDS(loadPathB))
{
auto generatedCode = m_context->instructions()->toString();
EXPECT_EQ(generatedCode.find("ds_write"), std::string::npos);
}
}
TEST_P(GEMMDirectLDSTestSuite, GPU_GEMM_LoadPath_Direct2LDS_FP32_Parameterized)
{
REQUIRE_ARCH_CAP(GPUCapability::HasDirectToLds);
auto [typeAB, tileSizeM, transOp, loadPathA, loadPathB] = std::get<1>(GetParam());
AssertFatal(typeAB == DataType::Float,
fmt::format("Expected A & B type to be Float but got {}.", toString(typeAB)));
GEMMProblem gemm;
gemm.macM = tileSizeM;
gemm.transA = transOp.first;
gemm.transB = transOp.second;
gemm.loadPathA = loadPathA;
gemm.loadPathB = loadPathB;
gemm.storePath = SolutionParams::StorePath::VGPRToGlobalMemoryWithBuffer;
basicGEMM<float>(gemm);
if(SolutionParams::IsBufferToLDS(loadPathA) && SolutionParams::IsBufferToLDS(loadPathB))
{
auto generatedCode = m_context->instructions()->toString();
EXPECT_EQ(generatedCode.find("ds_write"), std::string::npos);
}
}
template <typename DirectLDSTestType>
static auto FilterOutNonDirectLDSParamValues(
::testing::internal::ParamGenerator<DirectLDSTestType>&& inputParamGenerator)
{
using LP = SolutionParams::LoadPath;
using SM = rocRoller::Operations::ScaleMode;
std::vector<DirectLDSTestType> filtered;
for(auto const& inputParam : inputParamGenerator)
{
auto const& params = std::get<1>(inputParam);
auto const& loadPathA = std::get<3>(params);
auto const& loadPathB = std::get<4>(params);
if(SolutionParams::IsBufferToLDS(loadPathA) || SolutionParams::IsBufferToLDS(loadPathB))
{
filtered.push_back(inputParam);
}
}
return ::testing::ValuesIn(filtered);
}
INSTANTIATE_TEST_SUITE_P(
GEMMDirectLDSTest,
GEMMDirectLDSTestSuite,
FilterOutNonDirectLDSParamValues<GEMMDirectLDSTestSuite::ParamType>(::testing::Combine(
currentGPUISA(),
::testing::Combine(::testing::Values(rocRoller::DataType::Float),
::testing::Values(64, 128),
::testing::Values(std::pair<std::string, std::string>("N", "N"),
std::pair<std::string, std::string>("N", "T"),
std::pair<std::string, std::string>("T", "N"),
std::pair<std::string, std::string>("T", "T")),
::testing::Values(SolutionParams::LoadPath::BufferToLDS,
SolutionParams::LoadPath::BufferToLDSViaVGPR,
SolutionParams::LoadPath::GlobalToVGPR,
SolutionParams::LoadPath::GlobalToLDSViaVGPR),
::testing::Values(SolutionParams::LoadPath::BufferToLDS,
SolutionParams::LoadPath::BufferToLDSViaVGPR,
SolutionParams::LoadPath::GlobalToVGPR,
SolutionParams::LoadPath::GlobalToLDSViaVGPR)))));
} // namespace GEMMTests