mpir_request_complete.c

刚才是说明 现在是安装程序在 LINUX环境下进行编程的MPICH安装文件

/* -*- Mode: C; c-basic-offset:4 ; -*- */
/*
 *
 *  (C) 2001 by Argonne National Laboratory.
 *      See COPYRIGHT in top-level directory.
 */

#include "mpiimpl.h"

int MPIR_Request_complete(MPI_Request * request, MPID_Request * request_ptr,
			  MPI_Status * status, int * active)
{
    int mpi_errno = MPI_SUCCESS;

    *active = TRUE;
    switch(request_ptr->kind)
    {
	case MPID_REQUEST_SEND:
	case MPID_REQUEST_RECV:
	{
	    if (request_ptr->status.MPI_ERROR != MPI_SUCCESS)
	    {
		mpi_errno = request_ptr->status.MPI_ERROR;
	    }

	    if (status != MPI_STATUS_IGNORE)
	    {
		*status = request_ptr->status;
	    }
	    
	    *request = MPI_REQUEST_NULL;
	    MPID_Request_release(request_ptr);
	    break;
	}
			
	case MPID_PREQUEST_SEND:
	case MPID_PREQUEST_RECV:
	{
	    if (request_ptr->partner_request != NULL)
	    {
		MPID_Request * prequest_ptr;

		prequest_ptr = request_ptr->partner_request;
		request_ptr->cc = 0;
		request_ptr->cc_ptr = &request_ptr->cc;
		request_ptr->partner_request = NULL;
		
		if (prequest_ptr->status.MPI_ERROR != MPI_SUCCESS)
		{
		    mpi_errno = prequest_ptr->status.MPI_ERROR;
		}
			    
		if (status != MPI_STATUS_IGNORE)
		{
		    *status = prequest_ptr->status;
		}
	    
		MPID_Request_release(prequest_ptr);
	    }
	    else
	    {
		if (request_ptr->status.MPI_ERROR != MPI_SUCCESS)
		{
		    /* if the persistent request failed to start then make the
		       error code available */
		    if (status != MPI_STATUS_IGNORE)
		    {
			*status = request_ptr->status;
		    }
		}
		else
		{
		    *active = FALSE;
		    MPIR_Status_set_empty(status);
		}
	    }
	    
	    break;
	}

	case MPID_UREQUEST:
	{
	    int rc;
	    
	    if (request_ptr->status.MPI_ERROR != MPI_SUCCESS)
	    {
		mpi_errno = request_ptr->status.MPI_ERROR;
	    }
			    
	    rc = (request_ptr->query_fn)(request_ptr->grequest_extra_state,
					 &request_ptr->status);
	    if (request_ptr->status.MPI_ERROR == MPI_SUCCESS)
	    {
		request_ptr->status.MPI_ERROR = rc;
		mpi_errno = rc;
	    }
	    else
	    {
		mpi_errno = request_ptr->status.MPI_ERROR;
	    }
	    
	    rc = (request_ptr->free_fn)(request_ptr->grequest_extra_state);
	    if (request_ptr->status.MPI_ERROR == MPI_SUCCESS)
	    {
		request_ptr->status.MPI_ERROR = rc;
		mpi_errno = rc;
	    }
	    
	    if (status != MPI_STATUS_IGNORE)
	    {
		*status = request_ptr->status;
	    }
	    
	    MPID_Request_release(request_ptr);
	    *request = MPI_REQUEST_NULL;
	    break;
	}
    }

    return mpi_errno;
}