/home/docs/checkouts/readthedocs.org/user_builds/advanced-micro-devices-composable-kernel/checkouts/develop/include/ck/host_utility/flush_cache.hpp Source File

/home/docs/checkouts/readthedocs.org/user_builds/advanced-micro-devices-composable-kernel/checkouts/develop/include/ck/host_utility/flush_cache.hpp Source File#

Composable Kernel: /home/docs/checkouts/readthedocs.org/user_builds/advanced-micro-devices-composable-kernel/checkouts/develop/include/ck/host_utility/flush_cache.hpp Source File
Go to the documentation of this file.
 // SPDX-License-Identifier: MIT
 // Copyright (c) 2018-2024, Advanced Micro Devices, Inc. All rights reserved.
  
 #pragma once
  
 #include <hip/hip_runtime.h>
 #include <set>
 #include <vector>
  
 #include "ck/ck.hpp"
 #include "ck/utility/env.hpp"
 #include "ck/stream_config.hpp"
 #include "ck/host_utility/hip_check_error.hpp"
 #include "ck/utility/flush_icache.hpp"
 namespace ck {
 namespace utility {
  
 template <typename Argument, typename DsDataType>
 struct RotatingMemWrapperMultiD
 {
     static constexpr index_t NumDs = DsDataType::Size();
  
     using ADataType     = decltype(Argument::p_a_grid);
     using BDataType     = decltype(Argument::p_b_grid);
     using DsGridPointer = decltype(Argument::p_ds_grid);
  
     RotatingMemWrapperMultiD() = delete;
     RotatingMemWrapperMultiD(Argument& arg_,
                              std::size_t rotating_count_,
                              std::size_t size_a_,
                              std::size_t size_b_,
                              std::array<std::size_t, NumDs> size_ds_)
         : arg(arg_),
           rotating_count(rotating_count_),
           size_a(size_a_),
           size_b(size_b_),
           size_ds(size_ds_)
     {
         p_a_grids.push_back(arg.p_a_grid);
         p_b_grids.push_back(arg.p_b_grid);
         p_ds_grids.push_back(arg.p_ds_grid);
         for(size_t i = 1; i < rotating_count; i++)
         {
             {
                 void* pADeviceBuf;
                 hip_check_error(hipMalloc(static_cast<void**>(&pADeviceBuf), size_a_));
                 hip_check_error(hipMemcpy(static_cast<void*>(pADeviceBuf),
                                           const_cast<void*>(p_a_grids[0]),
                                           size_a_,
                                           hipMemcpyDeviceToDevice));
                 p_a_grids.push_back(pADeviceBuf);
             }
  
             {
                 void* pBDeviceBuf;
                 hip_check_error(hipMalloc(static_cast<void**>(&pBDeviceBuf), size_b_));
                 hip_check_error(hipMemcpy(static_cast<void*>(pBDeviceBuf),
                                           const_cast<void*>(p_b_grids[0]),
                                           size_b_,
                                           hipMemcpyDeviceToDevice));
                 p_b_grids.push_back(pBDeviceBuf);
             }
  
             {
  
                 DsGridPointer ds_buffer;
                 static_for<0, NumDs, 1>{}([&](auto j) {
                     void* pDDeviceBuf;
                     hip_check_error(hipMalloc(static_cast<void**>(&pDDeviceBuf), size_ds_[j]));
                     hip_check_error(hipMemcpy(static_cast<void*>(pDDeviceBuf),
                                               static_cast<const void*>(p_ds_grids[0][j]),
                                               size_ds_[j],
                                               hipMemcpyDeviceToDevice));
  
                     using DDataType = remove_cvref_t<tuple_element_t<j.value, DsDataType>>;
  
                     ds_buffer(j) = static_cast<const DDataType*>(pDDeviceBuf);
                 });
  
                 p_ds_grids.push_back(ds_buffer);
             }
         }
     }
  
     void Next()
     {
         if(rotating_count > 1)
         {
             std::size_t idx = iter++ % rotating_count;
             arg.p_a_grid    = reinterpret_cast<ADataType>(p_a_grids[idx]);
             arg.p_b_grid    = reinterpret_cast<BDataType>(p_b_grids[idx]);
             arg.p_ds_grid   = p_ds_grids[idx];
         }
     }
     void Print()
     {
         std::cout << "RotatingMemWrapperMultiD: { size_a: " << size_a << ", size_b: " << size_b
                   << ", rotating_count: " << rotating_count << "}" << std::endl;
     }
     ~RotatingMemWrapperMultiD()
     {
         if(rotating_count > 1)
         {
             // restore ptr
             arg.p_a_grid  = reinterpret_cast<ADataType>(p_a_grids[0]);
             arg.p_b_grid  = reinterpret_cast<BDataType>(p_b_grids[0]);
             arg.p_ds_grid = p_ds_grids[0];
  
             // free device mem
             for(size_t i = 1; i < rotating_count; i++)
             {
                 hip_check_error(hipFree(const_cast<void*>(p_a_grids[i])));
                 hip_check_error(hipFree(const_cast<void*>(p_b_grids[i])));
  
                 static_for<0, NumDs, 1>{}([&](auto j) {
                     using DDataType = remove_cvref_t<tuple_element_t<j.value, DsDataType>>;
                     hip_check_error(
                         hipFree(static_cast<void*>(const_cast<DDataType*>(p_ds_grids[i][j]))));
                 });
             }
         }
     }
  
     private:
     Argument& arg;
     std::size_t iter                       = 0;
     std::size_t rotating_count             = 1;
     std::size_t size_a                     = 0;
     std::size_t size_b                     = 0;
     std::array<std::size_t, NumDs> size_ds = {0};
     std::vector<const void*> p_a_grids;
     std::vector<const void*> p_b_grids;
     std::vector<DsGridPointer> p_ds_grids;
 };
  
 template <typename Argument>
 struct RotatingMemWrapper
 {
     using ADataType = decltype(Argument::p_a_grid);
     using BDataType = decltype(Argument::p_b_grid);
  
     RotatingMemWrapper() = delete;
     RotatingMemWrapper(Argument& arg_,
                        std::size_t rotating_count_,
                        std::size_t size_a_,
                        std::size_t size_b_)
         : arg(arg_), rotating_count(rotating_count_), size_a(size_a_), size_b(size_b_)
     {
         p_a_grids.push_back(arg.p_a_grid);
         p_b_grids.push_back(arg.p_b_grid);
         for(size_t i = 1; i < rotating_count; i++)
         {
             {
                 void* pADeviceBuf;
                 hip_check_error(hipMalloc(static_cast<void**>(&pADeviceBuf), size_a_));
                 hip_check_error(hipMemcpy(static_cast<void*>(pADeviceBuf),
                                           const_cast<void*>(p_a_grids[0]),
                                           size_a_,
                                           hipMemcpyDeviceToDevice));
                 p_a_grids.push_back(pADeviceBuf);
             }
  
             {
                 void* pBDeviceBuf;
                 hip_check_error(hipMalloc(static_cast<void**>(&pBDeviceBuf), size_b_));
                 hip_check_error(hipMemcpy(static_cast<void*>(pBDeviceBuf),
                                           const_cast<void*>(p_b_grids[0]),
                                           size_b_,
                                           hipMemcpyDeviceToDevice));
                 p_b_grids.push_back(pBDeviceBuf);
             }
         }
     }
  
     void Next()
     {
         if(rotating_count > 1)
         {
             std::size_t idx = iter++ % rotating_count;
             arg.p_a_grid    = reinterpret_cast<ADataType>(p_a_grids[idx]);
             arg.p_b_grid    = reinterpret_cast<BDataType>(p_b_grids[idx]);
         }
     }
     void Print()
     {
         std::cout << "RotatingMemWrapper: { size_a: " << size_a << ", size_b: " << size_b
                   << ", rotating_count: " << rotating_count << "}" << std::endl;
     }
     ~RotatingMemWrapper()
     {
         if(rotating_count > 1)
         {
             // restore ptr
             arg.p_a_grid = reinterpret_cast<ADataType>(p_a_grids[0]);
             arg.p_b_grid = reinterpret_cast<BDataType>(p_b_grids[0]);
  
             // free device mem
             for(size_t i = 1; i < rotating_count; i++)
             {
                 hip_check_error(hipFree(const_cast<void*>(p_a_grids[i])));
                 hip_check_error(hipFree(const_cast<void*>(p_b_grids[i])));
             }
         }
     }
  
     private:
     Argument& arg;
     std::size_t iter           = 0;
     std::size_t rotating_count = 1;
     std::size_t size_a         = 0;
     std::size_t size_b         = 0;
     std::vector<const void*> p_a_grids;
     std::vector<const void*> p_b_grids;
 };
  
 inline void flush_icache()
 {
     hipDeviceProp_t deviceProps;
     hip_check_error(hipGetDeviceProperties(&deviceProps, 0));
     int32_t gpu_block3 = deviceProps.multiProcessorCount * 60;
  
     ck::flush_icache<<<dim3(gpu_block3), dim3(64), 0, nullptr>>>();
     hip_check_error(hipGetLastError());
 }
 // if TimePrePress == false, return time does not include preprocess's time
 template <bool TimePreprocess,
           typename GemmArgs,
           typename... Args,
           typename F,
           typename PreProcessFunc>
 float launch_and_time_kernel_with_preprocess(const StreamConfig& stream_config,
                                              PreProcessFunc preprocess,
                                              F kernel,
                                              dim3 grid_dim,
                                              dim3 block_dim,
                                              std::size_t lds_byte,
                                              GemmArgs& gemm_args,
                                              Args... args)
 {
 #if CK_TIME_KERNEL
 #define MEDIAN 0
     if(stream_config.time_kernel_)
     {
         if(ck::EnvIsEnabled(CK_ENV(CK_LOGGING)))
         {
             printf("%s: grid_dim {%u, %u, %u}, block_dim {%u, %u, %u} \n",
                    __func__,
                    grid_dim.x,
                    grid_dim.y,
                    grid_dim.z,
                    block_dim.x,
                    block_dim.y,
                    block_dim.z);
  
             printf("Warm up %d times\n", stream_config.cold_niters_);
         }
         // warm up
         for(int i = 0; i < stream_config.cold_niters_; ++i)
         {
             kernel<<<grid_dim, block_dim, lds_byte, stream_config.stream_id_>>>(gemm_args, args...);
             hip_check_error(hipGetLastError());
         }
  
         const int nrepeat = stream_config.nrepeat_;
         if(nrepeat == 0)
         {
             return 0.0;
         }
         if(ck::EnvIsEnabled(CK_ENV(CK_LOGGING)))
         {
             printf("Start running %d times...\n", nrepeat);
         }
  
 #if MEDIAN
         std::set<float> times;
 #else
         float total_time = 0;
 #endif
         hipEvent_t start, stop;
  
         hip_check_error(hipEventCreate(&start));
         hip_check_error(hipEventCreate(&stop));
  
         hip_check_error(hipDeviceSynchronize());
         hip_check_error(hipEventRecord(start, stream_config.stream_id_));
  
         for(int i = 0; i < nrepeat; ++i)
         {
             if constexpr(!TimePreprocess)
             {
                 preprocess();
             }
  
             // hipEvent_t start, stop;
  
             // hip_check_error(hipEventCreate(&start));
             // hip_check_error(hipEventCreate(&stop));
  
             // hip_check_error(hipDeviceSynchronize());
             // hip_check_error(hipEventRecord(start, stream_config.stream_id_));
             // calculate preprocess time
             if constexpr(TimePreprocess)
             {
                 preprocess();
             }
             // run real kernel
             kernel<<<grid_dim, block_dim, lds_byte, stream_config.stream_id_>>>(gemm_args, args...);
             hip_check_error(hipGetLastError());
             // end real kernel
  
             //             hip_check_error(hipEventRecord(stop, stream_config.stream_id_));
             //             hip_check_error(hipEventSynchronize(stop));
             //             float cur_time = 0;
             //             hip_check_error(hipEventElapsedTime(&cur_time, start, stop));
             // #if MEDIAN
             //             times.insert(cur_time);
             // #else
             //             total_time += cur_time;
             // #endif
  
             if(ck::EnvIsEnabled(CK_ENV(CK_LOGGING)))
             {
                 // std::cout << "i: " << i << " cur_time: " << cur_time << std::endl;
  
                 printf("gemm_args.p_a_grid: %p, gemm_args.p_b_grid:%p\n",
                        static_cast<const void*>(gemm_args.p_a_grid),
                        static_cast<const void*>(gemm_args.p_b_grid));
             }
         }
         hip_check_error(hipEventRecord(stop, stream_config.stream_id_));
         hip_check_error(hipEventSynchronize(stop));
         float cur_time = 0;
         hip_check_error(hipEventElapsedTime(&cur_time, start, stop));
 #if MEDIAN
         times.insert(cur_time);
 #else
         total_time += cur_time;
 #endif
  
 #if MEDIAN
         auto mid = times.begin();
         std::advance(mid, (nrepeat - 1) / 2);
         if(nrepeat % 2 == 1)
         {
             return *mid;
         }
         else
         {
             auto mid_next = mid;
             std::advance(mid_next, 1);
             return (*mid + *mid_next) / 2;
         }
 #else
         // return total_time / nrepeat;
         hipDeviceProp_t deviceProps;
         hip_check_error(hipGetDeviceProperties(&deviceProps, 0));
         float preprocess_offset = deviceProps.multiProcessorCount == 80 ? 0.005 : 0.01;
         return (total_time - preprocess_offset * nrepeat) / nrepeat;
 #endif
     }
     else
     {
         preprocess();
         kernel<<<grid_dim, block_dim, lds_byte, stream_config.stream_id_>>>(gemm_args, args...);
         hip_check_error(hipGetLastError());
  
         return 0;
     }
 #else
     kernel<<<grid_dim, block_dim, lds_byte, stream_config.stream_id_>>>(gemm_args, args...);
     hip_check_error(hipGetLastError());
  
     return 0;
 #endif
 }
  
 } // namespace utility
 } // namespace ck