-static void compute(xbt_dynar_t action) {
- char *name=xbt_str_join(action," ");
- char *amout=xbt_dynar_get_as(action,2,char*);
- m_task_t task = MSG_task_create(name, atoi(amout), 0, NULL);
- INFO1("computing: %s",name);
- MSG_task_execute(task);
- MSG_task_destroy(task);
- INFO1("computed: %s",name);
+
+static int spawned_recv(int argc, char *argv[])
+{
+ m_task_t task = NULL;
+ char* name = (char *) MSG_process_get_data(MSG_process_self());
+ INFO1("Receiving on %s", name);
+ MSG_task_receive(&task, name);
+ INFO1("Received %s", MSG_task_get_name(task));
+ MSG_task_send(MSG_task_create("waiter",0,0,NULL),MSG_process_self()->name);
+
+ MSG_task_destroy(task);
+ return 0;
+}
+
+
+static void Irecv(xbt_dynar_t action)
+{
+ char *name = xbt_str_join(action, " ");
+ m_process_t comm_helper;
+
+ INFO1("Irecv on %s: spawn process ",
+ MSG_process_get_name(MSG_process_self()));
+
+ sprintf(name,"%s_wait",MSG_process_self()->name);
+ comm_helper = MSG_process_create(name,spawned_recv,
+ (void *) MSG_process_get_name(MSG_process_self()),
+ MSG_host_self());
+
+
+ free(name);
+}
+
+
+static void wait(xbt_dynar_t action)
+{
+ char *name = xbt_str_join(action, " ");
+ char task_name[80];
+ m_task_t task = NULL;
+
+ INFO1("wait: %s", name);
+ sprintf(task_name,"%s_wait",MSG_process_self()->name);
+ MSG_task_receive(&task,task_name);
+ INFO1("waited: %s", name);
+ free(name);
+}
+
+static void barrier (xbt_dynar_t action)
+{
+ char *name = xbt_str_join(action, " ");
+ INFO1("barrier: %s", name);
+
+
+ free(name);
+
+}
+static void sleep(xbt_dynar_t action)
+{
+ char *name = xbt_str_join(action, " ");
+ char *duration = xbt_dynar_get_as(action, 2, char *);
+ INFO1("sleep: %s", name);
+ MSG_process_sleep(parse_double(duration));
+ INFO1("sleept: %s", name);
+ free(name);
+}
+
+static void compute(xbt_dynar_t action)
+{
+ char *name = xbt_str_join(action, " ");
+ char *amout = xbt_dynar_get_as(action, 2, char *);
+ m_task_t task = MSG_task_create(name, parse_double(amout), 0, NULL);
+ INFO1("computing: %s", name);
+ MSG_task_execute(task);
+ MSG_task_destroy(task);
+ INFO1("computed: %s", name);
+ free(name);