[mpich-discuss] Error with MPI_Register_datarep

[Éric Chamberland]

Hi,

Here is my little test program.

Almost the same as chapter 9.1 of the book " Using MPI-2: Advanced 
Features of the Message-Passing Interface" from  William Gropp, Ewing 
Lusk, and Rajeev Thakur.

Thanks,

Eric


Le 16-03-09 22:39, Éric Chamberland a écrit :
> Hi,
>
> I am trying to use the MPI_Register_datarep functionnality with 
> mpich-3.2, but while executing, I have this error:
>
> ERROR Returned by MPI: 67148823
> ERROR_string Returned by MPI: An error occurred in a user-defined data 
> conversion function, error stack:
> MPI_REGISTER_DATAREP(108): Read and Write datarep conversions are 
> currently not supported by MPI-IO
> application called MPI_Abort(MPI_COMM_WORLD, 1) - process 0
>
> I have configured mpich-3.2 with: ./configure 
> --prefix=/opt/mpich-3.2_ch3sock --with-device=ch3:sock
>
> Is there anything I have to do to be able to use this functionality?
>
> Thanks,
>
> Eric
>
> _______________________________________________
> discuss mailing list     discuss at mpich.org
> To manage subscription options or unsubscribe:
> https://lists.mpich.org/mailman/listinfo/discuss

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.mpich.org/pipermail/discuss/attachments/20160310/b7b7be34/attachment.html>
-------------- next part --------------
#include <iostream>
#include "mpi.h"
#include <unistd.h>
#include <limits.h>
#include <fcntl.h>

void abortOnError(int ierr) {
  if (ierr != MPI_SUCCESS) {
    printf("ERROR Returned by MPI: %d\n",ierr);
    char* lCharPtr = new char[MPI_MAX_ERROR_STRING];
    int lLongueur = 0;
    MPI_Error_string(ierr,lCharPtr, &lLongueur);
    printf("ERROR_string Returned by MPI: %s\n",lCharPtr);
    MPI_Abort( MPI_COMM_WORLD, 1 );
  }
}

namespace PAIO {

int calculeExtentInt64VsInt32(MPI_Datatype pDataType,
MPI_Aint *pFileExtent,
void *pExtraState)
{
    int lReponse = MPI_ERR_TYPE;
    if (pDataType == MPI_LONG_INT) {
        lReponse = 8;
    }
    return lReponse;
}

int conversionLectureInt64VersInt32(void* pUserBuf,
MPI_Datatype pDataType,
int pCount,
void *pFileBuf,
MPI_Offset pPosition,
void* pExtraState)
{
    if (pDataType != MPI_LONG_INT) {
        return MPI_ERR_TYPE;
    }

    //ici byte_swap pas nécessaire...

    // Conversion du int64 en int32:
    for (int i = 0; i < pCount; ++i) {
        ((int*) pUserBuf)[pPosition+i] = ((long long int*) pFileBuf)[i];
    }
    return MPI_SUCCESS;
}

int conversionEcritureInt32VersInt64(void* pUserBuf,
MPI_Datatype pDataType,
int pCount,
void *pFileBuf,
MPI_Offset pPosition,
void* pExtraState)
{
    if (pDataType != MPI_LONG_INT) {
        return MPI_ERR_TYPE;
    }

    // Conversion du int32 en int64:
    for (int i = 0; i < pCount; ++i) {
        ((long long int*) pFileBuf)[i] = ((int*) pUserBuf)[pPosition+i];
    }

    //ici byte_swap pas nécessaire...

    return MPI_SUCCESS;
}

}

int main (int argc, char *argv[])
{

  MPI_Init( &argc, &argv );

  int nb_proc = 0;
  MPI_Comm_size( MPI_COMM_WORLD, &nb_proc );

  //Appelle l'enregistrement d'un nouveau "datarep":

  abortOnError(MPI_Register_datarep("int64",
  PAIO::conversionLectureInt64VersInt32,
  PAIO::conversionEcritureInt32VersInt64,
  PAIO::calculeExtentInt64VsInt32,
  NULL));

  MPI_Finalize();

  return 0;
}
-------------- next part --------------
_______________________________________________
discuss mailing list     discuss at mpich.org
To manage subscription options or unsubscribe:
https://lists.mpich.org/mailman/listinfo/discuss