* 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(test,
"Logging specific to this SimDag example");
unsigned int cursor;
SD_task_t task;
+ /* initialisation of SD */
+ SD_init(&argc, argv);
+
+ /* Check our arguments */
if (argc < 3) {
INFO1("Usage: %s platform_file dax_file", argv[0]);
INFO1("example: %s ../sd_platform.xml Montage_50.xml", argv[0]);
dax=SD_daxload(argv[2]);
/* Display all the tasks */
+ INFO0("------------------- Display all tasks of the loaded DAG ---------------------------");
+ xbt_dynar_foreach(dax,cursor,task) {
+ SD_task_dump(task);
+ }
+
+ FILE *dotout = fopen("dax.dot","w");
+ fprintf(dotout,"digraph A {\n");
+ xbt_dynar_foreach(dax,cursor,task) {
+ SD_task_dotty(task,dotout);
+ }
+ fprintf(dotout,"}\n");
+ fclose(dotout);
+
+ /* Schedule them all on the first workstation */
+ INFO0("------------------- Schedule tasks ---------------------------");
+ const SD_workstation_t *ws_list = SD_workstation_get_list();
+ int count = SD_workstation_get_number();
xbt_dynar_foreach(dax,cursor,task) {
+ if (SD_task_get_kind(task) == SD_TASK_COMP_SEQ) {
+ if (!strcmp(SD_task_get_name(task),"end"))
+ SD_task_schedulel(task,1,ws_list[0]);
+ else
+ SD_task_schedulel(task,1,ws_list[cursor%count]);
+ }
+ }
+
+ INFO0("------------------- Run the schedule ---------------------------");
+ SD_simulate(-1);
+ INFO0("------------------- Produce the trace file---------------------------");
+ char *last=strrchr(argv[2],'.');
+ char *filename=bprintf("%.*s.trace",last==NULL?strlen(argv[2]):last-argv[2],argv[2]);
+ INFO1("Producing the trace of the run into %s",filename);
+ FILE*out = fopen(filename,"w");
+ xbt_assert1(out,"Cannot write to %s",filename);
+ free(filename);
+
+ xbt_dynar_foreach(dax,cursor,task) {
+ int kind = SD_task_get_kind(task);
+ SD_workstation_t *wsl = SD_task_get_workstation_list(task);
+ switch (kind) {
+ case SD_TASK_COMP_SEQ:
+ fprintf(out,"[%f] %s compute %f # %s\n",SD_task_get_start_time(task),
+ SD_workstation_get_name(wsl[0]),SD_task_get_amount(task),
+ SD_task_get_name(task));
+ break;
+ case SD_TASK_COMM_E2E:
+ fprintf(out,"[%f] %s send %s %f # %s\n",SD_task_get_start_time(task),
+ SD_workstation_get_name(wsl[0]),SD_workstation_get_name(wsl[1]),
+ SD_task_get_amount(task), SD_task_get_name(task));
+ fprintf(out,"[%f] %s recv %s %f # %s\n",SD_task_get_start_time(task),
+ SD_workstation_get_name(wsl[1]),SD_workstation_get_name(wsl[0]),
+ SD_task_get_amount(task), SD_task_get_name(task));
+ break;
+ default:
+ xbt_die(bprintf("Task %s is of unknown kind %d",SD_task_get_name(task),SD_task_get_kind(task)));
+ }
}
+ fclose(out);
+
/* exit */
SD_exit();
return 1;