X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/16e1615dff6a9f5a19efb4861563436a638642ed..cac63707a2f233d0a979a67403336292eb2a3038:/src/smpi/smpi_sender.c?ds=sidebyside diff --git a/src/smpi/smpi_sender.c b/src/smpi/smpi_sender.c index d366d454ad..732ed78242 100644 --- a/src/smpi/smpi_sender.c +++ b/src/smpi/smpi_sender.c @@ -35,8 +35,6 @@ int smpi_sender(int argc,char*argv[]) { request_queue = smpi_global->pending_send_request_queues[index]; - smpi_global->sender_processes[index] = self; - do { request = xbt_fifo_shift(request_queue); @@ -94,11 +92,10 @@ int smpi_sender(int argc,char*argv[]) { SIMIX_mutex_unlock(request->mutex); // wake up receiver if necessary - receiver_process = smpi_global->receiver_processes[dindex]; - if (SIMIX_process_is_suspended(receiver_process)) { + smpi_host_data_t remote_host = SIMIX_host_get_data(SIMIX_process_get_host(smpi_global->main_processes[dindex])); + receiver_process = remote_host->receiver; + if (SIMIX_process_is_suspended(receiver_process)) SIMIX_process_resume(receiver_process); - } - } running_hosts_count = smpi_global->running_hosts_count;