root/ompi/mca/sharedfp/lockedfile/sharedfp_lockedfile.h

/* [<][>][^][v][top][bottom][index][help] */

INCLUDED FROM


   1 /*
   2  * Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
   3  *                         University Research and Technology
   4  *                         Corporation.  All rights reserved.
   5  * Copyright (c) 2004-2006 The University of Tennessee and The University
   6  *                         of Tennessee Research Foundation.  All rights
   7  *                         reserved.
   8  * Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
   9  *                         University of Stuttgart.  All rights reserved.
  10  * Copyright (c) 2004-2005 The Regents of the University of California.
  11  *                         All rights reserved.
  12  * Copyright (c) 2013-2016 University of Houston. All rights reserved.
  13  * Copyright (c) 2015-2018 Research Organization for Information Science
  14  *                         and Technology (RIST). All rights reserved.
  15  * Copyright (c) 2016-2017 IBM Corporation. All rights reserved.
  16  * $COPYRIGHT$
  17  *
  18  * Additional copyrights may follow
  19  *
  20  * $HEADER$
  21  */
  22 
  23 #ifndef MCA_SHAREDFP_LOCKEDFILE_H
  24 #define MCA_SHAREDFP_LOCKEDFILE_H
  25 
  26 #include "ompi_config.h"
  27 #include "ompi/mca/mca.h"
  28 #include "ompi/mca/sharedfp/sharedfp.h"
  29 #include "ompi/mca/common/ompio/common_ompio.h"
  30 
  31 
  32 BEGIN_C_DECLS
  33 
  34 int mca_sharedfp_lockedfile_component_init_query(bool enable_progress_threads,
  35                                                  bool enable_mpi_threads);
  36 struct mca_sharedfp_base_module_1_0_0_t *
  37         mca_sharedfp_lockedfile_component_file_query (ompio_file_t *file, int *priority);
  38 int mca_sharedfp_lockedfile_component_file_unquery (ompio_file_t *file);
  39 
  40 int mca_sharedfp_lockedfile_module_init (ompio_file_t *file);
  41 int mca_sharedfp_lockedfile_module_finalize (ompio_file_t *file);
  42 
  43 extern int mca_sharedfp_lockedfile_priority;
  44 extern int mca_sharedfp_lockedfile_verbose;
  45 
  46 OMPI_MODULE_DECLSPEC extern mca_sharedfp_base_component_2_0_0_t mca_sharedfp_lockedfile_component;
  47 /*
  48  * ******************************************************************
  49  * ********* functions which are implemented in this module *********
  50  * ******************************************************************
  51  */
  52 /*IMPORANT: Update here when implementing functions from sharedfp API*/
  53 
  54 int mca_sharedfp_lockedfile_seek (ompio_file_t *fh,
  55                                   OMPI_MPI_OFFSET_TYPE offset, int whence);
  56 int mca_sharedfp_lockedfile_get_position (ompio_file_t *fh,
  57                                           OMPI_MPI_OFFSET_TYPE * offset);
  58 int mca_sharedfp_lockedfile_file_open (struct ompi_communicator_t *comm,
  59                                        const char* filename,
  60                                        int amode,
  61                                        struct opal_info_t *info,
  62                                        ompio_file_t *fh);
  63 int mca_sharedfp_lockedfile_file_close (ompio_file_t *fh);
  64 int mca_sharedfp_lockedfile_read (ompio_file_t *fh,
  65                                   void *buf, int count, MPI_Datatype datatype, MPI_Status *status);
  66 int mca_sharedfp_lockedfile_read_ordered (ompio_file_t *fh,
  67                                           void *buf, int count, struct ompi_datatype_t *datatype,
  68                                           ompi_status_public_t *status
  69                                           );
  70 int mca_sharedfp_lockedfile_read_ordered_begin (ompio_file_t *fh,
  71                                                  void *buf,
  72                                                  int count,
  73                                                  struct ompi_datatype_t *datatype);
  74 int mca_sharedfp_lockedfile_read_ordered_end (ompio_file_t *fh,
  75                                                void *buf,
  76                                                ompi_status_public_t *status);
  77 int mca_sharedfp_lockedfile_iread (ompio_file_t *fh,
  78                                     void *buf,
  79                                     int count,
  80                                     struct ompi_datatype_t *datatype,
  81                                     ompi_request_t **request);
  82 int mca_sharedfp_lockedfile_write (ompio_file_t *fh,
  83                                    const void *buf,
  84                                    int count,
  85                                    struct ompi_datatype_t *datatype,
  86                                    ompi_status_public_t *status);
  87 int mca_sharedfp_lockedfile_write_ordered (ompio_file_t *fh,
  88                                            const void *buf,
  89                                            int count,
  90                                            struct ompi_datatype_t *datatype,
  91                                            ompi_status_public_t *status);
  92 int mca_sharedfp_lockedfile_write_ordered_begin (ompio_file_t *fh,
  93                                                  const void *buf,
  94                                                  int count,
  95                                                  struct ompi_datatype_t *datatype);
  96 int mca_sharedfp_lockedfile_write_ordered_end (ompio_file_t *fh,
  97                                                const void *buf,
  98                                                ompi_status_public_t *status);
  99 int mca_sharedfp_lockedfile_iwrite (ompio_file_t *fh,
 100                                     const void *buf,
 101                                     int count,
 102                                     struct ompi_datatype_t *datatype,
 103                                     ompi_request_t **request);
 104 
 105 /*--------------------------------------------------------------*
 106  *Structures and definitions only for this component
 107  *--------------------------------------------------------------*/
 108 
 109 /*This structure will hang off of the mca_sharedfp_base_data_t's
 110  *selected_module_data attribute
 111  */
 112 struct mca_sharedfp_lockedfile_data
 113 {
 114     int handle;
 115     char* filename;
 116 };
 117 
 118 typedef struct mca_sharedfp_lockedfile_data lockedfile_data;
 119 
 120 
 121 int mca_sharedfp_lockedfile_request_position (struct mca_sharedfp_base_data_t * sh,
 122                                               int bytes_requested,
 123                                               OMPI_MPI_OFFSET_TYPE * offset);
 124 /*
 125  * ******************************************************************
 126  * ************ functions implemented in this module end ************
 127  * ******************************************************************
 128  */
 129 
 130 END_C_DECLS
 131 
 132 #endif /* MCA_SHAREDFP_LOCKEDFILE_H */

/* [<][>][^][v][top][bottom][index][help] */