From: mquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Date: Tue, 6 Oct 2009 21:22:35 +0000 (+0000)
Subject: Automatically schedule E2E comms placed before and after sequential computations... 
X-Git-Tag: SVN~980
X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/13518d08d37880df7fa8eab8404f47e8a7a3a25c

Automatically schedule E2E comms placed before and after sequential computations when the latter get scheduled

git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@6733 48e7efb5-ca39-0410-a469-dd3cf9ba447f
---

diff --git a/src/simdag/sd_task.c b/src/simdag/sd_task.c
index 9538594c0a..7c5bc156d4 100644
--- a/src/simdag/sd_task.c
+++ b/src/simdag/sd_task.c
@@ -1232,6 +1232,28 @@ void SD_task_schedulev(SD_task_t task, int count, const SD_workstation_t*list) {
     xbt_die(bprintf("Kind of task %s not supported by SD_task_schedulev()",
           SD_task_get_name(task)));
   }
+  /* Iterate over all childs and parent being COMM_E2E to say where I am located (and start them if ready) */
+  if (task->kind == SD_TASK_COMP_SEQ) {
+    SD_dependency_t dep;
+    unsigned int cpt;
+    xbt_dynar_foreach(task->tasks_before,cpt,dep) {
+      SD_task_t before = dep->src;
+      if (before->kind == SD_TASK_COMM_E2E) {
+        before->workstation_list[1] = task->workstation_list[0];
+        if (before->workstation_list[0])
+          SD_task_do_schedule(before);
+      }
+    }
+    xbt_dynar_foreach(task->tasks_after,cpt,dep) {
+      SD_task_t after = dep->dst;
+      if (after->kind == SD_TASK_COMM_E2E) {
+        after->workstation_list[0] = task->workstation_list[0];
+        if (after->workstation_list[1])
+          SD_task_do_schedule(after);
+      }
+    }
+
+  }
 }
 /** @brief autoschedule a task on a list of workstations
  *