- t_simdata->using++;
- /* create SIMIX action to the communication */
- t_simdata->comm = SIMIX_action_communicate(t_simdata->sender->simdata->host->simdata->host,
- process->simdata->host->simdata->host,t->name, t_simdata->message_size,
- t_simdata->rate);
- /* if the process is suspend, create the action but stop its execution, it will be restart when the sender process resume */
- if (MSG_process_is_suspended(t_simdata->sender)) {
- DEBUG1("Process sender (%s) suspended", t_simdata->sender->name);
- SIMIX_action_set_priority(t_simdata->comm,0);
- }
- process->simdata->waiting_task = t;
- SIMIX_register_action_to_condition(t_simdata->comm, t_simdata->cond);
- SIMIX_register_condition_to_action(t_simdata->comm, t_simdata->cond);
- SIMIX_cond_wait(t_simdata->cond,t_simdata->mutex);
- process->simdata->waiting_task = NULL;
-
- /* the task has already finished and the pointer must be null*/
- if (t->simdata->sender) {
- t->simdata->sender->simdata->waiting_task = NULL;
- /* action ended, set comm and compute = NULL, the actions is already destroyed in the main function */
- //t->simdata->comm = NULL;
- //t->simdata->compute = NULL;
+ /* create SIMIX action to the communication */
+ t_simdata->comm =
+ SIMIX_action_communicate(t_simdata->sender->simdata->m_host->
+ simdata->smx_host,
+ process->simdata->m_host->simdata->smx_host,
+ t->name, t_simdata->message_size,
+ t_simdata->rate);
+ /* if the process is suspend, create the action but stop its execution, it will be restart when the sender process resume */
+ if (MSG_process_is_suspended(t_simdata->sender)) {
+ DEBUG1("Process sender (%s) suspended", t_simdata->sender->name);
+ SIMIX_action_set_priority(t_simdata->comm, 0);
+ }
+ process->simdata->waiting_task = t;
+ SIMIX_register_action_to_condition(t_simdata->comm, t_simdata->cond);
+ while (1) {
+ SIMIX_cond_wait(t_simdata->cond, t_simdata->mutex);
+ if (SIMIX_action_get_state(t_simdata->comm) != SURF_ACTION_RUNNING)
+ break;