tests: add test for lazy allocation

tests/Makefile.am

@@ -137,6 +137,7 @@ check_PROGRAMS += 				\
 	datawizard/increment_redux		\
 	datawizard/increment_redux_v2		\
 	datawizard/handle_to_pointer		\
+	datawizard/lazy_allocation		\
 	errorcheck/starpu_init_noworker		\
 	errorcheck/invalid_blocking_calls	\
 	errorcheck/invalid_tasks		\
@@ -412,6 +413,11 @@ datawizard_mpi_like_async_SOURCES +=		\
 endif
 
 testbin_PROGRAMS +=				\
+	datawizard/lazy_allocation
+datawizard_lazy_allocation_SOURCES =		\
+	datawizard/lazy_allocation.c
+
+testbin_PROGRAMS +=				\
 	errorcheck/starpu_init_noworker
 errorcheck_starpu_init_noworker_SOURCES =	\
 	errorcheck/starpu_init_noworker.c

tests/datawizard/lazy_allocation.c

@@ -0,0 +1,105 @@
+/* StarPU --- Runtime system for heterogeneous multicore architectures.
+ *
+ * Copyright (C) 2010  Université de Bordeaux 1
+ *
+ * StarPU is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation; either version 2.1 of the License, or (at
+ * your option) any later version.
+ *
+ * StarPU is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * See the GNU Lesser General Public License in COPYING.LGPL for more details.
+ */
+
+#include <stdio.h>
+#include <unistd.h>
+#include <errno.h>
+#include <starpu.h>
+#include <starpu_cuda.h>
+#include <stdlib.h>
+
+#define VECTORSIZE	1024
+#define FPRINTF(ofile, fmt, args ...) do { if (!getenv("STARPU_SSILENT")) {fprintf(ofile, fmt, ##args); }} while(0)
+
+static starpu_data_handle v_handle;
+
+/*
+ *	Memset
+ */
+
+#ifdef STARPU_USE_CUDA
+static void cuda_memset_codelet(void *descr[], __attribute__ ((unused)) void *_args)
+{
+	char *buf = (char *)STARPU_VECTOR_GET_PTR(descr[0]);
+	unsigned length = STARPU_VECTOR_GET_NX(descr[0]);
+
+	cudaMemsetAsync(buf, 42, length, starpu_cuda_get_local_stream());
+	cudaStreamSynchronize(starpu_cuda_get_local_stream());
+}
+#endif
+
+static void cpu_memset_codelet(void *descr[], __attribute__ ((unused)) void *_args)
+{
+	char *buf = (char *)STARPU_VECTOR_GET_PTR(descr[0]);
+	unsigned length = STARPU_VECTOR_GET_NX(descr[0]);
+
+	memset(buf, 42, length);
+}
+
+static starpu_codelet memset_cl = {
+	.where = STARPU_CPU|STARPU_CUDA,
+	.cpu_func = cpu_memset_codelet,
+#ifdef STARPU_USE_CUDA
+	.cuda_func = cuda_memset_codelet,
+#endif
+	.nbuffers = 1
+};
+
+/*
+ *	Check content
+ */
+
+static void check_content_codelet(void *descr[], __attribute__ ((unused)) void *_args)
+{
+	char *buf = (char *)STARPU_VECTOR_GET_PTR(descr[0]);
+	unsigned length = STARPU_VECTOR_GET_NX(descr[0]);
+
+	unsigned i;
+	for (i = 0; i < length; i++)
+	{
+		if (buf[i] != 42)
+		{
+			FPRINTF(stderr, "buf[%u] is %c while it should be %c\n", i, buf[i], 42);
+			exit(-1);
+		}
+	}
+}
+
+static starpu_codelet check_content_cl = {
+	.where = STARPU_CPU,
+	.cpu_func = check_content_codelet,
+#ifdef STARPU_USE_CUDA
+	.cuda_func = check_content_codelet,
+#endif
+	.nbuffers = 1
+};
+
+
+int main(int argc, char **argv)
+{
+	starpu_init(NULL);
+	starpu_vector_data_register(&v_handle, (uint32_t)-1, (uintptr_t)NULL, VECTORSIZE, sizeof(char));
+
+	starpu_insert_task(&memset_cl, STARPU_W, v_handle, 0);
+        starpu_task_wait_for_all();
+
+	starpu_insert_task(&check_content_cl, STARPU_R, v_handle, 0);
+        starpu_task_wait_for_all();
+
+	starpu_data_unregister(v_handle);
+	starpu_shutdown();
+	return 0;
+}