AI/rocm-systems
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SWDEV-291787 - Update files with proper EOL

Browse Source 
Change-Id: I3be96a3bb7d1d944f3a14b595df8ec533af6f953


[ROCm/clr commit: 82156484b4]
This commit is contained in:
Julia Jiang
2021-07-07 18:03:52 -04:00
parent 748680e8a6
commit 318fd353de
268 changed files with 45780 additions and 45780 deletions
Download Patch File Download Diff File Expand all files Collapse all files
projects/clr/opencl/tests/ocltst/module/perf/OCLPerfDevMemReadSpeed.cpp
+223 -223
View File
@@ -18,226 +18,226 @@
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE. */
#include "OCLPerfDevMemReadSpeed.h"
#include <assert.h>
#include <stdio.h>
#include <string.h>
#include "CL/opencl.h"
#include "Timer.h"
// Quiet pesky warnings
#ifdef WIN_OS
#define SNPRINTF sprintf_s
#else
#define SNPRINTF snprintf
#endif
#define NUM_SIZES 1
static const unsigned int Sizes[NUM_SIZES] = {256 * 1024 * 1024};
const static char *strKernel =
"__kernel void read_kernel(__global uint16 *src, ulong size1, uint "
"threads, __global uint* dst\n"
" )\n"
"{\n"
" uint16 pval;\n"
" int idx = get_global_id(0);\n"
" __global uint16 *srcEnd = src + size1;\n"
" uint tmp = 0;\n"
" src = &src[idx];"
" while (src < srcEnd) \n"
" {\n"
" pval = *src;\n"
" src += threads;\n"
" tmp += pval.s0 + pval.s1 + pval.s2 + pval.s3 + pval.s4 + pval.s5 + pval.s6 + \
pval.s7 + pval.s8 + pval.s9 + pval.sa + pval.sb + pval.sc + pval.sd + pval.se + pval.sf;\n"
" }\n"
" atomic_add(dst, tmp);\n"
"}\n";
OCLPerfDevMemReadSpeed::OCLPerfDevMemReadSpeed() { _numSubTests = 1; }
OCLPerfDevMemReadSpeed::~OCLPerfDevMemReadSpeed() {}
static void CL_CALLBACK notify_callback(const char *errinfo,
const void *private_info, size_t cb,
void *user_data) {}
void OCLPerfDevMemReadSpeed::open(unsigned int test, char *units,
double &conversion, unsigned int deviceId) {
error_ = CL_SUCCESS;
OCLTestImp::open(test, units, conversion, deviceId);
CHECK_RESULT((error_ != CL_SUCCESS), "Error opening test");
program_ = 0;
kernel_ = 0;
skip_ = false;
dstBuffer_ = 0;
nBytes = Sizes[0];
cl_ulong loopCnt = nBytes / (16 * sizeof(cl_uint));
cl_uint maxCUs;
error_ = _wrapper->clGetDeviceInfo(devices_[_deviceId],
CL_DEVICE_MAX_COMPUTE_UNITS,
sizeof(cl_uint), &maxCUs, 0);
CHECK_RESULT(error_ != CL_SUCCESS, "clGetDeviceInfo failed");
wgs = 64;
const static cl_uint wavesPerCU = 8;
nWorkItems = maxCUs * wavesPerCU * wgs;
inputData = 0x1;
nIter = 1000;
program_ = _wrapper->clCreateProgramWithSource(context_, 1, &strKernel, NULL,
&error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateProgramWithSource() failed");
error_ = _wrapper->clBuildProgram(program_, 1, &devices_[deviceId], NULL,
NULL, NULL);
if (error_ != CL_SUCCESS) {
char programLog[1024];
_wrapper->clGetProgramBuildInfo(program_, devices_[deviceId],
CL_PROGRAM_BUILD_LOG, 1024, programLog, 0);
printf("\n%s\n", programLog);
fflush(stdout);
}
CHECK_RESULT((error_ != CL_SUCCESS), "clBuildProgram() failed");
kernel_ = _wrapper->clCreateKernel(program_, "read_kernel", &error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateKernel() failed");
srcBuffer_ = _wrapper->clCreateBuffer(context_, CL_MEM_READ_ONLY, nBytes,
NULL, &error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateBuffer(srcBuffer) failed");
void *mem;
mem = _wrapper->clEnqueueMapBuffer(cmdQueues_[_deviceId], srcBuffer_, CL_TRUE,
CL_MAP_READ | CL_MAP_WRITE, 0, nBytes, 0,
NULL, NULL, &error_);
CHECK_RESULT(error_, "clEnqueueMapBuffer failed");
for (unsigned int i = 0; i < nBytes / sizeof(cl_uint); ++i) {
reinterpret_cast<cl_uint *>(mem)[i] = inputData;
}
dstBuffer_ = _wrapper->clCreateBuffer(context_, CL_MEM_WRITE_ONLY,
sizeof(cl_uint), NULL, &error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateBuffer(dstBuffer) failed");
_wrapper->clEnqueueUnmapMemObject(cmdQueues_[_deviceId], srcBuffer_, mem, 0,
NULL, NULL);
mem = _wrapper->clEnqueueMapBuffer(cmdQueues_[_deviceId], dstBuffer_, CL_TRUE,
CL_MAP_READ | CL_MAP_WRITE, 0,
sizeof(cl_uint), 0, NULL, NULL, &error_);
CHECK_RESULT(error_, "clEnqueueMapBuffer failed");
memset(mem, 0, sizeof(cl_uint));
_wrapper->clEnqueueUnmapMemObject(cmdQueues_[_deviceId], dstBuffer_, mem, 0,
NULL, NULL);
error_ = _wrapper->clSetKernelArg(kernel_, 0, sizeof(cl_mem), &srcBuffer_);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
error_ =
_wrapper->clSetKernelArg(kernel_, 1, sizeof(cl_ulong), (void *)&loopCnt);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
error_ = _wrapper->clSetKernelArg(kernel_, 2, sizeof(cl_uint),
(void *)&nWorkItems);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
error_ =
_wrapper->clSetKernelArg(kernel_, 3, sizeof(cl_mem), (void *)&dstBuffer_);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
}
void OCLPerfDevMemReadSpeed::run(void) {
if (skip_) {
return;
}
CPerfCounter timer;
size_t gws[1] = {nWorkItems};
size_t lws[1] = {wgs};
// warm up
error_ = _wrapper->clEnqueueNDRangeKernel(cmdQueues_[_deviceId], kernel_, 1,
NULL, gws, lws, 0, NULL, NULL);
CHECK_RESULT((error_ != CL_SUCCESS), "clEnqueueNDRangeKernel() failed");
_wrapper->clFinish(cmdQueues_[_deviceId]);
cl_uint *memResult;
memResult = (cl_uint *)malloc(sizeof(cl_uint));
if (0 == memResult) {
CHECK_RESULT_NO_RETURN(0, "malloc failed!\n");
return;
}
memset(memResult, 0, sizeof(cl_uint));
error_ = _wrapper->clEnqueueReadBuffer(cmdQueues_[_deviceId], dstBuffer_,
CL_FALSE, 0, sizeof(cl_uint),
memResult, 0, NULL, NULL);
CHECK_RESULT(error_, "clEnqueueReadBuffer dstBuffer_ failed!");
_wrapper->clFinish(cmdQueues_[_deviceId]);
if (memResult[0] != (nBytes / sizeof(cl_uint))) {
CHECK_RESULT_NO_RETURN(0, "Data validation failed for warm up run!\n");
free(memResult);
return;
}
free(memResult);
timer.Reset();
timer.Start();
double sec2 = 0;
cl_event *events = new cl_event[nIter];
for (unsigned int i = 0; i < nIter; i++) {
error_ = _wrapper->clEnqueueNDRangeKernel(
cmdQueues_[_deviceId], kernel_, 1, NULL, gws, lws, 0, NULL, &events[i]);
CHECK_RESULT((error_ != CL_SUCCESS), "clEnqueueNDRangeKernel() failed");
}
_wrapper->clFinish(cmdQueues_[_deviceId]);
timer.Stop();
for (unsigned int i = 0; i < nIter; i++) {
cl_ulong startTime = 0, endTime = 0;
error_ = _wrapper->clGetEventProfilingInfo(
events[i], CL_PROFILING_COMMAND_START, sizeof(cl_ulong), &startTime, 0);
CHECK_RESULT(error_, "clGetEventProfilingInfo failed");
error_ = _wrapper->clGetEventProfilingInfo(
events[i], CL_PROFILING_COMMAND_END, sizeof(cl_ulong), &endTime, 0);
CHECK_RESULT(error_, "clGetEventProfilingInfo failed");
_wrapper->clReleaseEvent(events[i]);
sec2 += endTime - startTime;
}
double sec = timer.GetElapsedTime();
delete[] events;
// read speed in GB/s
double perf = ((double)nBytes * nIter * (double)(1e-09)) / sec;
double perf2 = ((double)nBytes * nIter) / sec2;
_perfInfo = (float)perf2;
float perfInfo = (float)perf;
char buf[256];
SNPRINTF(buf, sizeof(buf), " (%8d bytes) i:%4d Wall time Perf: %.2f (GB/s)",
nBytes, nIter, perfInfo);
testDescString = buf;
}
unsigned int OCLPerfDevMemReadSpeed::close(void) {
if (!skip_) {
if (srcBuffer_) {
error_ = _wrapper->clReleaseMemObject(srcBuffer_);
CHECK_RESULT_NO_RETURN(error_ != CL_SUCCESS,
"clReleaseMemObject(srcBuffer_) failed");
}
if (dstBuffer_) {
error_ = _wrapper->clReleaseMemObject(dstBuffer_);
CHECK_RESULT_NO_RETURN(error_ != CL_SUCCESS,
"clReleaseMemObject(srcBuffer_) failed");
}
}
return OCLTestImp::close();
}
#include "OCLPerfDevMemReadSpeed.h"
#include <assert.h>
#include <stdio.h>
#include <string.h>
#include "CL/opencl.h"
#include "Timer.h"
// Quiet pesky warnings
#ifdef WIN_OS
#define SNPRINTF sprintf_s
#else
#define SNPRINTF snprintf
#endif
#define NUM_SIZES 1
static const unsigned int Sizes[NUM_SIZES] = {256 * 1024 * 1024};
const static char *strKernel =
"__kernel void read_kernel(__global uint16 *src, ulong size1, uint "
"threads, __global uint* dst\n"
" )\n"
"{\n"
" uint16 pval;\n"
" int idx = get_global_id(0);\n"
" __global uint16 *srcEnd = src + size1;\n"
" uint tmp = 0;\n"
" src = &src[idx];"
" while (src < srcEnd) \n"
" {\n"
" pval = *src;\n"
" src += threads;\n"
" tmp += pval.s0 + pval.s1 + pval.s2 + pval.s3 + pval.s4 + pval.s5 + pval.s6 + \
pval.s7 + pval.s8 + pval.s9 + pval.sa + pval.sb + pval.sc + pval.sd + pval.se + pval.sf;\n"
" }\n"
" atomic_add(dst, tmp);\n"
"}\n";
OCLPerfDevMemReadSpeed::OCLPerfDevMemReadSpeed() { _numSubTests = 1; }
OCLPerfDevMemReadSpeed::~OCLPerfDevMemReadSpeed() {}
static void CL_CALLBACK notify_callback(const char *errinfo,
const void *private_info, size_t cb,
void *user_data) {}
void OCLPerfDevMemReadSpeed::open(unsigned int test, char *units,
double &conversion, unsigned int deviceId) {
error_ = CL_SUCCESS;
OCLTestImp::open(test, units, conversion, deviceId);
CHECK_RESULT((error_ != CL_SUCCESS), "Error opening test");
program_ = 0;
kernel_ = 0;
skip_ = false;
dstBuffer_ = 0;
nBytes = Sizes[0];
cl_ulong loopCnt = nBytes / (16 * sizeof(cl_uint));
cl_uint maxCUs;
error_ = _wrapper->clGetDeviceInfo(devices_[_deviceId],
CL_DEVICE_MAX_COMPUTE_UNITS,
sizeof(cl_uint), &maxCUs, 0);
CHECK_RESULT(error_ != CL_SUCCESS, "clGetDeviceInfo failed");
wgs = 64;
const static cl_uint wavesPerCU = 8;
nWorkItems = maxCUs * wavesPerCU * wgs;
inputData = 0x1;
nIter = 1000;
program_ = _wrapper->clCreateProgramWithSource(context_, 1, &strKernel, NULL,
&error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateProgramWithSource() failed");
error_ = _wrapper->clBuildProgram(program_, 1, &devices_[deviceId], NULL,
NULL, NULL);
if (error_ != CL_SUCCESS) {
char programLog[1024];
_wrapper->clGetProgramBuildInfo(program_, devices_[deviceId],
CL_PROGRAM_BUILD_LOG, 1024, programLog, 0);
printf("\n%s\n", programLog);
fflush(stdout);
}
CHECK_RESULT((error_ != CL_SUCCESS), "clBuildProgram() failed");
kernel_ = _wrapper->clCreateKernel(program_, "read_kernel", &error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateKernel() failed");
srcBuffer_ = _wrapper->clCreateBuffer(context_, CL_MEM_READ_ONLY, nBytes,
NULL, &error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateBuffer(srcBuffer) failed");
void *mem;
mem = _wrapper->clEnqueueMapBuffer(cmdQueues_[_deviceId], srcBuffer_, CL_TRUE,
CL_MAP_READ | CL_MAP_WRITE, 0, nBytes, 0,
NULL, NULL, &error_);
CHECK_RESULT(error_, "clEnqueueMapBuffer failed");
for (unsigned int i = 0; i < nBytes / sizeof(cl_uint); ++i) {
reinterpret_cast<cl_uint *>(mem)[i] = inputData;
}
dstBuffer_ = _wrapper->clCreateBuffer(context_, CL_MEM_WRITE_ONLY,
sizeof(cl_uint), NULL, &error_);
CHECK_RESULT((error_ != CL_SUCCESS), "clCreateBuffer(dstBuffer) failed");
_wrapper->clEnqueueUnmapMemObject(cmdQueues_[_deviceId], srcBuffer_, mem, 0,
NULL, NULL);
mem = _wrapper->clEnqueueMapBuffer(cmdQueues_[_deviceId], dstBuffer_, CL_TRUE,
CL_MAP_READ | CL_MAP_WRITE, 0,
sizeof(cl_uint), 0, NULL, NULL, &error_);
CHECK_RESULT(error_, "clEnqueueMapBuffer failed");
memset(mem, 0, sizeof(cl_uint));
_wrapper->clEnqueueUnmapMemObject(cmdQueues_[_deviceId], dstBuffer_, mem, 0,
NULL, NULL);
error_ = _wrapper->clSetKernelArg(kernel_, 0, sizeof(cl_mem), &srcBuffer_);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
error_ =
_wrapper->clSetKernelArg(kernel_, 1, sizeof(cl_ulong), (void *)&loopCnt);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
error_ = _wrapper->clSetKernelArg(kernel_, 2, sizeof(cl_uint),
(void *)&nWorkItems);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
error_ =
_wrapper->clSetKernelArg(kernel_, 3, sizeof(cl_mem), (void *)&dstBuffer_);
CHECK_RESULT((error_ != CL_SUCCESS), "clSetKernelArg() failed");
}
void OCLPerfDevMemReadSpeed::run(void) {
if (skip_) {
return;
}
CPerfCounter timer;
size_t gws[1] = {nWorkItems};
size_t lws[1] = {wgs};
// warm up
error_ = _wrapper->clEnqueueNDRangeKernel(cmdQueues_[_deviceId], kernel_, 1,
NULL, gws, lws, 0, NULL, NULL);
CHECK_RESULT((error_ != CL_SUCCESS), "clEnqueueNDRangeKernel() failed");
_wrapper->clFinish(cmdQueues_[_deviceId]);
cl_uint *memResult;
memResult = (cl_uint *)malloc(sizeof(cl_uint));
if (0 == memResult) {
CHECK_RESULT_NO_RETURN(0, "malloc failed!\n");
return;
}
memset(memResult, 0, sizeof(cl_uint));
error_ = _wrapper->clEnqueueReadBuffer(cmdQueues_[_deviceId], dstBuffer_,
CL_FALSE, 0, sizeof(cl_uint),
memResult, 0, NULL, NULL);
CHECK_RESULT(error_, "clEnqueueReadBuffer dstBuffer_ failed!");
_wrapper->clFinish(cmdQueues_[_deviceId]);
if (memResult[0] != (nBytes / sizeof(cl_uint))) {
CHECK_RESULT_NO_RETURN(0, "Data validation failed for warm up run!\n");
free(memResult);
return;
}
free(memResult);
timer.Reset();
timer.Start();
double sec2 = 0;
cl_event *events = new cl_event[nIter];
for (unsigned int i = 0; i < nIter; i++) {
error_ = _wrapper->clEnqueueNDRangeKernel(
cmdQueues_[_deviceId], kernel_, 1, NULL, gws, lws, 0, NULL, &events[i]);
CHECK_RESULT((error_ != CL_SUCCESS), "clEnqueueNDRangeKernel() failed");
}
_wrapper->clFinish(cmdQueues_[_deviceId]);
timer.Stop();
for (unsigned int i = 0; i < nIter; i++) {
cl_ulong startTime = 0, endTime = 0;
error_ = _wrapper->clGetEventProfilingInfo(
events[i], CL_PROFILING_COMMAND_START, sizeof(cl_ulong), &startTime, 0);
CHECK_RESULT(error_, "clGetEventProfilingInfo failed");
error_ = _wrapper->clGetEventProfilingInfo(
events[i], CL_PROFILING_COMMAND_END, sizeof(cl_ulong), &endTime, 0);
CHECK_RESULT(error_, "clGetEventProfilingInfo failed");
_wrapper->clReleaseEvent(events[i]);
sec2 += endTime - startTime;
}
double sec = timer.GetElapsedTime();
delete[] events;
// read speed in GB/s
double perf = ((double)nBytes * nIter * (double)(1e-09)) / sec;
double perf2 = ((double)nBytes * nIter) / sec2;
_perfInfo = (float)perf2;
float perfInfo = (float)perf;
char buf[256];
SNPRINTF(buf, sizeof(buf), " (%8d bytes) i:%4d Wall time Perf: %.2f (GB/s)",
nBytes, nIter, perfInfo);
testDescString = buf;
}
unsigned int OCLPerfDevMemReadSpeed::close(void) {
if (!skip_) {
if (srcBuffer_) {
error_ = _wrapper->clReleaseMemObject(srcBuffer_);
CHECK_RESULT_NO_RETURN(error_ != CL_SUCCESS,
"clReleaseMemObject(srcBuffer_) failed");
}
if (dstBuffer_) {
error_ = _wrapper->clReleaseMemObject(dstBuffer_);
CHECK_RESULT_NO_RETURN(error_ != CL_SUCCESS,
"clReleaseMemObject(srcBuffer_) failed");
}
}
return OCLTestImp::close();
}