root/ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c

DEFINITIONS

1. ADIOI_TESTFS_IwriteContig
2. ADIOI_TESTFS_IwriteStrided

   1 /* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
   2 /* 
   3  *
   4  *   Copyright (C) 2001 University of Chicago. 
   5  *   See COPYRIGHT notice in top-level directory.
   6  */
   7 
   8 #include "ad_testfs.h"
   9 #include "adioi.h"
  10 
  11 #include "mpiu_greq.h"
  12 #include "../../mpi-io/mpioimpl.h"
  13 
  14 /* ADIOI_TESTFS_IwriteContig()
  15  *
  16  * Implemented by immediately calling WriteContig()
  17  */
  18 void ADIOI_TESTFS_IwriteContig(ADIO_File fd, const void *buf, int count,
  19                                MPI_Datatype datatype, int file_ptr_type,
  20                                ADIO_Offset offset, ADIO_Request *request, int
  21                                *error_code)
  22 {
  23     ADIO_Status status;
  24     int myrank, nprocs;
  25     MPI_Count typesize, len;
  26 
  27     *error_code = MPI_SUCCESS;
  28 
  29     MPI_Type_size_x(datatype, &typesize);
  30     MPI_Comm_size(fd->comm, &nprocs);
  31     MPI_Comm_rank(fd->comm, &myrank);
  32     FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_IwriteContig called on %s\n", 
  33             myrank, nprocs, fd->filename);
  34     FPRINTF(stdout, "[%d/%d]    calling ADIOI_TESTFS_WriteContig\n", 
  35             myrank, nprocs);
  36 
  37     len = count * typesize;
  38     ADIOI_TESTFS_WriteContig(fd, buf, len, MPI_BYTE, file_ptr_type, 
  39                              offset, &status, error_code);
  40     MPIO_Completed_request_create(&fd, len, error_code, request);
  41 
  42 }
  43 
  44 void ADIOI_TESTFS_IwriteStrided(ADIO_File fd, const void *buf, int count,
  45                                 MPI_Datatype datatype, int file_ptr_type,
  46                                 ADIO_Offset offset, ADIO_Request *request, int
  47                                 *error_code)
  48 {
  49     ADIO_Status status;
  50     int myrank, nprocs;
  51     MPI_Count typesize;
  52 
  53     *error_code = MPI_SUCCESS;
  54 
  55     MPI_Comm_size(fd->comm, &nprocs);
  56     MPI_Comm_rank(fd->comm, &myrank);
  57     MPI_Type_size_x(datatype, &typesize);
  58 
  59     FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_IwriteStrided called on %s\n", 
  60             myrank, nprocs, fd->filename);
  61     FPRINTF(stdout, "[%d/%d]    calling ADIOI_TESTFS_WriteStrided\n", 
  62             myrank, nprocs);
  63 
  64     ADIOI_TESTFS_WriteStrided(fd, buf, count, datatype, file_ptr_type, 
  65                               offset, &status, error_code);
  66     MPIO_Completed_request_create(&fd, count*typesize, error_code, request);
  67 
  68 }