- m_process_t process = MSG_process_self();
- simdata_task_t task_simdata = NULL;
- e_surf_action_state_t state = SURF_ACTION_NOT_IN_THE_SYSTEM;
- m_host_t local_host = NULL;
- m_host_t remote_host = NULL;
-
- CHECK_HOST();
-
- xbt_assert1((channel>=0) && (channel < msg_global->max_channel),"Invalid channel %d",channel);
-
- task_simdata = task->simdata;
- task_simdata->sender = process;
- task_simdata->source = MSG_process_get_host(process);
- xbt_assert0(task_simdata->using==1,"Gargl!");
- task_simdata->comm = NULL;
-
- local_host = ((simdata_process_t) process->simdata)->host;
- remote_host = dest;
-
- DEBUG4("Trying to send a task (%g Mb) from %s to %s on channel %d",
- task->simdata->message_size,local_host->name, remote_host->name, channel);
-
- xbt_fifo_push(((simdata_host_t) remote_host->simdata)->
- mbox[channel], task);
-
- PAJE_COMM_START(process,task,channel);
-
- if(remote_host->simdata->sleeping[channel]) {
- DEBUG0("Somebody is listening. Let's wake him up!");
- __MSG_process_unblock(remote_host->simdata->sleeping[channel]);
- }
-
- process->simdata->put_host = dest;
- process->simdata->put_channel = channel;
- while(!(task_simdata->comm)) {
- DEBUG0("Communication not initiated yet. Let's block!");
- __MSG_process_block(-1);
- }
- DEBUG0("Registering to this communication");
- surf_workstation_resource->common_public->action_use(task_simdata->comm);
- process->simdata->put_host = NULL;
- process->simdata->put_channel = -1;
-
-
- PAJE_PROCESS_PUSH_STATE(process,"C");
-
- state=surf_workstation_resource->common_public->action_get_state(task_simdata->comm);
- while (state==SURF_ACTION_RUNNING) {
- DEBUG0("Waiting for action termination");
- __MSG_task_wait_event(process, task);
- state=surf_workstation_resource->common_public->action_get_state(task_simdata->comm);
- }
- DEBUG0("Action terminated");
- task->simdata->rate=-1.0; /* Sets the rate back to default */
-
- PAJE_PROCESS_POP_STATE(process);
-
- if(state == SURF_ACTION_DONE) {
- if(surf_workstation_resource->common_public->action_free(task_simdata->comm))
- task_simdata->comm = NULL;
- MSG_task_destroy(task);
- MSG_RETURN(MSG_OK);
- } else if(surf_workstation_resource->extension_public->get_state(local_host->simdata->host)
- == SURF_CPU_OFF) {
- if(surf_workstation_resource->common_public->action_free(task_simdata->comm))
- task_simdata->comm = NULL;
- MSG_task_destroy(task);
- MSG_RETURN(MSG_HOST_FAILURE);
- } else {
- if(surf_workstation_resource->common_public->action_free(task_simdata->comm))
- task_simdata->comm = NULL;
- MSG_task_destroy(task);
- MSG_RETURN(MSG_TRANSFER_FAILURE);
- }