sync_and_notify_data_kernels.cu 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2009-2021 Université de Bordeaux, CNRS (LaBRI UMR 5800), Inria
  4. *
  5. * StarPU 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. * StarPU 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. /*
  18. * increment a (val[0])
  19. */
  20. static __global__ void _cuda_incA(unsigned *v)
  21. {
  22. v[0]++;
  23. }
  24. extern "C" void cuda_codelet_incA(void *descr[], void *_args)
  25. {
  26. unsigned *v = (unsigned *)STARPU_VECTOR_GET_PTR(descr[0]);
  27. _cuda_incA<<<1,1, 0, starpu_cuda_get_local_stream()>>>(v);
  28. cudaError_t status = cudaGetLastError();
  29. if (status != cudaSuccess) STARPU_CUDA_REPORT_ERROR(status);
  30. }
  31. /*
  32. * increment c (val[2])
  33. */
  34. static __global__ void _cuda_incC(unsigned *v)
  35. {
  36. v[2]++;
  37. }
  38. extern "C" void cuda_codelet_incC(void *descr[], void *_args)
  39. {
  40. unsigned *v = (unsigned *)STARPU_VECTOR_GET_PTR(descr[0]);
  41. _cuda_incC<<<1,1, 0, starpu_cuda_get_local_stream()>>>(v);
  42. cudaError_t status = cudaGetLastError();
  43. if (status != cudaSuccess) STARPU_CUDA_REPORT_ERROR(status);
  44. }