tests/: add missing calls to starpu_data_unregister

tests/core/execute_on_a_specific_worker.c

@@ -128,12 +128,14 @@ int main(int argc, char **argv)
 		PTHREAD_COND_WAIT(&cond, &mutex);
 	PTHREAD_MUTEX_UNLOCK(&mutex);
 
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;
 
 enodev:
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 	fprintf(stderr, "WARNING: No one can execute this task\n");

tests/core/insert_task.c

@@ -102,6 +102,8 @@ int main(int argc, char **argv)
         }
         FPRINTF(stderr, "VALUES: %d %f\n", x, f);
 
+	starpu_data_unregister(data_handles[0]);
+	starpu_data_unregister(data_handles[1]);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;

tests/datawizard/data_implicit_deps.c

@@ -128,6 +128,11 @@ int main(int argc, char **argv)
 	ret = starpu_task_wait_for_all();
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait_for_all");
 
+	starpu_data_unregister(A_handle);
+	starpu_data_unregister(B_handle);
+	starpu_data_unregister(C_handle);
+	starpu_data_unregister(D_handle);
+
 	free(A);
 	free(B);
 	free(C);

tests/datawizard/mpi_like.c

@@ -153,6 +153,7 @@ static void *thread_func(void *arg)
 		}
 	}
 
+	starpu_data_unregister(thread_data->handle);
 	return NULL;
 }
 

tests/datawizard/mpi_like_async.c

@@ -278,6 +278,8 @@ static void *thread_func(void *arg)
 	ret = starpu_task_wait_for_all();
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait_for_all");
 
+	starpu_data_unregister(thread_data->handle);
+
 	return NULL;
 }
 

tests/errorcheck/invalid_blocking_calls.c

@@ -97,7 +97,7 @@ int main(int argc, char **argv)
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_data_acquire");
 
 	starpu_data_release(handle);
-
+	starpu_data_unregister(handle);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;

tests/helper/starpu_data_cpy.c

@@ -40,6 +40,8 @@ int main(int argc, char **argv)
 	STARPU_ASSERT(var2 == 42);
 	starpu_data_release(var2_handle);
 
+	starpu_data_unregister(var1_handle);
+	starpu_data_unregister(var2_handle);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;

tests/microbenchs/local_pingpong.c

@@ -103,6 +103,7 @@ int main(int argc, char **argv)
 	fprintf(stderr, "Took %f ms\n", timing/1000);
 	fprintf(stderr, "Avg. transfer time : %f us\n", timing/(2*niter));
 
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 

tests/microbenchs/redundant_buffer.c

@@ -81,12 +81,14 @@ int main(int argc, char **argv)
 	ret = starpu_task_wait_for_all();
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait_for_all");
 
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;
 
 enodev:
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	fprintf(stderr, "WARNING: No one can execute this task\n");
 	/* yes, we do not perform the computation but we did detect that no one

tests/microbenchs/tasks_overhead.c

@@ -148,6 +148,11 @@ int main(int argc, char **argv)
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_tag_wait");
 	gettimeofday(&end_exec, NULL);
 
+	for (buffer = 0; buffer < nbuffers; buffer++)
+	{
+		starpu_data_unregister(data_handles[buffer]);
+	}
+
 	timing_submit = (double)((end_submit.tv_sec - start_submit.tv_sec)*1000000 + (end_submit.tv_usec - start_submit.tv_usec));
 	timing_exec = (double)((end_exec.tv_sec - start_exec.tv_sec)*1000000 + (end_exec.tv_usec - start_exec.tv_usec));
 

tests/overlap/overlap.c

@@ -120,12 +120,14 @@ int main(int argc, char **argv)
 		PTHREAD_COND_WAIT(&cond, &mutex);
 	PTHREAD_MUTEX_UNLOCK(&mutex);
 
+	starpu_data_unregister(handle);
 	starpu_free(buffer);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;
 
 enodev:
+	starpu_data_unregister(handle);
 	starpu_free(buffer);
 	fprintf(stderr, "WARNING: No one can execute this task\n");
 	/* yes, we do not perform the computation but we did detect that no one

tests/parallel_tasks/explicit_combined_worker.c

@@ -96,12 +96,14 @@ int main(int argc, char **argv)
 	ret = starpu_task_wait_for_all();
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait_for_all");
 
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;
 
 enodev:
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	fprintf(stderr, "WARNING: No one can execute this task\n");
 	/* yes, we do not perform the computation but we did detect that no one

tests/parallel_tasks/parallel_kernels.c

@@ -99,12 +99,14 @@ int main(int argc, char **argv)
 	ret = starpu_task_wait_for_all();
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait_for_all");
 
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;
 
 enodev:
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	fprintf(stderr, "WARNING: No one can execute this task\n");
 	/* yes, we do not perform the computation but we did detect that no one

tests/parallel_tasks/parallel_kernels_spmd.c

@@ -101,11 +101,13 @@ int main(int argc, char **argv)
 	ret = starpu_task_wait_for_all();
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait_for_all");
 
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 	return EXIT_SUCCESS;
 
 enodev:
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	fprintf(stderr, "WARNING: No one can execute this task\n");
 	/* yes, we do not perform the computation but we did detect that no one

tests/parallel_tasks/spmd_pgreedy.c

@@ -85,12 +85,14 @@ int main(int argc, char **argv)
 	ret = starpu_task_wait_for_all();
 	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_wait_for_all");
 
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	starpu_shutdown();
 
 	return EXIT_SUCCESS;
 
 enodev:
+	starpu_data_unregister(v_handle);
 	starpu_free(v);
 	fprintf(stderr, "WARNING: No one can execute this task\n");
 	/* yes, we do not perform the computation but we did detect that no one