lazy_unregister.c 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2010, 2011, 2012 Centre National de la Recherche Scientifique
  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 <config.h>
  17. #include <starpu.h>
  18. #include <stdlib.h>
  19. #include <unistd.h>
  20. #include "../helper.h"
  21. static void dummy_func(void ** buffers, void * args)
  22. {
  23. (void) buffers;
  24. (void) args;
  25. }
  26. static struct starpu_codelet dummy_cl =
  27. {
  28. .modes = { STARPU_RW },
  29. .cpu_funcs = { dummy_func, NULL },
  30. .nbuffers = 1
  31. };
  32. int main(void)
  33. {
  34. int ret;
  35. int buffer[1024];
  36. starpu_data_handle_t handle;
  37. struct starpu_task *t1,*t2;
  38. ret = starpu_init(NULL);
  39. if (ret == -ENODEV)
  40. return STARPU_TEST_SKIPPED;
  41. STARPU_CHECK_RETURN_VALUE(ret, "starpu_init");
  42. starpu_variable_data_register(&handle, STARPU_MAIN_RAM, (uintptr_t)buffer, 1024*sizeof(int));
  43. t1 = starpu_task_create();
  44. t2 = starpu_task_create();
  45. t2->cl = &dummy_cl;
  46. t2->detach = 0;
  47. t2->handles[0] = handle;
  48. starpu_task_declare_deps_array(t2, 1, &t1);
  49. ret = starpu_task_submit(t2);
  50. if (ret == -ENODEV)
  51. return STARPU_TEST_SKIPPED;
  52. STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_submit");
  53. starpu_data_unregister_submit(handle);
  54. ret = starpu_task_submit(t1);
  55. if (ret == -ENODEV)
  56. return STARPU_TEST_SKIPPED;
  57. STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_submit");
  58. ret = starpu_task_wait(t2);
  59. if (ret == -ENODEV)
  60. return STARPU_TEST_SKIPPED;
  61. STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait");
  62. while (starpu_data_lookup(buffer) != NULL)
  63. usleep(100000);
  64. starpu_shutdown();
  65. return EXIT_SUCCESS;
  66. }