coll_utils.c

fortran并行计算包

/*  (C)Copyright IBM Corp.  2007, 2008  */
/**
 * \file src/coll/coll_utils.c
 * \brief ???
 */

#include "mpido_coll.h"

int MPIDI_ConvertMPItoDCMF(MPI_Op op, DCMF_Op *dcmf_op,
                           MPI_Datatype datatype, DCMF_Dt *dcmf_dt)
{
   int rc = 0;

   switch(op)
   {
      case MPI_SUM:
         *dcmf_op = DCMF_SUM;
         break;
      case MPI_PROD:
         if(datatype == MPI_COMPLEX || datatype == MPI_DOUBLE_COMPLEX)
            return -1;
         *dcmf_op = DCMF_PROD;
         rc = NOTTREEOP;
         break;
      case MPI_MAX:
         *dcmf_op = DCMF_MAX;
         break;
      case MPI_MIN:
         *dcmf_op = DCMF_MIN;
         break;
      case MPI_LAND: /* orange book, page 231 */
         if(datatype == MPI_LOGICAL || datatype == MPI_INT ||
            datatype == MPI_INTEGER || datatype == MPI_LONG ||
            datatype == MPI_UNSIGNED|| datatype == MPI_UNSIGNED_LONG)
         {
            *dcmf_op = DCMF_LAND;
         	 rc = NOTTREEOP;
         }
         else return -1;
         break;
      case MPI_LOR:
         if(datatype == MPI_LOGICAL || datatype == MPI_INT ||
            datatype == MPI_INTEGER || datatype == MPI_LONG ||
            datatype == MPI_UNSIGNED|| datatype == MPI_UNSIGNED_LONG)
         {
            *dcmf_op = DCMF_LOR;
         	 rc = NOTTREEOP;
         }
         else return -1;
         break;
      case MPI_LXOR:
         if(datatype == MPI_LOGICAL || datatype == MPI_INT ||
            datatype == MPI_INTEGER || datatype == MPI_LONG ||
            datatype == MPI_UNSIGNED|| datatype == MPI_UNSIGNED_LONG)
         {
            *dcmf_op = DCMF_LXOR;
         	 rc = NOTTREEOP;
         }
         else return -1;
         break;
      case MPI_BAND:
         if(datatype == MPI_LONG || datatype == MPI_INTEGER ||
            datatype == MPI_BYTE || datatype == MPI_UNSIGNED ||
            datatype == MPI_INT  || datatype == MPI_UNSIGNED_LONG)
         {
            *dcmf_op = DCMF_BAND;
         }
         else return -1;
         break;
      case MPI_BOR:
         if(datatype == MPI_LONG || datatype == MPI_INTEGER ||
            datatype == MPI_BYTE || datatype == MPI_UNSIGNED ||
            datatype == MPI_INT  || datatype == MPI_UNSIGNED_LONG)
         {
            *dcmf_op = DCMF_BOR;
         }
         else return -1;
         break;
      case MPI_BXOR:
         if(datatype == MPI_LONG || datatype == MPI_INTEGER ||
            datatype == MPI_BYTE || datatype == MPI_UNSIGNED ||
            datatype == MPI_INT  || datatype == MPI_UNSIGNED_LONG)
         {
            *dcmf_op = DCMF_BXOR;
         }
         else return -1;
         break;
      case MPI_MAXLOC:
         *dcmf_op = DCMF_MAXLOC;
         break;
      case MPI_MINLOC:
         *dcmf_op = DCMF_MINLOC;
         break;
      default:
         *dcmf_dt = DCMF_UNDEFINED_DT;
         *dcmf_op = DCMF_UNDEFINED_OP;
         return -1;
   }
   int rc_tmp = rc;
   switch(datatype)
   {
      case MPI_CHAR:
      case MPI_SIGNED_CHAR:
      case MPI_CHARACTER:
         *dcmf_dt = DCMF_SIGNED_CHAR;
         return NOTTREEOP;
         break;

      case MPI_UNSIGNED_CHAR:
      case MPI_BYTE:
         *dcmf_dt = DCMF_UNSIGNED_CHAR;
         return NOTTREEOP;
         break;

      case MPI_INT:
      case MPI_INTEGER:
      case MPI_LONG:
         *dcmf_dt = DCMF_SIGNED_INT;
         break;

      case MPI_UNSIGNED:
      case MPI_UNSIGNED_LONG:
         *dcmf_dt = DCMF_UNSIGNED_INT;
         break;

      case MPI_SHORT:
         *dcmf_dt = DCMF_SIGNED_SHORT;
         break;

      case MPI_UNSIGNED_SHORT:
         *dcmf_dt = DCMF_UNSIGNED_SHORT;
         break;


      case MPI_FLOAT:
      case MPI_REAL:
         *dcmf_dt = DCMF_FLOAT;
         if(op != MPI_MAX || op != MPI_MIN )
            return NOTTREEOP;
         break;

      case MPI_DOUBLE:
      case MPI_DOUBLE_PRECISION:
         *dcmf_dt = DCMF_DOUBLE;
         break;

      case MPI_LONG_DOUBLE:
         *dcmf_dt = DCMF_LONG_DOUBLE;
         if(op == MPI_LAND || op == MPI_LOR || op == MPI_LXOR)
            return -1;
         return NOTTREEOP;
         break;

      case MPI_LONG_LONG:
         *dcmf_dt = DCMF_UNSIGNED_LONG_LONG;
         break;

      case MPI_DOUBLE_COMPLEX:
         *dcmf_dt = DCMF_DOUBLE_COMPLEX;
         return NOTTREEOP;
         break;

      case MPI_COMPLEX:
         *dcmf_dt = DCMF_SINGLE_COMPLEX;
         return NOTTREEOP;
         break;

      case MPI_LOGICAL:
         *dcmf_dt = DCMF_LOGICAL;
         break;

      case MPI_FLOAT_INT:
         *dcmf_dt = DCMF_LOC_FLOAT_INT;
         break;

      case MPI_DOUBLE_INT:
         *dcmf_dt = DCMF_LOC_DOUBLE_INT;
         break;

      case MPI_LONG_INT:
      case MPI_2INT:
      case MPI_2INTEGER:
         *dcmf_dt = DCMF_LOC_2INT;
         break;

      case MPI_SHORT_INT:
         *dcmf_dt = DCMF_LOC_SHORT_INT;
         break;

      case MPI_2REAL:
         *dcmf_dt = DCMF_LOC_2FLOAT;
         break;

      case MPI_2DOUBLE_PRECISION:
         *dcmf_dt = DCMF_LOC_2DOUBLE;
         break;

      default:
         *dcmf_dt = DCMF_UNDEFINED_DT;
         *dcmf_op = DCMF_UNDEFINED_OP;
         return -1;
   }
   if(rc_tmp ==NOTTREEOP)
     return rc_tmp;
   return rc;
}