From 377ac7d3e14671c3feb8074eeb6db36f9667bac5 Mon Sep 17 00:00:00 2001
From: Martin Quinson <martin.quinson@loria.fr>
Date: Wed, 19 Oct 2011 21:47:23 +0200
Subject: [PATCH] first prealpha not working prototype (please public keep
 away) version of what could be a GOAL loader using simdag

---
 buildtools/Cmake/MakeExe.cmake      |  1 +
 examples/simdag/goal/CMakeLists.txt | 12 +++++
 examples/simdag/goal/goal_test.c    | 82 +++++++++++++++++++++++++++++
 3 files changed, 95 insertions(+)
 create mode 100644 examples/simdag/goal/CMakeLists.txt
 create mode 100644 examples/simdag/goal/goal_test.c

diff --git a/buildtools/Cmake/MakeExe.cmake b/buildtools/Cmake/MakeExe.cmake
index ed00683542..da26f94bba 100644
--- a/buildtools/Cmake/MakeExe.cmake
+++ b/buildtools/Cmake/MakeExe.cmake
@@ -78,6 +78,7 @@ add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/amok/saturate)
 
 add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/simdag)
 add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/simdag/dax)
+add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/simdag/goal)
 if(HAVE_GRAPHVIZ)
   add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/simdag/dot)
 endif(HAVE_GRAPHVIZ)
diff --git a/examples/simdag/goal/CMakeLists.txt b/examples/simdag/goal/CMakeLists.txt
new file mode 100644
index 0000000000..941fc7d548
--- /dev/null
+++ b/examples/simdag/goal/CMakeLists.txt
@@ -0,0 +1,12 @@
+cmake_minimum_required(VERSION 2.6)
+
+set(EXECUTABLE_OUTPUT_PATH "${CMAKE_CURRENT_BINARY_DIR}")
+
+add_executable(goal_test goal_test.c)
+
+### Add definitions for compile
+if(NOT WIN32)
+target_link_libraries(goal_test simgrid pthread m )
+else(NOT WIN32)
+target_link_libraries(goal_test simgrid)
+endif(NOT WIN32)
diff --git a/examples/simdag/goal/goal_test.c b/examples/simdag/goal/goal_test.c
new file mode 100644
index 0000000000..4f1ddf5912
--- /dev/null
+++ b/examples/simdag/goal/goal_test.c
@@ -0,0 +1,82 @@
+/* GOAL loader prototype. Not ready for public usage yet */
+
+/* Copyright (c) 2011. The SimGrid Team.
+ * All rights reserved.                                                     */
+
+/* This program is free software; you can redistribute it and/or modify it
+ * under the terms of the license (GNU LGPL) which comes with this package. */
+
+#include <stdlib.h>
+#include <stdio.h>
+#include "simdag/simdag.h"
+#include "xbt/log.h"
+#include "xbt/ex.h"
+#include <string.h>
+
+XBT_LOG_NEW_DEFAULT_CATEGORY(goal, "The GOAL loader into SimDag");
+
+typedef struct {
+  int i, j, k;
+} s_bcast_task_t,*bcast_task_t;
+
+
+const SD_workstation_t* ws_list;
+int count = 0;
+
+static void send_one(int from, int to) {
+  //XBT_DEBUG("send_one(%d, %d)",from,to);
+
+  if (count %1000 == 0)
+    XBT_INFO("Sending task #%d",count);
+  count++;
+
+  bcast_task_t bt = xbt_new(s_bcast_task_t,1);
+
+  bt->i=from;
+  bt->j=(from+to)/2;
+  bt->k=to;
+
+  SD_task_t t = SD_task_create_comm_e2e("Blab",bt,424242);
+  XBT_DEBUG("Schedule task between %d and %d",bt->i,bt->j);
+  SD_task_schedulel(t,2,ws_list[bt->i],ws_list[bt->j]);
+  SD_task_watch(t,SD_DONE);
+}
+
+int main(int argc, char **argv) {
+
+  /* initialization of SD */
+  SD_init(&argc, argv);
+
+  if (argc > 1) {
+    SD_create_environment(argv[1]);
+  } else {
+    SD_create_environment("../../platforms/One_cluster_no_backbone.xml");
+  }
+
+  ws_list = SD_workstation_get_list();
+  xbt_dynar_t done = NULL;
+  send_one(0,10000);
+  do {
+    if (done != NULL && xbt_dynar_length(done) > 0) {
+      unsigned int cursor;
+      SD_task_t task;
+
+      xbt_dynar_foreach(done, cursor, task) {
+        bcast_task_t bt = SD_task_get_data(task);
+
+        if (bt->i != bt->j -1)
+          send_one(bt->i,bt->j);
+        if (bt->j != bt->k -1)
+          send_one(bt->j,bt->k);
+
+        SD_task_destroy(task);
+        free(bt);
+      }
+      xbt_dynar_free(&done);
+    }
+    done=SD_simulate(-1);
+  } while(xbt_dynar_length(done) > 0);
+
+  SD_exit();
+  return 0;
+}
-- 
2.20.1