|
@@ -1,7 +1,7 @@
|
|
|
/* StarPU --- Runtime system for heterogeneous multicore architectures.
|
|
|
*
|
|
|
* Copyright (C) 2011,2012,2014 Inria
|
|
|
- * Copyright (C) 2011-2016 Université de Bordeaux
|
|
|
+ * Copyright (C) 2011-2016,2019 Université de Bordeaux
|
|
|
* Copyright (C) 2011-2017 CNRS
|
|
|
* Copyright (C) 2011 Télécom-SudParis
|
|
|
*
|
|
@@ -49,6 +49,19 @@ static void memset_cuda(void *descr[], void *arg)
|
|
|
extern void memset_opencl(void *buffers[], void *args);
|
|
|
#endif
|
|
|
|
|
|
+void memset0_cpu(void *descr[], void *arg)
|
|
|
+{
|
|
|
+ (void)arg;
|
|
|
+ STARPU_SKIP_IF_VALGRIND;
|
|
|
+
|
|
|
+ int *ptr = (int *)STARPU_VECTOR_GET_PTR(descr[0]);
|
|
|
+ unsigned n = STARPU_VECTOR_GET_NX(descr[0]);
|
|
|
+ unsigned i;
|
|
|
+
|
|
|
+ for (i = 0; i < n; i++)
|
|
|
+ ptr[i] = 42;
|
|
|
+}
|
|
|
+
|
|
|
void memset_cpu(void *descr[], void *arg)
|
|
|
{
|
|
|
(void)arg;
|
|
@@ -57,6 +70,7 @@ void memset_cpu(void *descr[], void *arg)
|
|
|
int *ptr = (int *)STARPU_VECTOR_GET_PTR(descr[0]);
|
|
|
unsigned n = STARPU_VECTOR_GET_NX(descr[0]);
|
|
|
|
|
|
+ usleep(10);
|
|
|
memset(ptr, 42, n * sizeof(*ptr));
|
|
|
}
|
|
|
|
|
@@ -82,8 +96,8 @@ static struct starpu_codelet memset_cl =
|
|
|
.opencl_funcs = {memset_opencl},
|
|
|
.opencl_flags = {STARPU_OPENCL_ASYNC},
|
|
|
#endif
|
|
|
- .cpu_funcs = {memset_cpu},
|
|
|
- .cpu_funcs_name = {"memset_cpu"},
|
|
|
+ .cpu_funcs = {memset0_cpu, memset_cpu},
|
|
|
+ .cpu_funcs_name = {"memset0_cpu", "memset_cpu"},
|
|
|
.model = &model,
|
|
|
.nbuffers = 1,
|
|
|
.modes = {STARPU_W}
|
|
@@ -99,8 +113,8 @@ static struct starpu_codelet nl_memset_cl =
|
|
|
.opencl_funcs = {memset_opencl},
|
|
|
.opencl_flags = {STARPU_OPENCL_ASYNC},
|
|
|
#endif
|
|
|
- .cpu_funcs = {memset_cpu},
|
|
|
- .cpu_funcs_name = {"memset_cpu"},
|
|
|
+ .cpu_funcs = {memset0_cpu, memset_cpu},
|
|
|
+ .cpu_funcs_name = {"memset0_cpu", "memset_cpu"},
|
|
|
.model = &nl_model,
|
|
|
.nbuffers = 1,
|
|
|
.modes = {STARPU_W}
|
|
@@ -158,7 +172,7 @@ int main(int argc, char **argv)
|
|
|
|
|
|
starpu_conf_init(&conf);
|
|
|
|
|
|
- conf.sched_policy_name = "eager";
|
|
|
+ conf.sched_policy_name = "dmda";
|
|
|
conf.calibrate = 2;
|
|
|
|
|
|
ret = starpu_initialize(&conf, &argc, &argv);
|