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!");
+ "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,