/* * Copyright (c) 2004-2007 The Trustees of Indiana University and Indiana * University Research and Technology * Corporation. All rights reserved. * Copyright (c) 2004-2005 The University of Tennessee and The University * of Tennessee Research Foundation. All rights * reserved. * Copyright (c) 2004-2008 High Performance Computing Center Stuttgart, * University of Stuttgart. All rights reserved. * Copyright (c) 2004-2005 The Regents of the University of California. * All rights reserved. * Copyright (c) 2006 Cisco Systems, Inc. All rights reserved. * $COPYRIGHT$ * * Additional copyrights may follow * * $HEADER$ */ #include "ompi_config.h" #include #include "ompi/mpi/c/bindings.h" #include "ompi/runtime/params.h" #include "ompi/communicator/communicator.h" #include "ompi/errhandler/errhandler.h" #include "ompi/datatype/ompi_datatype.h" #include "opal/datatype/opal_convertor.h" #include "ompi/memchecker.h" #if OPAL_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES #pragma weak MPI_Pack_external = PMPI_Pack_external #endif #if OMPI_PROFILING_DEFINES #include "ompi/mpi/c/profile/defines.h" #endif static const char FUNC_NAME[] = "MPI_Pack_external"; int MPI_Pack_external(char *datarep, void *inbuf, int incount, MPI_Datatype datatype, void *outbuf, MPI_Aint outsize, MPI_Aint *position) { int rc; opal_convertor_t local_convertor; struct iovec invec; unsigned int iov_count; size_t size; MEMCHECKER( memchecker_datatype(datatype); memchecker_call(&opal_memchecker_base_isdefined, inbuf, incount, datatype); ); if (MPI_PARAM_CHECK) { OMPI_ERR_INIT_FINALIZE(FUNC_NAME); if ((NULL == outbuf) || (NULL == position)) { /* inbuf can be MPI_BOTTOM */ return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG, FUNC_NAME); } else if (incount < 0) { return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COUNT, FUNC_NAME); } else if (outsize < 0) { return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG, FUNC_NAME); } else if (MPI_DATATYPE_NULL == datatype || NULL == datatype) { return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_TYPE, FUNC_NAME); } } OPAL_CR_ENTER_LIBRARY(); OBJ_CONSTRUCT(&local_convertor, opal_convertor_t); /* The resulting convertor will be set to the position zero. We have to use * CONVERTOR_SEND_CONVERSION in order to force the convertor to do anything * more than just packing the data. */ opal_convertor_copy_and_prepare_for_send( ompi_mpi_external32_convertor, &(datatype->super), incount, inbuf, CONVERTOR_SEND_CONVERSION, &local_convertor ); /* Check for truncation */ opal_convertor_get_packed_size( &local_convertor, &size ); if( (*position + size) > (size_t)outsize ) { /* we can cast as we already checked for < 0 */ OBJ_DESTRUCT( &local_convertor ); OPAL_CR_EXIT_LIBRARY(); return OMPI_ERRHANDLER_INVOKE( MPI_COMM_WORLD, MPI_ERR_TRUNCATE, FUNC_NAME ); } /* Prepare the iovec with all informations */ invec.iov_base = (char*) outbuf + (*position); invec.iov_len = size; /* Do the actual packing */ iov_count = 1; rc = opal_convertor_pack( &local_convertor, &invec, &iov_count, &size ); *position += size; OBJ_DESTRUCT( &local_convertor ); /* All done. Note that the convertor returns 1 upon success, not OMPI_SUCCESS. */ OMPI_ERRHANDLER_RETURN((rc == 1) ? OMPI_SUCCESS : OMPI_ERROR, MPI_COMM_WORLD, MPI_ERR_UNKNOWN, FUNC_NAME); }