2004-01-25 02:17:43 +03:00
|
|
|
/*
|
2007-03-17 02:11:45 +03:00
|
|
|
* Copyright (c) 2004-2007 The Trustees of Indiana University and Indiana
|
2005-11-05 22:57:48 +03:00
|
|
|
* 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.
|
2008-02-12 11:46:27 +03:00
|
|
|
* Copyright (c) 2004-2008 High Performance Computing Center Stuttgart,
|
2004-11-28 23:09:25 +03:00
|
|
|
* University of Stuttgart. All rights reserved.
|
2005-03-24 15:43:37 +03:00
|
|
|
* Copyright (c) 2004-2005 The Regents of the University of California.
|
|
|
|
* All rights reserved.
|
2008-08-06 16:16:54 +04:00
|
|
|
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
2004-11-22 04:38:40 +03:00
|
|
|
* $COPYRIGHT$
|
|
|
|
*
|
|
|
|
* Additional copyrights may follow
|
|
|
|
*
|
2004-01-25 02:17:43 +03:00
|
|
|
* $HEADER$
|
|
|
|
*/
|
|
|
|
|
2004-06-07 19:33:53 +04:00
|
|
|
#include "ompi_config.h"
|
2004-01-25 02:17:43 +03:00
|
|
|
|
2006-02-12 04:33:29 +03:00
|
|
|
#include "ompi/mpi/c/bindings.h"
|
2009-04-29 05:32:14 +04:00
|
|
|
#include "ompi/runtime/params.h"
|
|
|
|
#include "ompi/errhandler/errhandler.h"
|
- Split the datatype engine into two parts: an MPI specific part in
OMPI
and a language agnostic part in OPAL. The convertor is completely
moved into OPAL. This offers several benefits as described in RFC
http://www.open-mpi.org/community/lists/devel/2009/07/6387.php
namely:
- Fewer basic types (int* and float* types, boolean and wchar
- Fixing naming scheme to ompi-nomenclature.
- Usability outside of the ompi-layer.
- Due to the fixed nature of simple opal types, their information is
completely
known at compile time and therefore constified
- With fewer datatypes (22), the actual sizes of bit-field types may be
reduced
from 64 to 32 bits, allowing reorganizing the opal_datatype
structure, eliminating holes and keeping data required in convertor
(upon send/recv) in one cacheline...
This has implications to the convertor-datastructure and other parts
of the code.
- Several performance tests have been run, the netpipe latency does not
change with
this patch on Linux/x86-64 on the smoky cluster.
- Extensive tests have been done to verify correctness (no new
regressions) using:
1. mpi_test_suite on linux/x86-64 using clean ompi-trunk and
ompi-ddt:
a. running both trunk and ompi-ddt resulted in no differences
(except for MPI_SHORT_INT and MPI_TYPE_MIX_LB_UB do now run
correctly).
b. with --enable-memchecker and running under valgrind (one buglet
when run with static found in test-suite, commited)
2. ibm testsuite on linux/x86-64 using clean ompi-trunk and ompi-ddt:
all passed (except for the dynamic/ tests failed!! as trunk/MTT)
3. compilation and usage of HDF5 tests on Jaguar using PGI and
PathScale compilers.
4. compilation and usage on Scicortex.
- Please note, that for the heterogeneous case, (-m32 compiled
binaries/ompi), neither
ompi-trunk, nor ompi-ddt branch would successfully launch.
This commit was SVN r21641.
2009-07-13 08:56:31 +04:00
|
|
|
#include "ompi/datatype/ompi_datatype.h"
|
2005-09-12 13:17:44 +04:00
|
|
|
#include "ompi/file/file.h"
|
|
|
|
#include "ompi/mca/io/io.h"
|
|
|
|
#include "ompi/mca/io/base/io_base_request.h"
|
2008-02-12 21:01:17 +03:00
|
|
|
#include "ompi/memchecker.h"
|
2004-01-25 02:17:43 +03:00
|
|
|
|
2009-05-07 00:11:28 +04:00
|
|
|
#if OPAL_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
|
2004-01-25 02:17:43 +03:00
|
|
|
#pragma weak MPI_File_iwrite_at = PMPI_File_iwrite_at
|
|
|
|
#endif
|
|
|
|
|
2004-06-07 19:33:53 +04:00
|
|
|
#if OMPI_PROFILING_DEFINES
|
2006-02-12 04:33:29 +03:00
|
|
|
#include "ompi/mpi/c/profile/defines.h"
|
2004-04-20 22:50:43 +04:00
|
|
|
#endif
|
|
|
|
|
2004-07-30 06:58:53 +04:00
|
|
|
static const char FUNC_NAME[] = "MPI_File_iwrite_at";
|
|
|
|
|
|
|
|
|
2004-02-12 07:21:05 +03:00
|
|
|
int MPI_File_iwrite_at(MPI_File fh, MPI_Offset offset, void *buf,
|
|
|
|
int count, MPI_Datatype datatype,
|
2004-07-30 06:58:53 +04:00
|
|
|
MPI_Request *request)
|
|
|
|
{
|
2004-09-14 14:55:10 +04:00
|
|
|
int rc;
|
2008-02-20 01:15:52 +03:00
|
|
|
|
2008-02-12 11:46:27 +03:00
|
|
|
MEMCHECKER(
|
|
|
|
memchecker_datatype(datatype);
|
|
|
|
memchecker_call(&opal_memchecker_base_isdefined, buf, count, datatype);
|
|
|
|
);
|
2007-03-17 02:11:45 +03:00
|
|
|
|
2004-09-14 14:55:10 +04:00
|
|
|
if (MPI_PARAM_CHECK) {
|
|
|
|
rc = MPI_SUCCESS;
|
|
|
|
OMPI_ERR_INIT_FINALIZE(FUNC_NAME);
|
|
|
|
if (ompi_file_invalid(fh)) {
|
|
|
|
fh = MPI_FILE_NULL;
|
|
|
|
rc = MPI_ERR_FILE;
|
|
|
|
} else if (count < 0) {
|
|
|
|
rc = MPI_ERR_COUNT;
|
Clean up request handling in the I/O framework to be more consistent with
other request-using frameworks.
- Rather than having mpi/c/* functions allocate requests explicitly,
pass the MPI_Request* down to the I/O component and have it
perform the allocation.
- While the I/O base provides a base request which can be used,
it is not required and all request management occurs within
the component.
- Push progress management into the component, rather than having it
happen in the base. Progress functions are now easily registered,
and not all (ie, the one existing) components use progress functions
in any rational way.
ROMIO switched to generalized requests instead of MPIO_Requests many
moons ago, and Open MPI now uses ROMIO's generalized requests, so there
is no reason to wrap those requests (which are OMPI requests) in another
level of request.
Now the file function passes the MPI_Request* to the ROMIO component,
which passes it to the underlying ROMIO function, which calls
MPI_Grequest_start to create an OMPI request, which is what gets set
as the request to the user. Much cleaner.
This patch has two motivations. One, a whole heck of a lot of code
just got removed, and request handling is now much cleaner for I/O
components. Two, by adding support for Argonne's proposed generalized
request extensions, we can allow ROMIO to provide async I/O through
generalized requests, which we couldn't rationally do in the old
setup due to the crazy request completion rules.
This commit was SVN r22235.
2009-11-26 08:13:43 +03:00
|
|
|
} else if (NULL == request) {
|
|
|
|
rc = MPI_ERR_REQUEST;
|
2004-09-14 14:55:10 +04:00
|
|
|
} else {
|
|
|
|
OMPI_CHECK_DATATYPE_FOR_SEND(rc, datatype, count);
|
|
|
|
}
|
|
|
|
OMPI_ERRHANDLER_CHECK(rc, fh, rc, FUNC_NAME);
|
|
|
|
}
|
2004-07-30 06:58:53 +04:00
|
|
|
|
2008-02-20 01:15:52 +03:00
|
|
|
OPAL_CR_ENTER_LIBRARY();
|
|
|
|
|
2004-09-14 14:55:10 +04:00
|
|
|
/* Call the back-end io component function */
|
|
|
|
switch (fh->f_io_version) {
|
2008-08-06 16:16:54 +04:00
|
|
|
case MCA_IO_BASE_V_2_0_0:
|
|
|
|
rc = fh->f_io_selected_module.v2_0_0.
|
2004-09-14 14:55:10 +04:00
|
|
|
io_module_file_iwrite_at(fh, offset, buf, count, datatype,
|
Clean up request handling in the I/O framework to be more consistent with
other request-using frameworks.
- Rather than having mpi/c/* functions allocate requests explicitly,
pass the MPI_Request* down to the I/O component and have it
perform the allocation.
- While the I/O base provides a base request which can be used,
it is not required and all request management occurs within
the component.
- Push progress management into the component, rather than having it
happen in the base. Progress functions are now easily registered,
and not all (ie, the one existing) components use progress functions
in any rational way.
ROMIO switched to generalized requests instead of MPIO_Requests many
moons ago, and Open MPI now uses ROMIO's generalized requests, so there
is no reason to wrap those requests (which are OMPI requests) in another
level of request.
Now the file function passes the MPI_Request* to the ROMIO component,
which passes it to the underlying ROMIO function, which calls
MPI_Grequest_start to create an OMPI request, which is what gets set
as the request to the user. Much cleaner.
This patch has two motivations. One, a whole heck of a lot of code
just got removed, and request handling is now much cleaner for I/O
components. Two, by adding support for Argonne's proposed generalized
request extensions, we can allow ROMIO to provide async I/O through
generalized requests, which we couldn't rationally do in the old
setup due to the crazy request completion rules.
This commit was SVN r22235.
2009-11-26 08:13:43 +03:00
|
|
|
request);
|
2004-09-14 14:55:10 +04:00
|
|
|
break;
|
|
|
|
|
|
|
|
default:
|
|
|
|
rc = MPI_ERR_INTERN;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* All done */
|
|
|
|
|
|
|
|
OMPI_ERRHANDLER_RETURN(rc, fh, rc, FUNC_NAME);
|
2004-01-25 02:17:43 +03:00
|
|
|
}
|