From 55eda6695068477d25d74cfa9335f79ad5a9b826 Mon Sep 17 00:00:00 2001 From: Christian Heinrich Date: Tue, 26 May 2015 14:42:17 +0200 Subject: [PATCH] [SMPI] Just some cosmetics (indentation), no changes --- src/smpi/smpi_base.c | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/src/smpi/smpi_base.c b/src/smpi/smpi_base.c index 76e98d8406..84edb27fe1 100644 --- a/src/smpi/smpi_base.c +++ b/src/smpi/smpi_base.c @@ -873,31 +873,31 @@ void smpi_mpi_iprobe(int source, int tag, MPI_Comm comm, int* flag, MPI_Status* print_request("New iprobe", request); // We have to test both mailboxes as we don't know if we will receive one one or another - if (sg_cfg_get_int("smpi/async_small_thres")>0){ - mailbox = smpi_process_mailbox_small(); - XBT_DEBUG("trying to probe the perm recv mailbox"); - request->action = simcall_comm_iprobe(mailbox, 0, request->src, request->tag, &match_recv, (void*)request); - } - if (request->action==NULL){ - mailbox = smpi_process_mailbox(); - XBT_DEBUG("trying to probe the other mailbox"); - request->action = simcall_comm_iprobe(mailbox, 0, request->src,request->tag, &match_recv, (void*)request); - } + if (sg_cfg_get_int("smpi/async_small_thres")>0){ + mailbox = smpi_process_mailbox_small(); + XBT_DEBUG("trying to probe the perm recv mailbox"); + request->action = simcall_comm_iprobe(mailbox, 0, request->src, request->tag, &match_recv, (void*)request); + } + if (request->action==NULL){ + mailbox = smpi_process_mailbox(); + XBT_DEBUG("trying to probe the other mailbox"); + request->action = simcall_comm_iprobe(mailbox, 0, request->src,request->tag, &match_recv, (void*)request); + } - if(request->action){ + if (request->action){ MPI_Request req = (MPI_Request)SIMIX_comm_get_src_data(request->action); *flag = 1; if(status != MPI_STATUS_IGNORE && !(req->flags & PREPARED)) { status->MPI_SOURCE = smpi_group_rank(smpi_comm_group(comm), req->src); - status->MPI_TAG = req->tag; - status->MPI_ERROR = MPI_SUCCESS; - status->count = req->real_size; + status->MPI_TAG = req->tag; + status->MPI_ERROR = MPI_SUCCESS; + status->count = req->real_size; } nsleeps=1;//reset the number of sleeps we will do next time } else { - *flag = 0; - nsleeps++; + *flag = 0; + nsleeps++; } smpi_mpi_request_free(&request); -- 2.20.1