communication_amount, NULL);
MSG_parallel_task_execute(ptask);
+ MSG_task_destroy(ptask);
/* There is no need to free that! */
/* free(communication_amount); */
/* free(computation_amount); */
MSG_error_t test_all(const char *platform_file)
{
MSG_error_t res = MSG_OK;
+ m_host_t *hosts;
MSG_config("workstation/model", "ptask_L07");
MSG_set_channel_number(1);
MSG_create_environment(platform_file);
- MSG_process_create("test", test, NULL, MSG_get_host_table()[0]);
+ hosts = MSG_get_host_table();
+ MSG_process_create("test", test, NULL, hosts[0]);
res = MSG_main();
+ xbt_free(hosts);
INFO1("Simulation time %g", MSG_get_clock());
return res;
execution_time = MSG_get_clock();
MSG_parallel_task_execute(task);
+ MSG_task_destroy(task);
+ xbt_free(m_host_list);
execution_time = MSG_get_clock() - execution_time;
INFO1("execution_time=%g ", execution_time);
redistribution_time = MSG_get_clock();
MSG_parallel_task_execute(task);
+ MSG_task_destroy(task);
+ xbt_free(m_host_list);
redistribution_time = MSG_get_clock() - redistribution_time;
INFO1("redistribution_time=%g ", redistribution_time);
MSG_task_set_priority(task, priority);
MSG_task_execute(task);
-
+ MSG_task_destroy(task);
INFO0("Goodbye now!");
return 0;
time = sender_time;
communication_time = time1 - time;
INFO1("Task received : %s", task_la->name);
+ xbt_free(task_la->data);
MSG_task_destroy(task_la);
INFO1("Communic. time %le", communication_time);
INFO1("--- la %f ----", communication_time);
time = sender_time;
communication_time = time1 - time;
INFO1("Task received : %s", task_bw->name);
+ xbt_free(task_bw->data);
MSG_task_destroy(task_bw);
INFO1("Communic. time %le", communication_time);
INFO1("--- bw %f ----", task_comm_size_bw / communication_time);
task = MSG_task_create("proc 0", task_comp_size, 0, NULL);
MSG_task_set_priority(task, task_prio);
MSG_task_execute(task);
+ MSG_task_destroy(task);
INFO0("Test finished");