1
1

- In case of MPI_REQUEST_NULL, set the *status to the empty_status,

by copying structure:

   psendrecv.c:81
   4e7:   cmpl   $0x0,0x34(%ebp)           4e7:   cmpl   $0x0,0x34(%ebp)
   4eb:   je     51e <PMPI_Sendrecv+0x51e> 4eb:   je     517 <PMPI_Sendrecv+0x517>
   psendrecv.c:85
   4ed:   mov    0x34(%ebp),%eax           4ed:   mov    0x34(%ebp),%edx
   4f0:   movl   $0xfffffffe,(%eax)        4f0:   mov    0x38,%eax
   psendrecv.c:86                          4f5:   mov    %eax,(%edx)
   4f6:   mov    0x34(%ebp),%eax           4f7:   mov    0x3c,%eax
   4f9:   movl   $0xffffffff,0x4(%eax)     4fc:   mov    %eax,0x4(%edx)
   psendrecv.c:87                          4ff:   mov    0x40,%eax
   500:   mov    0x34(%ebp),%eax           504:   mov    %eax,0x8(%edx)
   503:   movl   $0x0,0x8(%eax)            507:   mov    0x44,%eax
   psendrecv.c:88                          50c:   mov    %eax,0xc(%edx)
   50a:   mov    0x34(%ebp),%eax           50f:   mov    0x48,%eax
   50d:   movl   $0x0,0xc(%eax)            514:   mov    %eax,0x10(%edx)
   psendrecv.c:89
   514:   mov    0x34(%ebp),%eax
   517:   movl   $0x0,0x10(%eax)
   psendrecv.c:91

This commit was SVN r17230.
Этот коммит содержится в:
Rainer Keller 2008-01-25 12:58:59 +00:00
родитель 3f94d6a494
Коммит 2b4975de8e
5 изменённых файлов: 11 добавлений и 28 удалений

Просмотреть файл

@ -20,6 +20,7 @@
#include "ompi/mpi/c/bindings.h" #include "ompi/mpi/c/bindings.h"
#include "ompi/mca/pml/pml.h" #include "ompi/mca/pml/pml.h"
#include "ompi/request/request.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES #if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Iprobe = PMPI_Iprobe #pragma weak MPI_Iprobe = PMPI_Iprobe
@ -32,7 +33,7 @@
static const char FUNC_NAME[] = "MPI_Iprobe"; static const char FUNC_NAME[] = "MPI_Iprobe";
int MPI_Iprobe(int source, int tag, MPI_Comm comm, int *flag, MPI_Status *status) int MPI_Iprobe(int source, int tag, MPI_Comm comm, int *flag, MPI_Status *status)
{ {
int rc; int rc;
@ -54,12 +55,8 @@ int MPI_Iprobe(int source, int tag, MPI_Comm comm, int *flag, MPI_Status *status
} }
if (MPI_PROC_NULL == source) { if (MPI_PROC_NULL == source) {
if (status) { if (MPI_STATUS_IGNORE != status) {
status->MPI_SOURCE = MPI_PROC_NULL; *status = ompi_request_empty.req_status;
status->MPI_TAG = MPI_ANY_TAG;
status->MPI_ERROR = MPI_SUCCESS;
status->_count = 0;
status->_cancelled = 0;
} }
return MPI_SUCCESS; return MPI_SUCCESS;
} }

Просмотреть файл

@ -20,6 +20,7 @@
#include "ompi/mpi/c/bindings.h" #include "ompi/mpi/c/bindings.h"
#include "ompi/mca/pml/pml.h" #include "ompi/mca/pml/pml.h"
#include "ompi/request/request.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES #if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Probe = PMPI_Probe #pragma weak MPI_Probe = PMPI_Probe
@ -54,12 +55,8 @@ int MPI_Probe(int source, int tag, MPI_Comm comm, MPI_Status *status)
} }
if (MPI_PROC_NULL == source) { if (MPI_PROC_NULL == source) {
if (status) { if (MPI_STATUS_IGNORE != status) {
status->MPI_SOURCE = MPI_PROC_NULL; *status = ompi_request_empty.req_status;
status->MPI_TAG = MPI_ANY_TAG;
status->MPI_ERROR = MPI_SUCCESS;
status->_count = 0;
status->_cancelled = 0;
} }
return MPI_SUCCESS; return MPI_SUCCESS;
} }

Просмотреть файл

@ -20,6 +20,7 @@
#include "ompi/mpi/c/bindings.h" #include "ompi/mpi/c/bindings.h"
#include "ompi/mca/pml/pml.h" #include "ompi/mca/pml/pml.h"
#include "ompi/request/request.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES #if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Recv = PMPI_Recv #pragma weak MPI_Recv = PMPI_Recv
@ -59,11 +60,7 @@ int MPI_Recv(void *buf, int count, MPI_Datatype type, int source,
if (MPI_PROC_NULL == source) { if (MPI_PROC_NULL == source) {
if (MPI_STATUS_IGNORE != status) { if (MPI_STATUS_IGNORE != status) {
status->MPI_SOURCE = MPI_PROC_NULL; *status = ompi_request_empty.req_status;
status->MPI_TAG = MPI_ANY_TAG;
status->MPI_ERROR = MPI_SUCCESS;
status->_count = 0;
status->_cancelled = 0;
} }
return MPI_SUCCESS; return MPI_SUCCESS;
} }

Просмотреть файл

@ -79,11 +79,7 @@ int MPI_Sendrecv(void *sendbuf, int sendcount, MPI_Datatype sendtype,
rc = ompi_request_wait(&req, status); rc = ompi_request_wait(&req, status);
} else { } else {
if (MPI_STATUS_IGNORE != status) { if (MPI_STATUS_IGNORE != status) {
status->MPI_SOURCE = MPI_PROC_NULL; *status = ompi_request_empty.req_status;
status->MPI_TAG = MPI_ANY_TAG;
status->MPI_ERROR = MPI_SUCCESS;
status->_count = 0;
status->_cancelled = 0;
} }
rc = MPI_SUCCESS; rc = MPI_SUCCESS;
} }

Просмотреть файл

@ -50,11 +50,7 @@ int MPI_Wait(MPI_Request *request, MPI_Status *status)
if (MPI_REQUEST_NULL == *request) { if (MPI_REQUEST_NULL == *request) {
if (MPI_STATUS_IGNORE != status) { if (MPI_STATUS_IGNORE != status) {
status->MPI_SOURCE = MPI_PROC_NULL; *status = ompi_request_empty.req_status;
status->MPI_TAG = MPI_ANY_TAG;
status->MPI_ERROR = MPI_SUCCESS;
status->_count = 0;
status->_cancelled = 0;
} }
return MPI_SUCCESS; return MPI_SUCCESS;
} }