task_simdata->sender = process;
task_simdata->source = MSG_process_get_host(process);
xbt_assert0(task_simdata->using==1,
- "This taks is still being used somewhere else. You cannot send it now. Go fix your code!");
+ "This task is still being used somewhere else. You cannot send it now. Go fix your code!");
task_simdata->comm = NULL;
local_host = ((simdata_process_t) process->simdata)->host;
while(!(task_simdata->comm)) {
if(max_duration>0) {
if(!first_time) {
+ xbt_fifo_remove(((simdata_host_t) remote_host->simdata)->mbox[channel],
+ task);
PAJE_PROCESS_POP_STATE(process);
PAJE_COMM_STOP(process,task,channel);
MSG_RETURN(MSG_TRANSFER_FAILURE);
simdata = task->simdata;
xbt_assert0((!simdata->compute)&&(task->simdata->using==1),
- "This taks is executed somewhere else. Go fix your code!");
- task->simdata->using++;
+ "This task is executed somewhere else. Go fix your code!");
+ simdata->using++;
simdata->compute = surf_workstation_resource->extension_public->
execute(MSG_process_get_host(process)->simdata->host,
simdata->computation_amount);
set_priority(simdata->compute, simdata->priority);
surf_workstation_resource->common_public->action_set_data(simdata->compute,task);
- task->simdata->using--;
+ simdata->using--;
}
MSG_error_t __MSG_wait_for_computation(m_process_t process, m_task_t task)