forgot another new file

src/core/dependencies/task-deps.c

@@ -0,0 +1,81 @@
+/*
+ * StarPU
+ * Copyright (C) INRIA 2008-2010 (see AUTHORS file)
+ *
+ * This program 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.
+ *
+ * This program 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 <starpu.h>
+#include <common/config.h>
+#include <core/dependencies/tags.h>
+#include <core/dependencies/htable.h>
+#include <core/jobs.h>
+#include <core/task.h>
+#include <core/policies/sched_policy.h>
+#include <core/dependencies/data-concurrency.h>
+
+static cg_t *create_cg_task(unsigned ntags, job_t j)
+{
+	cg_t *cg = malloc(sizeof(cg_t));
+	STARPU_ASSERT(cg);
+
+	cg->ntags = ntags;
+	cg->remaining = ntags;
+	cg->cg_type = CG_TASK;
+
+	cg->succ.job = j;
+	j->job_successors.ndeps++;
+
+	return cg;
+}
+
+/* the job lock must be taken */
+static void _starpu_task_add_succ(job_t j, cg_t *cg)
+{
+	STARPU_ASSERT(j);
+
+	_starpu_add_successor_to_cg_list(&j->job_successors, cg);
+
+	if (j->terminated) {
+		/* the task was already completed sooner */
+		_starpu_notify_cg(cg);
+	}
+}
+
+void _starpu_notify_task_dependencies(job_t j)
+{
+	_starpu_notify_cg_list(&j->job_successors);
+}
+
+/* task depends on the tasks in task array */
+void starpu_task_declare_deps_array(struct starpu_task *task, unsigned ndeps, struct starpu_task *task_array[])
+{
+	unsigned i;
+
+	job_t job;
+
+	job = _starpu_get_job_associated_to_task(task);
+	cg_t *cg = create_cg_task(ndeps, job);
+
+	STARPU_ASSERT(ndeps != 0);
+	
+	for (i = 0; i < ndeps; i++)
+	{
+		struct starpu_task *dep_task = task_array[i];
+
+		job = _starpu_get_job_associated_to_task(dep_task);
+
+		pthread_mutex_lock(&job->sync_mutex);
+		_starpu_task_add_succ(job, cg);
+		pthread_mutex_unlock(&job->sync_mutex);
+	}
+}