io: do not cast way the const modifier when this is not necessary
update the io framework and mpi c bindings
Этот коммит содержится в:
Gilles Gouaillardet
родитель
e01bac962f
Коммит
fe351f6801
@ -91,7 +91,7 @@ int ompi_file_init(void)
|
||||
/*
|
||||
* Back end to MPI_FILE_OPEN
|
||||
*/
|
||||
int ompi_file_open(struct ompi_communicator_t *comm, char *filename,
|
||||
int ompi_file_open(struct ompi_communicator_t *comm, const char *filename,
|
||||
int amode, struct ompi_info_t *info, ompi_file_t **fh)
|
||||
{
|
||||
int ret;
|
||||
|
||||
@ -12,6 +12,8 @@
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2009 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2009-2012 Cisco Systems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -145,7 +147,7 @@ int ompi_file_init(void);
|
||||
* mainly calls OBJ_RELEASE() but also does some other error
|
||||
* handling as well.
|
||||
*/
|
||||
int ompi_file_open(struct ompi_communicator_t *comm, char *filename,
|
||||
int ompi_file_open(struct ompi_communicator_t *comm, const char *filename,
|
||||
int amode, struct ompi_info_t *info,
|
||||
ompi_file_t **fh);
|
||||
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2014 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -56,7 +58,7 @@ int mca_fcoll_dynamic_file_read_all (mca_io_ompio_file_t *fh,
|
||||
|
||||
|
||||
int mca_fcoll_dynamic_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -48,7 +50,7 @@ static int local_heap_sort (mca_io_ompio_local_io_array *io_array,
|
||||
|
||||
int
|
||||
mca_fcoll_dynamic_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -126,14 +128,14 @@ typedef int (*mca_fcoll_base_module_file_iread_all_fn_t)
|
||||
|
||||
typedef int (*mca_fcoll_base_module_file_write_all_fn_t)
|
||||
(struct mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
|
||||
typedef int (*mca_fcoll_base_module_file_iwrite_all_fn_t)
|
||||
(struct mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2014 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -56,7 +58,7 @@ int mca_fcoll_individual_file_read_all (mca_io_ompio_file_t *fh,
|
||||
|
||||
|
||||
int mca_fcoll_individual_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -30,7 +32,7 @@
|
||||
|
||||
|
||||
int mca_fcoll_individual_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -55,7 +57,7 @@ int mca_fcoll_static_file_read_all (mca_io_ompio_file_t *fh,
|
||||
|
||||
|
||||
int mca_fcoll_static_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
|
||||
@ -11,7 +11,8 @@
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Los Alamos National Security, LLC. All rights reserved.
|
||||
*
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -58,7 +59,7 @@ int get_process_id (int rank,
|
||||
|
||||
int
|
||||
mca_fcoll_static_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2014 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -56,7 +58,7 @@ int mca_fcoll_two_phase_file_read_all (mca_io_ompio_file_t *fh,
|
||||
|
||||
|
||||
int mca_fcoll_two_phase_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
|
||||
@ -53,7 +53,7 @@ typedef struct flat_list_node {
|
||||
|
||||
/* local function declarations */
|
||||
static int two_phase_exch_and_write(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
MPI_Datatype datatype,
|
||||
mca_io_ompio_access_array_t *others_req,
|
||||
struct iovec *offset_len,
|
||||
@ -69,7 +69,7 @@ static int two_phase_exch_and_write(mca_io_ompio_file_t *fh,
|
||||
|
||||
|
||||
static int two_phase_exchage_data(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
char *write_buf,
|
||||
struct iovec *offset_length,
|
||||
int *send_size, int *start_pos,
|
||||
@ -92,7 +92,7 @@ static int two_phase_exchage_data(mca_io_ompio_file_t *fh,
|
||||
|
||||
|
||||
static int two_phase_fill_send_buffer(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
Flatlist_node *flat_buf,
|
||||
char **send_buf,
|
||||
struct iovec *offset_length,
|
||||
@ -138,7 +138,7 @@ double exch_write = 0.0, start_exch = 0.0, end_exch = 0.0;
|
||||
|
||||
int
|
||||
mca_fcoll_two_phase_file_write_all (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -577,7 +577,7 @@ exit :
|
||||
|
||||
|
||||
static int two_phase_exch_and_write(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
MPI_Datatype datatype,
|
||||
mca_io_ompio_access_array_t *others_req,
|
||||
struct iovec *offset_len,
|
||||
@ -923,7 +923,7 @@ exit:
|
||||
}
|
||||
|
||||
static int two_phase_exchage_data(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
char *write_buf,
|
||||
struct iovec *offset_length,
|
||||
int *send_size,int *start_pos,
|
||||
@ -1253,7 +1253,7 @@ exit:
|
||||
|
||||
|
||||
static int two_phase_fill_send_buffer(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
Flatlist_node *flat_buf,
|
||||
char **send_buf,
|
||||
struct iovec *offset_length,
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -107,7 +109,7 @@ typedef int (*mca_fs_base_module_finalize_1_0_0_fn_t)
|
||||
(struct mca_io_ompio_file_t *file);
|
||||
|
||||
typedef int (*mca_fs_base_module_file_open_fn_t)(
|
||||
struct ompi_communicator_t *comm, char *filename, int amode,
|
||||
struct ompi_communicator_t *comm, const char *filename, int amode,
|
||||
struct ompi_info_t *info, struct mca_io_ompio_file_t *fh);
|
||||
typedef int (*mca_fs_base_module_file_close_fn_t)(struct mca_io_ompio_file_t *fh);
|
||||
typedef int (*mca_fs_base_module_file_delete_fn_t)(
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -56,7 +58,7 @@ OMPI_MODULE_DECLSPEC extern mca_fs_base_component_2_0_0_t mca_fs_lustre_componen
|
||||
*/
|
||||
|
||||
int mca_fs_lustre_file_open (struct ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -55,7 +57,7 @@ static void *alloc_lum()
|
||||
|
||||
int
|
||||
mca_fs_lustre_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int access_mode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -49,7 +51,7 @@ OMPI_MODULE_DECLSPEC extern mca_fs_base_component_2_0_0_t mca_fs_plfs_component;
|
||||
*/
|
||||
|
||||
int mca_fs_plfs_file_open (struct ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2014 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -40,7 +42,7 @@
|
||||
*/
|
||||
int
|
||||
mca_fs_plfs_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int access_mode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -66,7 +68,7 @@ OMPI_MODULE_DECLSPEC extern mca_fs_base_component_2_0_0_t mca_fs_pvfs2_component
|
||||
*/
|
||||
|
||||
int mca_fs_pvfs2_file_open (struct ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2014 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -41,7 +43,7 @@ struct open_status_s {
|
||||
typedef struct open_status_s open_status;
|
||||
|
||||
static void fake_an_open(PVFS_fs_id id,
|
||||
char *pvfs2_name,
|
||||
const char *pvfs2_name,
|
||||
int access_mode,
|
||||
int stripe_width,
|
||||
PVFS_size stripe_size,
|
||||
@ -56,7 +58,7 @@ static void fake_an_open(PVFS_fs_id id,
|
||||
*/
|
||||
int
|
||||
mca_fs_pvfs2_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int access_mode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh)
|
||||
@ -184,7 +186,7 @@ mca_fs_pvfs2_file_open (struct ompi_communicator_t *comm,
|
||||
}
|
||||
|
||||
static void fake_an_open(PVFS_fs_id id,
|
||||
char *pvfs2_name,
|
||||
const char *pvfs2_name,
|
||||
int access_mode,
|
||||
int stripe_width,
|
||||
PVFS_size stripe_size,
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -46,7 +48,7 @@ OMPI_MODULE_DECLSPEC extern mca_fs_base_component_2_0_0_t mca_fs_ufs_component;
|
||||
*/
|
||||
|
||||
int mca_fs_ufs_file_open (struct ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2014 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -38,7 +40,7 @@
|
||||
*/
|
||||
int
|
||||
mca_fs_ufs_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int access_mode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008 Cisco Systems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -154,10 +156,10 @@ BEGIN_C_DECLS
|
||||
* the available components (rather than some pre-selected
|
||||
* module). See io.h for details.
|
||||
*/
|
||||
OMPI_DECLSPEC int mca_io_base_delete(char *filename,
|
||||
OMPI_DECLSPEC int mca_io_base_delete(const char *filename,
|
||||
struct ompi_info_t *info);
|
||||
|
||||
OMPI_DECLSPEC int mca_io_base_register_datarep(char *,
|
||||
OMPI_DECLSPEC int mca_io_base_register_datarep(const char *,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_extent_function*,
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -50,19 +52,19 @@ typedef struct avail_io_t avail_io_t;
|
||||
* Local functions
|
||||
*/
|
||||
static opal_list_t *check_components(opal_list_t *components,
|
||||
char *filename, struct ompi_info_t *info,
|
||||
const char *filename, struct ompi_info_t *info,
|
||||
char **names, int num_names);
|
||||
static avail_io_t *check_one_component(const mca_base_component_t *component,
|
||||
char *filename, struct ompi_info_t *info);
|
||||
const char *filename, struct ompi_info_t *info);
|
||||
|
||||
static avail_io_t *query(const mca_base_component_t *component,
|
||||
char *filename, struct ompi_info_t *info);
|
||||
const char *filename, struct ompi_info_t *info);
|
||||
static avail_io_t *query_2_0_0(const mca_io_base_component_2_0_0_t *io_component,
|
||||
char *filename, struct ompi_info_t *info);
|
||||
const char *filename, struct ompi_info_t *info);
|
||||
|
||||
static void unquery(avail_io_t *avail, char *filename, struct ompi_info_t *info);
|
||||
static void unquery(avail_io_t *avail, const char *filename, struct ompi_info_t *info);
|
||||
|
||||
static int delete_file(avail_io_t *avail, char *filename, struct ompi_info_t *info);
|
||||
static int delete_file(avail_io_t *avail, const char *filename, struct ompi_info_t *info);
|
||||
|
||||
|
||||
/*
|
||||
@ -73,7 +75,7 @@ static OBJ_CLASS_INSTANCE(avail_io_t, opal_list_item_t, NULL, NULL);
|
||||
|
||||
/*
|
||||
*/
|
||||
int mca_io_base_delete(char *filename, struct ompi_info_t *info)
|
||||
int mca_io_base_delete(const char *filename, struct ompi_info_t *info)
|
||||
{
|
||||
int err;
|
||||
opal_list_t *selectable;
|
||||
@ -178,7 +180,7 @@ static int avail_io_compare (opal_list_item_t **itema,
|
||||
* priority order.
|
||||
*/
|
||||
static opal_list_t *check_components(opal_list_t *components,
|
||||
char *filename, struct ompi_info_t *info,
|
||||
const char *filename, struct ompi_info_t *info,
|
||||
char **names, int num_names)
|
||||
{
|
||||
int i;
|
||||
@ -247,7 +249,7 @@ static opal_list_t *check_components(opal_list_t *components,
|
||||
* Check a single component
|
||||
*/
|
||||
static avail_io_t *check_one_component(const mca_base_component_t *component,
|
||||
char *filename, struct ompi_info_t *info)
|
||||
const char *filename, struct ompi_info_t *info)
|
||||
{
|
||||
avail_io_t *avail;
|
||||
|
||||
@ -280,7 +282,7 @@ static avail_io_t *check_one_component(const mca_base_component_t *component,
|
||||
* module struct
|
||||
*/
|
||||
static avail_io_t *query(const mca_base_component_t *component,
|
||||
char *filename, struct ompi_info_t *info)
|
||||
const char *filename, struct ompi_info_t *info)
|
||||
{
|
||||
const mca_io_base_component_2_0_0_t *ioc_200;
|
||||
|
||||
@ -301,7 +303,7 @@ static avail_io_t *query(const mca_base_component_t *component,
|
||||
|
||||
|
||||
static avail_io_t *query_2_0_0(const mca_io_base_component_2_0_0_t *component,
|
||||
char *filename, struct ompi_info_t *info)
|
||||
const char *filename, struct ompi_info_t *info)
|
||||
{
|
||||
bool usable;
|
||||
int priority, ret;
|
||||
@ -331,7 +333,7 @@ static avail_io_t *query_2_0_0(const mca_io_base_component_2_0_0_t *component,
|
||||
* Unquery functions
|
||||
**************************************************************************/
|
||||
|
||||
static void unquery(avail_io_t *avail, char *filename, struct ompi_info_t *info)
|
||||
static void unquery(avail_io_t *avail, const char *filename, struct ompi_info_t *info)
|
||||
{
|
||||
const mca_io_base_component_2_0_0_t *ioc_200;
|
||||
|
||||
@ -356,7 +358,7 @@ static void unquery(avail_io_t *avail, char *filename, struct ompi_info_t *info)
|
||||
/*
|
||||
* Invoke the component's delete function
|
||||
*/
|
||||
static int delete_file(avail_io_t *avail, char *filename, struct ompi_info_t *info)
|
||||
static int delete_file(avail_io_t *avail, const char *filename, struct ompi_info_t *info)
|
||||
{
|
||||
const mca_io_base_component_2_0_0_t *ioc_200;
|
||||
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -27,7 +29,7 @@
|
||||
|
||||
|
||||
int
|
||||
mca_io_base_register_datarep(char *datarep,
|
||||
mca_io_base_register_datarep(const char *datarep,
|
||||
MPI_Datarep_conversion_function* read_fn,
|
||||
MPI_Datarep_conversion_function* write_fn,
|
||||
MPI_Datarep_extent_function* extent_fn,
|
||||
|
||||
@ -14,6 +14,8 @@
|
||||
* Copyright (c) 2015 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -87,18 +89,18 @@ typedef int (*mca_io_base_component_file_unquery_fn_t)
|
||||
(struct ompi_file_t *file, struct mca_io_base_file_t *private_data);
|
||||
|
||||
typedef int (*mca_io_base_component_file_delete_query_fn_t)
|
||||
(char *filename, struct ompi_info_t *info,
|
||||
(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t **private_data,
|
||||
bool *usable, int *priority);
|
||||
typedef int (*mca_io_base_component_file_delete_select_fn_t)
|
||||
(char *filename, struct ompi_info_t *info,
|
||||
(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t *private_data);
|
||||
typedef int (*mca_io_base_component_file_delete_unselect_fn_t)
|
||||
(char *filename, struct ompi_info_t *info,
|
||||
(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t *private_data);
|
||||
|
||||
typedef int (*mca_io_base_component_register_datarep_fn_t)(
|
||||
char *,
|
||||
const char *,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_extent_function*,
|
||||
@ -137,7 +139,7 @@ typedef union mca_io_base_components_t mca_io_base_components_t;
|
||||
*/
|
||||
|
||||
typedef int (*mca_io_base_module_file_open_fn_t)
|
||||
(struct ompi_communicator_t *comm, char *filename, int amode,
|
||||
(struct ompi_communicator_t *comm, const char *filename, int amode,
|
||||
struct ompi_info_t *info, struct ompi_file_t *fh);
|
||||
typedef int (*mca_io_base_module_file_close_fn_t)(struct ompi_file_t *fh);
|
||||
|
||||
@ -156,7 +158,7 @@ typedef int (*mca_io_base_module_file_get_info_fn_t)
|
||||
|
||||
typedef int (*mca_io_base_module_file_set_view_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset disp, struct ompi_datatype_t *etype,
|
||||
struct ompi_datatype_t *filetype, char *datarep,
|
||||
struct ompi_datatype_t *filetype, const char *datarep,
|
||||
struct ompi_info_t *info);
|
||||
typedef int (*mca_io_base_module_file_get_view_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset *disp,
|
||||
@ -172,11 +174,11 @@ typedef int (*mca_io_base_module_file_read_at_all_fn_t)
|
||||
int count, struct ompi_datatype_t *datatype,
|
||||
struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_at_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, void *buf,
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, const void *buf,
|
||||
int count, struct ompi_datatype_t *datatype,
|
||||
struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_at_all_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, void *buf,
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, const void *buf,
|
||||
int count, struct ompi_datatype_t *datatype,
|
||||
struct ompi_status_public_t *status);
|
||||
|
||||
@ -185,7 +187,7 @@ typedef int (*mca_io_base_module_file_iread_at_fn_t)
|
||||
int count, struct ompi_datatype_t *datatype,
|
||||
struct ompi_request_t **request);
|
||||
typedef int (*mca_io_base_module_file_iwrite_at_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, void *buf,
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, const void *buf,
|
||||
int count, struct ompi_datatype_t *datatype,
|
||||
struct ompi_request_t **request);
|
||||
|
||||
@ -194,7 +196,7 @@ typedef int (*mca_io_base_module_file_iread_at_all_fn_t)
|
||||
int count, struct ompi_datatype_t *datatype,
|
||||
struct ompi_request_t **request);
|
||||
typedef int (*mca_io_base_module_file_iwrite_at_all_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, void *buf,
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, const void *buf,
|
||||
int count, struct ompi_datatype_t *datatype,
|
||||
struct ompi_request_t **request);
|
||||
|
||||
@ -205,24 +207,24 @@ typedef int (*mca_io_base_module_file_read_all_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *
|
||||
datatype, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *
|
||||
(struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *
|
||||
datatype, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_all_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *
|
||||
(struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *
|
||||
datatype, struct ompi_status_public_t *status);
|
||||
|
||||
typedef int (*mca_io_base_module_file_iread_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_request_t **request);
|
||||
typedef int (*mca_io_base_module_file_iwrite_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
(struct ompi_file_t *fh, const void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_request_t **request);
|
||||
|
||||
typedef int (*mca_io_base_module_file_iread_all_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_request_t **request);
|
||||
typedef int (*mca_io_base_module_file_iwrite_all_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
(struct ompi_file_t *fh, const void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_request_t **request);
|
||||
|
||||
typedef int (*mca_io_base_module_file_seek_fn_t)
|
||||
@ -236,19 +238,19 @@ typedef int (*mca_io_base_module_file_read_shared_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_shared_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
(struct ompi_file_t *fh, const void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_iread_shared_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_request_t **request);
|
||||
typedef int (*mca_io_base_module_file_iwrite_shared_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
(struct ompi_file_t *fh, const void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_request_t **request);
|
||||
typedef int (*mca_io_base_module_file_read_ordered_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_ordered_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
(struct ompi_file_t *fh, const void *buf, int count,
|
||||
struct ompi_datatype_t *datatype, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_seek_shared_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, int whence);
|
||||
@ -261,30 +263,30 @@ typedef int (*mca_io_base_module_file_read_at_all_begin_fn_t)
|
||||
typedef int (*mca_io_base_module_file_read_at_all_end_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_at_all_begin_fn_t)
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, void *buf,
|
||||
(struct ompi_file_t *fh, MPI_Offset offset, const void *buf,
|
||||
int count, struct ompi_datatype_t *datatype);
|
||||
typedef int (*mca_io_base_module_file_write_at_all_end_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, struct ompi_status_public_t *status);
|
||||
(struct ompi_file_t *fh, const void *buf, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_read_all_begin_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
typedef int (*mca_io_base_module_file_read_all_end_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_all_begin_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
(struct ompi_file_t *fh, const void *buf, int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
typedef int (*mca_io_base_module_file_write_all_end_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, struct ompi_status_public_t *status);
|
||||
(struct ompi_file_t *fh, const void *buf, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_read_ordered_begin_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
typedef int (*mca_io_base_module_file_read_ordered_end_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, struct ompi_status_public_t *status);
|
||||
typedef int (*mca_io_base_module_file_write_ordered_begin_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, int count,
|
||||
(struct ompi_file_t *fh, const void *buf, int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
typedef int (*mca_io_base_module_file_write_ordered_end_fn_t)
|
||||
(struct ompi_file_t *fh, void *buf, struct ompi_status_public_t *status);
|
||||
(struct ompi_file_t *fh, const void *buf, struct ompi_status_public_t *status);
|
||||
|
||||
typedef int (*mca_io_base_module_file_get_type_extent_fn_t)
|
||||
(struct ompi_file_t *fh, struct ompi_datatype_t *datatype,
|
||||
|
||||
@ -587,7 +587,7 @@ int ompi_io_ompio_set_explicit_offset (mca_io_ompio_file_t *fh,
|
||||
int ompi_io_ompio_decode_datatype (struct mca_io_ompio_file_t *fh,
|
||||
ompi_datatype_t *datatype,
|
||||
int count,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
size_t *max_data,
|
||||
struct iovec **iov,
|
||||
uint32_t *iovec_count)
|
||||
|
||||
@ -11,6 +11,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -194,7 +196,7 @@ struct mca_io_ompio_file_t;
|
||||
typedef int (*mca_io_ompio_decode_datatype_fn_t) (struct mca_io_ompio_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
int count,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
size_t *max_data,
|
||||
struct iovec **iov,
|
||||
uint32_t *iov_count);
|
||||
@ -289,7 +291,7 @@ struct mca_io_ompio_file_t {
|
||||
int f_amode;
|
||||
int f_perm;
|
||||
ompi_communicator_t *f_comm;
|
||||
char *f_filename;
|
||||
const char *f_filename;
|
||||
char *f_datarep;
|
||||
opal_convertor_t *f_convertor;
|
||||
ompi_info_t *f_info;
|
||||
@ -399,20 +401,20 @@ OMPI_DECLSPEC int mca_io_ompio_build_io_array ( mca_io_ompio_file_t *fh, int ind
|
||||
OMPI_DECLSPEC int ompi_io_ompio_set_file_defaults (mca_io_ompio_file_t *fh);
|
||||
|
||||
OMPI_DECLSPEC int ompio_io_ompio_file_open (ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh,bool use_sharedfp);
|
||||
|
||||
OMPI_DECLSPEC int ompio_io_ompio_file_write_at (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
|
||||
OMPI_DECLSPEC int ompio_io_ompio_file_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
@ -421,27 +423,27 @@ OMPI_DECLSPEC int ompio_io_ompio_file_close (mca_io_ompio_file_t *fh);
|
||||
|
||||
OMPI_DECLSPEC int ompio_io_ompio_file_write_at_all (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
|
||||
OMPI_DECLSPEC int ompio_io_ompio_file_iwrite_at (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
|
||||
OMPI_DECLSPEC int ompio_io_ompio_file_iwrite (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
|
||||
OMPI_DECLSPEC int ompio_io_ompio_file_iwrite_at_all (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -493,7 +495,7 @@ OMPI_DECLSPEC int ompio_io_ompio_file_get_position (mca_io_ompio_file_t *fh,
|
||||
OMPI_DECLSPEC int ompi_io_ompio_decode_datatype (struct mca_io_ompio_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
int count,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
size_t *max_data,
|
||||
struct iovec **iov,
|
||||
uint32_t *iov_count);
|
||||
@ -685,14 +687,14 @@ int mca_io_ompio_file_set_view (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE disp,
|
||||
struct ompi_datatype_t *etype,
|
||||
struct ompi_datatype_t *filetype,
|
||||
char *datarep,
|
||||
const char *datarep,
|
||||
struct ompi_info_t *info);
|
||||
|
||||
int mca_io_ompio_set_view_internal (struct mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE disp,
|
||||
struct ompi_datatype_t *etype,
|
||||
struct ompi_datatype_t *filetype,
|
||||
char *datarep,
|
||||
const char *datarep,
|
||||
struct ompi_info_t *info);
|
||||
|
||||
int mca_io_ompio_file_get_view (struct ompi_file_t *fh,
|
||||
@ -701,12 +703,12 @@ int mca_io_ompio_file_get_view (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t **filetype,
|
||||
char *datarep);
|
||||
int mca_io_ompio_file_open (struct ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
struct ompi_file_t *fh);
|
||||
int mca_io_ompio_file_close (struct ompi_file_t *fh);
|
||||
int mca_io_ompio_file_delete (char *filename,
|
||||
int mca_io_ompio_file_delete (const char *filename,
|
||||
struct ompi_info_t *info);
|
||||
int mca_io_ompio_file_set_size (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE size);
|
||||
@ -729,7 +731,7 @@ int mca_io_ompio_file_set_view (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE disp,
|
||||
struct ompi_datatype_t *etype,
|
||||
struct ompi_datatype_t *filetype,
|
||||
char *datarep,
|
||||
const char *datarep,
|
||||
struct ompi_info_t *info);
|
||||
int mca_io_ompio_file_get_view (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE *disp,
|
||||
@ -752,13 +754,13 @@ int mca_io_ompio_file_read_at_all (struct ompi_file_t *fh,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_at (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_at_all (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
@ -770,7 +772,7 @@ int mca_io_ompio_file_iread_at (struct ompi_file_t *fh,
|
||||
ompi_request_t **request);
|
||||
int mca_io_ompio_file_iwrite_at (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -799,23 +801,23 @@ int mca_io_ompio_file_iread_at_all (ompi_file_t *fh,
|
||||
ompi_request_t **request);
|
||||
|
||||
int mca_io_ompio_file_write (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_all (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_iwrite_all (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_io_ompio_file_iwrite_at_all (ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -825,7 +827,7 @@ int mca_io_ompio_file_iread (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_io_ompio_file_iwrite (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -845,7 +847,7 @@ int mca_io_ompio_file_read_shared (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_shared (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
@ -855,7 +857,7 @@ int mca_io_ompio_file_iread_shared (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_io_ompio_file_iwrite_shared (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -865,7 +867,7 @@ int mca_io_ompio_file_read_ordered (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_ordered (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
@ -886,11 +888,11 @@ int mca_io_ompio_file_read_at_all_end (struct ompi_file_t *fh,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_at_all_begin (struct ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_io_ompio_file_write_at_all_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_read_all_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
@ -900,11 +902,11 @@ int mca_io_ompio_file_read_all_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_all_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_io_ompio_file_write_all_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_read_ordered_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
@ -914,11 +916,11 @@ int mca_io_ompio_file_read_ordered_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
ompi_status_public_t *status);
|
||||
int mca_io_ompio_file_write_ordered_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_io_ompio_file_write_ordered_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
struct ompi_status_public_t *status);
|
||||
|
||||
/* Section 9.5.1 */
|
||||
|
||||
@ -55,20 +55,21 @@ file_query (struct ompi_file_t *file,
|
||||
static int file_unquery(struct ompi_file_t *file,
|
||||
struct mca_io_base_file_t *private_data);
|
||||
|
||||
static int delete_query(char *filename, struct ompi_info_t *info,
|
||||
static int delete_query(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t **private_data,
|
||||
bool *usable, int *priorty);
|
||||
|
||||
static int delete_select(char *filename, struct ompi_info_t *info,
|
||||
static int delete_select(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t *private_data);
|
||||
/*
|
||||
static int io_progress(void);
|
||||
|
||||
static int register_datarep(char *,
|
||||
static int register_datarep(const char *,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_extent_function*,
|
||||
void*);
|
||||
/*
|
||||
static int io_progress(void);
|
||||
|
||||
*/
|
||||
|
||||
/*
|
||||
@ -125,6 +126,8 @@ mca_io_base_component_2_0_0_t mca_io_ompio_component = {
|
||||
|
||||
.io_delete_query = delete_query,
|
||||
.io_delete_select = delete_select,
|
||||
|
||||
.io_register_datarep = register_datarep,
|
||||
};
|
||||
|
||||
static int register_component(void)
|
||||
@ -284,7 +287,7 @@ static int file_unquery(struct ompi_file_t *file,
|
||||
}
|
||||
|
||||
|
||||
static int delete_query(char *filename, struct ompi_info_t *info,
|
||||
static int delete_query(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t **private_data,
|
||||
bool *usable, int *priority)
|
||||
{
|
||||
@ -295,7 +298,7 @@ static int delete_query(char *filename, struct ompi_info_t *info,
|
||||
return OMPI_SUCCESS;
|
||||
}
|
||||
|
||||
static int delete_select(char *filename, struct ompi_info_t *info,
|
||||
static int delete_select(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t *private_data)
|
||||
{
|
||||
int ret;
|
||||
@ -306,6 +309,16 @@ static int delete_select(char *filename, struct ompi_info_t *info,
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
static int register_datarep(const char * datarep,
|
||||
MPI_Datarep_conversion_function* read_fn,
|
||||
MPI_Datarep_conversion_function* write_fn,
|
||||
MPI_Datarep_extent_function* extent_fn,
|
||||
void* state)
|
||||
{
|
||||
return OMPI_ERROR;
|
||||
}
|
||||
|
||||
/*
|
||||
static int io_progress (void)
|
||||
{
|
||||
|
||||
@ -1,20 +1,22 @@
|
||||
/*
|
||||
* Copyright (c) 2004-2005 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-2005 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) 2008-2015 University of Houston. All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
* Copyright (c) 2004-2005 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-2005 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) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
* Additional copyrights may follow
|
||||
*
|
||||
* $HEADER$
|
||||
* $HEADER$
|
||||
*/
|
||||
|
||||
#include "ompi_config.h"
|
||||
@ -39,7 +41,7 @@
|
||||
|
||||
int
|
||||
mca_io_ompio_file_open (ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
ompi_info_t *info,
|
||||
ompi_file_t *fh)
|
||||
@ -71,7 +73,7 @@ mca_io_ompio_file_open (ompi_communicator_t *comm,
|
||||
|
||||
int
|
||||
ompio_io_ompio_file_open (ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
ompi_info_t *info,
|
||||
mca_io_ompio_file_t *ompio_fh, bool use_sharedfp)
|
||||
@ -399,7 +401,7 @@ ompio_io_ompio_file_close (mca_io_ompio_file_t *ompio_fh)
|
||||
return ret;
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_delete (char *filename,
|
||||
int mca_io_ompio_file_delete (const char *filename,
|
||||
struct ompi_info_t *info)
|
||||
{
|
||||
int ret = OMPI_SUCCESS;
|
||||
|
||||
@ -45,7 +45,7 @@ int mca_io_ompio_set_view_internal(mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE disp,
|
||||
ompi_datatype_t *etype,
|
||||
ompi_datatype_t *filetype,
|
||||
char *datarep,
|
||||
const char *datarep,
|
||||
ompi_info_t *info)
|
||||
{
|
||||
|
||||
@ -185,7 +185,7 @@ int mca_io_ompio_file_set_view (ompi_file_t *fp,
|
||||
OMPI_MPI_OFFSET_TYPE disp,
|
||||
ompi_datatype_t *etype,
|
||||
ompi_datatype_t *filetype,
|
||||
char *datarep,
|
||||
const char *datarep,
|
||||
ompi_info_t *info)
|
||||
{
|
||||
int ret=OMPI_SUCCESS;
|
||||
|
||||
@ -1,20 +1,22 @@
|
||||
/*
|
||||
* Copyright (c) 2004-2005 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-2005 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) 2008-2015 University of Houston. All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
* Copyright (c) 2004-2005 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-2005 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) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
* Additional copyrights may follow
|
||||
*
|
||||
* $HEADER$
|
||||
* $HEADER$
|
||||
*/
|
||||
|
||||
#include "ompi_config.h"
|
||||
@ -53,7 +55,7 @@
|
||||
|
||||
|
||||
int mca_io_ompio_file_write (ompi_file_t *fp,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -70,7 +72,7 @@ int mca_io_ompio_file_write (ompi_file_t *fp,
|
||||
}
|
||||
|
||||
int ompio_io_ompio_file_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -156,7 +158,7 @@ int ompio_io_ompio_file_write (mca_io_ompio_file_t *fh,
|
||||
|
||||
int mca_io_ompio_file_write_at (ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -172,7 +174,7 @@ int mca_io_ompio_file_write_at (ompi_file_t *fh,
|
||||
|
||||
int ompio_io_ompio_file_write_at (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -195,7 +197,7 @@ int ompio_io_ompio_file_write_at (mca_io_ompio_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_iwrite (ompi_file_t *fp,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -210,7 +212,7 @@ int mca_io_ompio_file_iwrite (ompi_file_t *fp,
|
||||
}
|
||||
|
||||
int ompio_io_ompio_file_iwrite (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -297,7 +299,7 @@ int ompio_io_ompio_file_iwrite (mca_io_ompio_file_t *fh,
|
||||
|
||||
int mca_io_ompio_file_iwrite_at (ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -313,7 +315,7 @@ int mca_io_ompio_file_iwrite_at (ompi_file_t *fh,
|
||||
|
||||
int ompio_io_ompio_file_iwrite_at (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -470,7 +472,7 @@ int mca_io_ompio_build_io_array ( mca_io_ompio_file_t *fh, int index, int cycles
|
||||
/******************************************************************/
|
||||
|
||||
int mca_io_ompio_file_write_all (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -499,7 +501,7 @@ int mca_io_ompio_file_write_all (ompi_file_t *fh,
|
||||
|
||||
int mca_io_ompio_file_write_at_all (ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -514,7 +516,7 @@ int mca_io_ompio_file_write_at_all (ompi_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_iwrite_all (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -545,7 +547,7 @@ int mca_io_ompio_file_iwrite_all (ompi_file_t *fh,
|
||||
|
||||
int ompio_io_ompio_file_write_at_all (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -567,7 +569,7 @@ int ompio_io_ompio_file_write_at_all (mca_io_ompio_file_t *fh,
|
||||
|
||||
int mca_io_ompio_file_iwrite_at_all (ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -582,7 +584,7 @@ int mca_io_ompio_file_iwrite_at_all (ompi_file_t *fh,
|
||||
|
||||
int ompio_io_ompio_file_iwrite_at_all (mca_io_ompio_file_t *fp,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -622,7 +624,7 @@ int ompio_io_ompio_file_iwrite_at_all (mca_io_ompio_file_t *fp,
|
||||
/******************************************************/
|
||||
|
||||
int mca_io_ompio_file_write_shared (ompi_file_t *fp,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -647,7 +649,7 @@ int mca_io_ompio_file_write_shared (ompi_file_t *fp,
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_iwrite_shared (ompi_file_t *fp,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -672,7 +674,7 @@ int mca_io_ompio_file_iwrite_shared (ompi_file_t *fp,
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_write_ordered (ompi_file_t *fp,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -697,7 +699,7 @@ int mca_io_ompio_file_write_ordered (ompi_file_t *fp,
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_write_ordered_begin (ompi_file_t *fp,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -721,7 +723,7 @@ int mca_io_ompio_file_write_ordered_begin (ompi_file_t *fp,
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_write_ordered_end (ompi_file_t *fp,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status)
|
||||
{
|
||||
int ret = OMPI_SUCCESS;
|
||||
@ -747,7 +749,7 @@ int mca_io_ompio_file_write_ordered_end (ompi_file_t *fp,
|
||||
/* Split collectives . Not really used but infrastructure is in place */
|
||||
/**********************************************************************/
|
||||
int mca_io_ompio_file_write_all_begin (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -768,7 +770,7 @@ int mca_io_ompio_file_write_all_begin (ompi_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_io_ompio_file_write_all_end (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status)
|
||||
{
|
||||
int ret = OMPI_SUCCESS;
|
||||
@ -787,7 +789,7 @@ int mca_io_ompio_file_write_all_end (ompi_file_t *fh,
|
||||
|
||||
int mca_io_ompio_file_write_at_all_begin (ompi_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -810,7 +812,7 @@ int mca_io_ompio_file_write_at_all_begin (ompi_file_t *fh,
|
||||
|
||||
|
||||
int mca_io_ompio_file_write_at_all_end (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t * status)
|
||||
{
|
||||
int ret = OMPI_SUCCESS;
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -62,12 +64,12 @@ typedef struct mca_io_romio314_data_t mca_io_romio314_data_t;
|
||||
*/
|
||||
/* Section 9.2 */
|
||||
int mca_io_romio314_file_open (struct ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
ompi_file_t *fh);
|
||||
int mca_io_romio314_file_close (struct ompi_file_t *fh);
|
||||
int mca_io_romio314_file_delete (char *filename,
|
||||
int mca_io_romio314_file_delete (const char *filename,
|
||||
struct ompi_info_t *info);
|
||||
int mca_io_romio314_file_set_size (struct ompi_file_t *fh,
|
||||
MPI_Offset size);
|
||||
@ -87,7 +89,7 @@ int mca_io_romio314_file_set_view (struct ompi_file_t *fh,
|
||||
MPI_Offset disp,
|
||||
struct ompi_datatype_t *etype,
|
||||
struct ompi_datatype_t *filetype,
|
||||
char *datarep,
|
||||
const char *datarep,
|
||||
struct ompi_info_t *info);
|
||||
int mca_io_romio314_file_get_view (struct ompi_file_t *fh,
|
||||
MPI_Offset * disp,
|
||||
@ -110,13 +112,13 @@ int mca_io_romio314_file_read_at_all (struct ompi_file_t *fh,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_at (struct ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_at_all (struct ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
@ -128,7 +130,7 @@ int mca_io_romio314_file_iread_at (struct ompi_file_t *fh,
|
||||
ompi_request_t **request);
|
||||
int mca_io_romio314_file_iwrite_at (struct ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -145,12 +147,12 @@ int mca_io_romio314_file_read_all (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_all (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
@ -160,7 +162,7 @@ int mca_io_romio314_file_iread (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_io_romio314_file_iwrite (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -180,7 +182,7 @@ int mca_io_romio314_file_read_shared (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_shared (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
@ -190,7 +192,7 @@ int mca_io_romio314_file_iread_shared (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_io_romio314_file_iwrite_shared (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
@ -200,7 +202,7 @@ int mca_io_romio314_file_read_ordered (struct ompi_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_ordered (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status);
|
||||
@ -221,11 +223,11 @@ int mca_io_romio314_file_read_at_all_end (struct ompi_file_t *fh,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_at_all_begin (struct ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_io_romio314_file_write_at_all_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_read_all_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
@ -235,11 +237,11 @@ int mca_io_romio314_file_read_all_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_all_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_io_romio314_file_write_all_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_read_ordered_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
@ -249,11 +251,11 @@ int mca_io_romio314_file_read_ordered_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
ompi_status_public_t * status);
|
||||
int mca_io_romio314_file_write_ordered_begin (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_io_romio314_file_write_ordered_end (struct ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
struct ompi_status_public_t * status);
|
||||
|
||||
/* Section 9.5.1 */
|
||||
|
||||
@ -48,13 +48,13 @@ static const struct mca_io_base_module_2_0_0_t *
|
||||
static int file_unquery(struct ompi_file_t *file,
|
||||
struct mca_io_base_file_t *private_data);
|
||||
|
||||
static int delete_query(char *filename, struct ompi_info_t *info,
|
||||
static int delete_query(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t **private_data,
|
||||
bool *usable, int *priorty);
|
||||
static int delete_select(char *filename, struct ompi_info_t *info,
|
||||
static int delete_select(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t *private_data);
|
||||
|
||||
static int register_datarep(char *,
|
||||
static int register_datarep(const char *,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_conversion_function*,
|
||||
MPI_Datarep_extent_function*,
|
||||
@ -222,7 +222,7 @@ static int file_unquery(struct ompi_file_t *file,
|
||||
}
|
||||
|
||||
|
||||
static int delete_query(char *filename, struct ompi_info_t *info,
|
||||
static int delete_query(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t **private_data,
|
||||
bool *usable, int *priority)
|
||||
{
|
||||
@ -234,7 +234,7 @@ static int delete_query(char *filename, struct ompi_info_t *info,
|
||||
}
|
||||
|
||||
|
||||
static int delete_select(char *filename, struct ompi_info_t *info,
|
||||
static int delete_select(const char *filename, struct ompi_info_t *info,
|
||||
struct mca_io_base_delete_t *private_data)
|
||||
{
|
||||
int ret;
|
||||
@ -248,7 +248,7 @@ static int delete_select(char *filename, struct ompi_info_t *info,
|
||||
|
||||
|
||||
static int
|
||||
register_datarep(char * datarep,
|
||||
register_datarep(const char * datarep,
|
||||
MPI_Datarep_conversion_function* read_fn,
|
||||
MPI_Datarep_conversion_function* write_fn,
|
||||
MPI_Datarep_extent_function* extent_fn,
|
||||
|
||||
@ -1,19 +1,21 @@
|
||||
/*
|
||||
* Copyright (c) 2004-2005 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-2005 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$
|
||||
* Copyright (c) 2004-2005 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-2005 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) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
* Additional copyrights may follow
|
||||
*
|
||||
* $HEADER$
|
||||
* $HEADER$
|
||||
*/
|
||||
|
||||
#include "ompi_config.h"
|
||||
@ -27,7 +29,7 @@
|
||||
|
||||
int
|
||||
mca_io_romio314_file_open (ompi_communicator_t *comm,
|
||||
char *filename,
|
||||
const char *filename,
|
||||
int amode,
|
||||
ompi_info_t *info,
|
||||
ompi_file_t *fh)
|
||||
@ -182,7 +184,7 @@ mca_io_romio314_file_set_view (ompi_file_t *fh,
|
||||
MPI_Offset disp,
|
||||
struct ompi_datatype_t *etype,
|
||||
struct ompi_datatype_t *filetype,
|
||||
char *datarep,
|
||||
const char *datarep,
|
||||
ompi_info_t *info)
|
||||
{
|
||||
int ret;
|
||||
|
||||
@ -1,19 +1,21 @@
|
||||
/*
|
||||
* Copyright (c) 2004-2005 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-2005 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$
|
||||
* Copyright (c) 2004-2005 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-2005 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) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
* Additional copyrights may follow
|
||||
*
|
||||
* $HEADER$
|
||||
* $HEADER$
|
||||
*/
|
||||
|
||||
#include "ompi_config.h"
|
||||
@ -25,7 +27,7 @@
|
||||
int
|
||||
mca_io_romio314_file_write_at (ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -48,7 +50,7 @@ mca_io_romio314_file_write_at (ompi_file_t *fh,
|
||||
int
|
||||
mca_io_romio314_file_write_at_all (ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -71,7 +73,7 @@ mca_io_romio314_file_write_at_all (ompi_file_t *fh,
|
||||
int
|
||||
mca_io_romio314_file_iwrite_at (ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -95,7 +97,7 @@ mca_io_romio314_file_iwrite_at (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -115,7 +117,7 @@ mca_io_romio314_file_write (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_all (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -135,7 +137,7 @@ mca_io_romio314_file_write_all (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_iwrite (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -156,7 +158,7 @@ mca_io_romio314_file_iwrite (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_shared (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -176,7 +178,7 @@ mca_io_romio314_file_write_shared (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_iwrite_shared (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request)
|
||||
@ -196,7 +198,7 @@ mca_io_romio314_file_iwrite_shared (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_ordered (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t * status)
|
||||
@ -217,7 +219,7 @@ mca_io_romio314_file_write_ordered (ompi_file_t *fh,
|
||||
int
|
||||
mca_io_romio314_file_write_at_all_begin (ompi_file_t *fh,
|
||||
MPI_Offset offset,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -235,7 +237,7 @@ mca_io_romio314_file_write_at_all_begin (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_at_all_end (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t * status)
|
||||
{
|
||||
int ret;
|
||||
@ -252,7 +254,7 @@ mca_io_romio314_file_write_at_all_end (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_all_begin (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -270,7 +272,7 @@ mca_io_romio314_file_write_all_begin (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_all_end (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t * status)
|
||||
{
|
||||
int ret;
|
||||
@ -286,7 +288,7 @@ mca_io_romio314_file_write_all_end (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_ordered_begin (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -304,7 +306,7 @@ mca_io_romio314_file_write_ordered_begin (ompi_file_t *fh,
|
||||
|
||||
int
|
||||
mca_io_romio314_file_write_ordered_end (ompi_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t * status)
|
||||
{
|
||||
int ret;
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -53,7 +55,7 @@ int mca_sharedfp_individual_get_position(mca_io_ompio_file_t *fh,
|
||||
int mca_sharedfp_individual_seek (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE offset, int whence);
|
||||
int mca_sharedfp_individual_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh);
|
||||
@ -76,24 +78,24 @@ int mca_sharedfp_individual_iread (mca_io_ompio_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_sharedfp_individual_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_individual_write_ordered (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_individual_write_ordered_begin (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_sharedfp_individual_write_ordered_end (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_individual_iwrite (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -29,7 +31,7 @@
|
||||
|
||||
|
||||
int mca_sharedfp_individual_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -27,7 +29,7 @@
|
||||
#include "ompi/mca/sharedfp/base/base.h"
|
||||
|
||||
int mca_sharedfp_individual_iwrite(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
ompi_datatype_t *datatype,
|
||||
MPI_Request * request)
|
||||
@ -88,7 +90,7 @@ int mca_sharedfp_individual_iwrite(mca_io_ompio_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_sharedfp_individual_write_ordered_begin(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -212,7 +214,7 @@ exit:
|
||||
}
|
||||
|
||||
int mca_sharedfp_individual_write_ordered_end(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status)
|
||||
{
|
||||
int ret = OMPI_SUCCESS;
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -27,7 +29,7 @@
|
||||
#include "ompi/mca/sharedfp/base/base.h"
|
||||
|
||||
int mca_sharedfp_individual_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -85,7 +87,7 @@ int mca_sharedfp_individual_write (mca_io_ompio_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_sharedfp_individual_write_ordered (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -53,7 +55,7 @@ int mca_sharedfp_lockedfile_seek (mca_io_ompio_file_t *fh,
|
||||
int mca_sharedfp_lockedfile_get_position (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE * offset);
|
||||
int mca_sharedfp_lockedfile_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh);
|
||||
@ -77,24 +79,24 @@ int mca_sharedfp_lockedfile_iread (mca_io_ompio_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_sharedfp_lockedfile_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_lockedfile_write_ordered (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_lockedfile_write_ordered_begin (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_sharedfp_lockedfile_write_ordered_end (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_lockedfile_iwrite (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
|
||||
@ -34,7 +34,7 @@
|
||||
#include <fcntl.h>
|
||||
|
||||
int mca_sharedfp_lockedfile_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh)
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -28,7 +30,7 @@
|
||||
#include "ompi/mca/io/ompio/io_ompio.h"
|
||||
|
||||
int mca_sharedfp_lockedfile_iwrite(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
ompi_datatype_t *datatype,
|
||||
MPI_Request * request)
|
||||
@ -87,7 +89,7 @@ int mca_sharedfp_lockedfile_iwrite(mca_io_ompio_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_sharedfp_lockedfile_write_ordered_begin(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -216,7 +218,7 @@ exit:
|
||||
|
||||
|
||||
int mca_sharedfp_lockedfile_write_ordered_end(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status)
|
||||
{
|
||||
int ret = OMPI_SUCCESS;
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -27,7 +29,7 @@
|
||||
#include "ompi/mca/sharedfp/base/base.h"
|
||||
|
||||
int mca_sharedfp_lockedfile_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -85,7 +87,7 @@ int mca_sharedfp_lockedfile_write (mca_io_ompio_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_sharedfp_lockedfile_write_ordered (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008-2013 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -120,28 +122,28 @@ typedef int (*mca_sharedfp_base_module_get_position_fn_t)(
|
||||
struct mca_io_ompio_file_t *fh, OMPI_MPI_OFFSET_TYPE * offset);
|
||||
typedef int (*mca_sharedfp_base_module_write_fn_t)(
|
||||
struct mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
typedef int (*mca_sharedfp_base_module_write_ordered_fn_t)(
|
||||
struct mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
typedef int (*mca_sharedfp_base_module_write_ordered_begin_fn_t)(
|
||||
struct mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
typedef int (*mca_sharedfp_base_module_write_ordered_end_fn_t)(
|
||||
struct mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status);
|
||||
typedef int (*mca_sharedfp_base_module_iwrite_fn_t)(
|
||||
struct mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t ** request);
|
||||
@ -173,7 +175,7 @@ typedef int (*mca_sharedfp_base_module_read_ordered_end_fn_t)(
|
||||
void *buf,
|
||||
ompi_status_public_t *status);
|
||||
typedef int (*mca_sharedfp_base_module_file_open_fn_t)(
|
||||
struct ompi_communicator_t *comm, char *filename, int amode,
|
||||
struct ompi_communicator_t *comm, const char *filename, int amode,
|
||||
struct ompi_info_t *info, struct mca_io_ompio_file_t *fh);
|
||||
typedef int (*mca_sharedfp_base_module_file_close_fn_t)(struct mca_io_ompio_file_t *fh);
|
||||
|
||||
|
||||
@ -10,7 +10,9 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2008-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Cisco Systems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Cisco Systems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -53,7 +55,7 @@ int mca_sharedfp_sm_seek (mca_io_ompio_file_t *fh,
|
||||
int mca_sharedfp_sm_get_position (mca_io_ompio_file_t *fh,
|
||||
OMPI_MPI_OFFSET_TYPE * offset);
|
||||
int mca_sharedfp_sm_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh);
|
||||
@ -77,24 +79,24 @@ int mca_sharedfp_sm_iread (mca_io_ompio_file_t *fh,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
int mca_sharedfp_sm_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_sm_write_ordered (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_sm_write_ordered_begin (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype);
|
||||
int mca_sharedfp_sm_write_ordered_end (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status);
|
||||
int mca_sharedfp_sm_iwrite (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_request_t **request);
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* Copyright (c) 2013 Intel, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* Copyright (c) 2015 Cisco Systems, Inc. All rights reserved.
|
||||
* Copyright (c) 2015 Cisco Systems, Inc. All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -44,7 +44,7 @@
|
||||
|
||||
|
||||
int mca_sharedfp_sm_file_open (struct ompi_communicator_t *comm,
|
||||
char* filename,
|
||||
const char* filename,
|
||||
int amode,
|
||||
struct ompi_info_t *info,
|
||||
mca_io_ompio_file_t *fh)
|
||||
@ -131,7 +131,7 @@ int mca_sharedfp_sm_file_open (struct ompi_communicator_t *comm,
|
||||
** overwriting each other, e.g. orte_process_info.proc_session_dir
|
||||
*/
|
||||
/*sprintf(sm_filename,"%s%s",filename,".sm");*/
|
||||
filename_basename = basename(filename);
|
||||
filename_basename = basename((void *)filename);
|
||||
sm_filename = (char*) malloc( sizeof(char) * (strlen(filename_basename)+64) );
|
||||
if (NULL == sm_filename) {
|
||||
free(sm_data);
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -27,7 +29,7 @@
|
||||
#include "ompi/mca/sharedfp/base/base.h"
|
||||
|
||||
int mca_sharedfp_sm_iwrite(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
ompi_datatype_t *datatype,
|
||||
MPI_Request * request)
|
||||
@ -86,7 +88,7 @@ int mca_sharedfp_sm_iwrite(mca_io_ompio_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_sharedfp_sm_write_ordered_begin(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype)
|
||||
{
|
||||
@ -217,7 +219,7 @@ exit:
|
||||
|
||||
|
||||
int mca_sharedfp_sm_write_ordered_end(mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
ompi_status_public_t *status)
|
||||
{
|
||||
int ret = OMPI_SUCCESS;
|
||||
|
||||
@ -10,6 +10,8 @@
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013-2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -27,7 +29,7 @@
|
||||
#include "ompi/mca/sharedfp/base/base.h"
|
||||
|
||||
int mca_sharedfp_sm_write (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
@ -86,7 +88,7 @@ int mca_sharedfp_sm_write (mca_io_ompio_file_t *fh,
|
||||
}
|
||||
|
||||
int mca_sharedfp_sm_write_ordered (mca_io_ompio_file_t *fh,
|
||||
void *buf,
|
||||
const void *buf,
|
||||
int count,
|
||||
struct ompi_datatype_t *datatype,
|
||||
ompi_status_public_t *status)
|
||||
|
||||
@ -12,6 +12,8 @@
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -77,7 +79,6 @@ int MPI_File_delete(const char *filename, MPI_Info info)
|
||||
/* Since there is no MPI_File handle associated with this
|
||||
function, the MCA has to do a selection and perform the
|
||||
action */
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = mca_io_base_delete((char *) filename, info);
|
||||
rc = mca_io_base_delete(filename, info);
|
||||
OMPI_ERRHANDLER_RETURN(rc, MPI_FILE_NULL, rc, FUNC_NAME);
|
||||
}
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -73,9 +75,8 @@ int MPI_File_iwrite(MPI_File fh, const void *buf, int count, MPI_Datatype
|
||||
/* Call the back-end io component function */
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_iwrite(fh, (void *) buf, count, datatype, request);
|
||||
io_module_file_iwrite(fh, buf, count, datatype, request);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -14,6 +14,8 @@
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -74,9 +76,8 @@ int MPI_File_iwrite_all(MPI_File fh, const void *buf, int count, MPI_Datatype
|
||||
/* Call the back-end io component function */
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_iwrite_all(fh, (void *) buf, count, datatype, request);
|
||||
io_module_file_iwrite_all(fh, buf, count, datatype, request);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -74,9 +76,8 @@ int MPI_File_iwrite_at(MPI_File fh, MPI_Offset offset, const void *buf,
|
||||
/* Call the back-end io component function */
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_iwrite_at(fh, offset, (void *) buf, count, datatype,
|
||||
io_module_file_iwrite_at(fh, offset, buf, count, datatype,
|
||||
request);
|
||||
break;
|
||||
|
||||
|
||||
@ -14,6 +14,8 @@
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 University of Houston. All rights reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -75,9 +77,8 @@ int MPI_File_iwrite_at_all(MPI_File fh, MPI_Offset offset, const void *buf,
|
||||
/* Call the back-end io component function */
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_iwrite_at_all(fh, offset, (void *) buf, count, datatype,
|
||||
io_module_file_iwrite_at_all(fh, offset, buf, count, datatype,
|
||||
request);
|
||||
break;
|
||||
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -72,9 +74,8 @@ int MPI_File_iwrite_shared(MPI_File fh, const void *buf, int count,
|
||||
/* Call the back-end io component function */
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_iwrite_shared(fh, (void *) buf, count, datatype, request);
|
||||
io_module_file_iwrite_shared(fh, buf, count, datatype, request);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -10,9 +10,11 @@
|
||||
* University of Stuttgart. All rights reserved.
|
||||
* Copyright (c) 2004-2005 The Regents of the University of California.
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013 Cisco Systems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Cisco Systems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -90,8 +92,7 @@ int MPI_File_open(MPI_Comm comm, const char *filename, int amode,
|
||||
/* Create an empty MPI_File handle */
|
||||
|
||||
*fh = MPI_FILE_NULL;
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = ompi_file_open(comm, (char *) filename, amode, info, fh);
|
||||
rc = ompi_file_open(comm, filename, amode, info, fh);
|
||||
|
||||
/* Creating the file handle also selects a component to use,
|
||||
creates a module, and calls file_open() on the module. So
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -71,9 +73,8 @@ int MPI_File_set_view(MPI_File fh, MPI_Offset disp, MPI_Datatype etype,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_set_view(fh, disp, etype, filetype, (char *) datarep, info);
|
||||
io_module_file_set_view(fh, disp, etype, filetype, datarep, info);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -70,9 +72,8 @@ int MPI_File_write(MPI_File fh, const void *buf, int count,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write(fh, (void *) buf, count, datatype, status);
|
||||
io_module_file_write(fh, buf, count, datatype, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -70,9 +72,8 @@ int MPI_File_write_all(MPI_File fh, const void *buf, int count, MPI_Datatype
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_all(fh, (void *) buf, count, datatype, status);
|
||||
io_module_file_write_all(fh, buf, count, datatype, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -70,9 +72,8 @@ int MPI_File_write_all_begin(MPI_File fh, const void *buf, int count,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_all_begin(fh, (void *) buf, count, datatype);
|
||||
io_module_file_write_all_begin(fh, buf, count, datatype);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -58,9 +60,8 @@ int MPI_File_write_all_end(MPI_File fh, const void *buf, MPI_Status *status)
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_all_end(fh, (void *) buf, status);
|
||||
io_module_file_write_all_end(fh, buf, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -71,9 +73,8 @@ int MPI_File_write_at(MPI_File fh, MPI_Offset offset, const void *buf,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_at(fh, offset, (void *) buf, count, datatype, status);
|
||||
io_module_file_write_at(fh, offset, buf, count, datatype, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -71,9 +73,8 @@ int MPI_File_write_at_all(MPI_File fh, MPI_Offset offset, const void *buf,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_at_all(fh, offset, (void *) buf, count, datatype,
|
||||
io_module_file_write_at_all(fh, offset, buf, count, datatype,
|
||||
status);
|
||||
break;
|
||||
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -70,9 +72,8 @@ int MPI_File_write_at_all_begin(MPI_File fh, MPI_Offset offset, const void *buf,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_at_all_begin(fh, offset, (void *) buf, count,
|
||||
io_module_file_write_at_all_begin(fh, offset, buf, count,
|
||||
datatype);
|
||||
break;
|
||||
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -58,9 +60,8 @@ int MPI_File_write_at_all_end(MPI_File fh, const void *buf, MPI_Status *status)
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_at_all_end(fh, (void *) buf, status);
|
||||
io_module_file_write_at_all_end(fh, buf, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -70,9 +72,8 @@ int MPI_File_write_ordered(MPI_File fh, const void *buf, int count,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_ordered(fh, (void *) buf, count, datatype, status);
|
||||
io_module_file_write_ordered(fh, buf, count, datatype, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -70,9 +72,8 @@ int MPI_File_write_ordered_begin(MPI_File fh, const void *buf, int count,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_ordered_begin(fh, (void *) buf, count, datatype);
|
||||
io_module_file_write_ordered_begin(fh, buf, count, datatype);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -58,9 +60,8 @@ int MPI_File_write_ordered_end(MPI_File fh, const void *buf, MPI_Status *status)
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_ordered_end(fh, (void *) buf, status);
|
||||
io_module_file_write_ordered_end(fh, buf, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -13,6 +13,8 @@
|
||||
* Copyright (c) 2008 Sun Microsystems, Inc. All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -70,9 +72,8 @@ int MPI_File_write_shared(MPI_File fh, const void *buf, int count,
|
||||
|
||||
switch (fh->f_io_version) {
|
||||
case MCA_IO_BASE_V_2_0_0:
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = fh->f_io_selected_module.v2_0_0.
|
||||
io_module_file_write_shared(fh, (void *) buf, count, datatype, status);
|
||||
io_module_file_write_shared(fh, buf, count, datatype, status);
|
||||
break;
|
||||
|
||||
default:
|
||||
|
||||
@ -12,6 +12,8 @@
|
||||
* All rights reserved.
|
||||
* Copyright (c) 2013 Los Alamos National Security, LLC. All rights
|
||||
* reserved.
|
||||
* Copyright (c) 2015 Research Organization for Information Science
|
||||
* and Technology (RIST). All rights reserved.
|
||||
* $COPYRIGHT$
|
||||
*
|
||||
* Additional copyrights may follow
|
||||
@ -68,8 +70,7 @@ int MPI_Register_datarep(const char *datarep,
|
||||
OPAL_CR_ENTER_LIBRARY();
|
||||
|
||||
/* Call the back-end io component function */
|
||||
/* XXX -- CONST -- do not cast away const -- update mca/io */
|
||||
rc = mca_io_base_register_datarep((char *) datarep, read_conversion_fn,
|
||||
rc = mca_io_base_register_datarep(datarep, read_conversion_fn,
|
||||
write_conversion_fn,
|
||||
dtype_file_extent_fn,
|
||||
extra_state);
|
||||
|
||||
Загрузка…
x
Ссылка в новой задаче
Block a user