smx_host_t dhost;
- char communication[] = "communication";
smx_action_t action;
smpi_received_message_t message;
SIMIX_mutex_lock(request->mutex);
message->comm = request->comm;
- message->src = smpi_mpi_comm_rank(request->comm);
+ message->src = request->comm->index_to_rank_map[index];
message->tag = request->tag;
message->data = request->data;
message->buf = xbt_malloc(request->datatype->size * request->count);
request->completed = 1;
}
- action = SIMIX_action_communicate(shost, dhost, communication, request->datatype->size * request->count, -1.0);
+ action = SIMIX_action_communicate(shost, dhost, "communication", request->datatype->size * request->count, -1.0);
SIMIX_register_action_to_condition(action, request->cond);
SIMIX_cond_wait(request->cond, request->mutex);