/* * 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 Sun Microsystems, Inc. All rights reserved. * Copyright (c) 2015-2017 Research Organization for Information Science * and Technology (RIST). All rights reserved. * Copyright (c) 2016-2017 IBM Corporation. All rights reserved. * $COPYRIGHT$ * * Additional copyrights may follow * * $HEADER$ */ #ifndef MCA_IO_ROMIO321_H #define MCA_IO_ROMIO321_H #include "ompi_config.h" #include "opal/threads/mutex.h" #include "ompi/request/request.h" #include "ompi/file/file.h" #include "ompi/mca/io/io.h" #include "romio/adio/include/romioconf.h" #include "romio/include/mpio.h" BEGIN_C_DECLS OMPI_DECLSPEC extern mca_io_base_component_2_0_0_t mca_io_romio321_component; /* * global variables, instantiated in module.c */ extern opal_mutex_t mca_io_romio321_mutex; extern mca_io_base_module_2_0_0_t mca_io_romio321_module; OMPI_DECLSPEC extern mca_io_base_component_2_0_0_t mca_io_romio321_component; /* * Private data for ROMIO modules */ struct mca_io_romio321_data_t { ROMIO_PREFIX (MPI_File) romio_fh; }; typedef struct mca_io_romio321_data_t mca_io_romio321_data_t; /* * Module functions */ /* * mca->ROMIO module routines: * ROMIO_PREFIX(file_XXX) * ROMIO operations names: * ROMIO_PREFIX(MPI_File_XXX) */ /* Section 9.2 */ int mca_io_romio321_file_open (struct ompi_communicator_t *comm, const char *filename, int amode, struct opal_info_t *info, ompi_file_t *fh); int mca_io_romio321_file_close (struct ompi_file_t *fh); int mca_io_romio321_file_delete (const char *filename, struct opal_info_t *info); int mca_io_romio321_file_set_size (struct ompi_file_t *fh, MPI_Offset size); int mca_io_romio321_file_preallocate (struct ompi_file_t *fh, MPI_Offset size); int mca_io_romio321_file_get_size (struct ompi_file_t *fh, MPI_Offset * size); int mca_io_romio321_file_get_amode (struct ompi_file_t *fh, int *amode); int mca_io_romio321_file_set_info (struct ompi_file_t *fh, struct opal_info_t *info); int mca_io_romio321_file_get_info (struct ompi_file_t *fh, struct opal_info_t ** info_used); /* Section 9.3 */ int mca_io_romio321_file_set_view (struct ompi_file_t *fh, MPI_Offset disp, struct ompi_datatype_t *etype, struct ompi_datatype_t *filetype, const char *datarep, struct opal_info_t *info); int mca_io_romio321_file_get_view (struct ompi_file_t *fh, MPI_Offset * disp, struct ompi_datatype_t ** etype, struct ompi_datatype_t ** filetype, char *datarep); /* Section 9.4.2 */ int mca_io_romio321_file_read_at (struct ompi_file_t *fh, MPI_Offset offset, void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_read_at_all (struct ompi_file_t *fh, MPI_Offset offset, void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_write_at (struct ompi_file_t *fh, MPI_Offset offset, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_write_at_all (struct ompi_file_t *fh, MPI_Offset offset, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_iread_at (struct ompi_file_t *fh, MPI_Offset offset, void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_iread_at_all (struct ompi_file_t *fh, MPI_Offset offset, void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_iwrite_at (struct ompi_file_t *fh, MPI_Offset offset, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_iwrite_at_all (struct ompi_file_t *fh, MPI_Offset offset, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); /* Section 9.4.3 */ int mca_io_romio321_file_read (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_read_all (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_write (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_write_all (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_iread (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_iread_all (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_iwrite (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_iwrite_all (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_seek (struct ompi_file_t *fh, MPI_Offset offset, int whence); int mca_io_romio321_file_get_position (struct ompi_file_t *fh, MPI_Offset * offset); int mca_io_romio321_file_get_byte_offset (struct ompi_file_t *fh, MPI_Offset offset, MPI_Offset * disp); /* Section 9.4.4 */ int mca_io_romio321_file_read_shared (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_write_shared (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_iread_shared (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_iwrite_shared (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_request_t **request); int mca_io_romio321_file_read_ordered (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_write_ordered (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype, ompi_status_public_t * status); int mca_io_romio321_file_seek_shared (struct ompi_file_t *fh, MPI_Offset offset, int whence); int mca_io_romio321_file_get_position_shared (struct ompi_file_t *fh, MPI_Offset * offset); /* Section 9.4.5 */ int mca_io_romio321_file_read_at_all_begin (struct ompi_file_t *fh, MPI_Offset offset, void *buf, int count, struct ompi_datatype_t *datatype); int mca_io_romio321_file_read_at_all_end (struct ompi_file_t *fh, void *buf, ompi_status_public_t * status); int mca_io_romio321_file_write_at_all_begin (struct ompi_file_t *fh, MPI_Offset offset, const void *buf, int count, struct ompi_datatype_t *datatype); int mca_io_romio321_file_write_at_all_end (struct ompi_file_t *fh, const void *buf, ompi_status_public_t * status); int mca_io_romio321_file_read_all_begin (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype); int mca_io_romio321_file_read_all_end (struct ompi_file_t *fh, void *buf, ompi_status_public_t * status); int mca_io_romio321_file_write_all_begin (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype); int mca_io_romio321_file_write_all_end (struct ompi_file_t *fh, const void *buf, ompi_status_public_t * status); int mca_io_romio321_file_read_ordered_begin (struct ompi_file_t *fh, void *buf, int count, struct ompi_datatype_t *datatype); int mca_io_romio321_file_read_ordered_end (struct ompi_file_t *fh, void *buf, ompi_status_public_t * status); int mca_io_romio321_file_write_ordered_begin (struct ompi_file_t *fh, const void *buf, int count, struct ompi_datatype_t *datatype); int mca_io_romio321_file_write_ordered_end (struct ompi_file_t *fh, const void *buf, struct ompi_status_public_t * status); /* Section 9.5.1 */ int mca_io_romio321_file_get_type_extent (struct ompi_file_t *fh, struct ompi_datatype_t *datatype, MPI_Aint * extent); /* Section 9.6.1 */ int mca_io_romio321_file_set_atomicity (struct ompi_file_t *fh, int flag); int mca_io_romio321_file_get_atomicity (struct ompi_file_t *fh, int *flag); int mca_io_romio321_file_sync (struct ompi_file_t *fh); /* End Prototypes */ END_C_DECLS #endif /* MCA_IO_ROMIO321_H */