block_opencl.c 1.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. /*
  2. * StarPU
  3. * Copyright (C) INRIA 2008-2009 (see AUTHORS file)
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU Lesser General Public License as published by
  7. * the Free Software Foundation; either version 2.1 of the License, or (at
  8. * your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful, but
  11. * WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  13. *
  14. * See the GNU Lesser General Public License in COPYING.LGPL for more details.
  15. */
  16. #include <starpu.h>
  17. #include <starpu_opencl.h>
  18. extern struct starpu_opencl_program opencl_code;
  19. void opencl_codelet(void *descr[], void *_args)
  20. {
  21. cl_kernel kernel;
  22. cl_command_queue queue;
  23. int id, devid, err, n;
  24. float *block = (float *)STARPU_BLOCK_GET_PTR(descr[0]);
  25. int nx = (int)STARPU_BLOCK_GET_NX(descr[0]);
  26. int ny = (int)STARPU_BLOCK_GET_NY(descr[0]);
  27. int nz = (int)STARPU_BLOCK_GET_NZ(descr[0]);
  28. float *multiplier = (float *)_args;
  29. id = starpu_worker_get_id();
  30. devid = starpu_worker_get_devid(id);
  31. err = starpu_opencl_load_kernel(&kernel, &queue, &opencl_code, "block", devid);
  32. if (err != CL_SUCCESS) STARPU_OPENCL_REPORT_ERROR(err);
  33. err = 0;
  34. n=0;
  35. err = clSetKernelArg(kernel, 0, sizeof(cl_mem), &block);
  36. err = clSetKernelArg(kernel, 1, sizeof(int), &nx);
  37. err = clSetKernelArg(kernel, 2, sizeof(int), &ny);
  38. err = clSetKernelArg(kernel, 3, sizeof(int), &nz);
  39. err = clSetKernelArg(kernel, 4, sizeof(float), multiplier);
  40. if (err) STARPU_OPENCL_REPORT_ERROR(err);
  41. {
  42. size_t global=1024;
  43. err = clEnqueueNDRangeKernel(queue, kernel, 1, NULL, &global, NULL, 0, NULL, NULL);
  44. if (err != CL_SUCCESS) STARPU_OPENCL_REPORT_ERROR(err);
  45. }
  46. clFinish(queue);
  47. starpu_opencl_release_kernel(kernel);
  48. }