1 /* -*- Mode: C; c-basic-offset:4 ; -*- */
2 /*
3 *
4 * Copyright (C) 1997 University of Chicago.
5 * See COPYRIGHT notice in top-level directory.
6 */
7
8 #include "mpioimpl.h"
9
10 #ifdef HAVE_WEAK_SYMBOLS
11
12 #if defined(HAVE_PRAGMA_WEAK)
13 #pragma weak MPI_File_write_all_begin = PMPI_File_write_all_begin
14 #elif defined(HAVE_PRAGMA_HP_SEC_DEF)
15 #pragma _HP_SECONDARY_DEF PMPI_File_write_all_begin MPI_File_write_all_begin
16 #elif defined(HAVE_PRAGMA_CRI_DUP)
17 #pragma _CRI duplicate MPI_File_write_all_begin as PMPI_File_write_all_begin
18 /* end of weak pragmas */
19 #endif
20
21 /* Include mapping from MPI->PMPI */
22 #define MPIO_BUILD_PROFILING
23 #include "mpioprof.h"
24 #endif
25
26 /*@
27 MPI_File_write_all_begin - Begin a split collective write using
28 individual file pointer
29
30 Input Parameters:
31 . fh - file handle (handle)
32 . buf - initial address of buffer (choice)
33 . count - number of elements in buffer (nonnegative integer)
34 . datatype - datatype of each buffer element (handle)
35
36 .N fortran
37 @*/
MPI_File_write_all_begin(MPI_File mpi_fh,MPICH2_CONST void * buf,int count,MPI_Datatype datatype)38 int MPI_File_write_all_begin(MPI_File mpi_fh, MPICH2_CONST void *buf, int count,
39 MPI_Datatype datatype)
40 {
41 int error_code;
42 static char myname[] = "MPI_FILE_WRITE_ALL_BEGIN";
43
44 error_code = MPIOI_File_write_all_begin(mpi_fh, (MPI_Offset) 0,
45 ADIO_INDIVIDUAL, buf, count,
46 datatype, myname);
47
48 return error_code;
49 }
50
51 /* prevent multiple definitions of this routine */
52 #ifdef MPIO_BUILD_PROFILING
MPIOI_File_write_all_begin(MPI_File mpi_fh,MPI_Offset offset,int file_ptr_type,const void * buf,int count,MPI_Datatype datatype,char * myname)53 int MPIOI_File_write_all_begin(MPI_File mpi_fh,
54 MPI_Offset offset,
55 int file_ptr_type,
56 const void *buf,
57 int count,
58 MPI_Datatype datatype,
59 char *myname)
60 {
61 int error_code, datatype_size;
62 ADIO_File fh;
63 void *e32buf=NULL, *xbuf=NULL;
64
65 MPIU_THREAD_CS_ENTER(ALLFUNC,);
66
67 fh = MPIO_File_resolve(mpi_fh);
68
69 /* --BEGIN ERROR HANDLING-- */
70 MPIO_CHECK_FILE_HANDLE(fh, myname, error_code);
71 MPIO_CHECK_COUNT(fh, count, myname, error_code);
72 MPIO_CHECK_DATATYPE(fh, datatype, myname, error_code);
73 MPIO_CHECK_NOT_SEQUENTIAL_MODE(fh, myname, error_code);
74
75 if (file_ptr_type == ADIO_EXPLICIT_OFFSET && offset < 0)
76 {
77 error_code = MPIO_Err_create_code(MPI_SUCCESS, MPIR_ERR_RECOVERABLE,
78 myname, __LINE__, MPI_ERR_ARG,
79 "**iobadoffset", 0);
80 error_code = MPIO_Err_return_file(fh, error_code);
81 goto fn_exit;
82 }
83
84 if (fh->split_coll_count)
85 {
86 error_code = MPIO_Err_create_code(MPI_SUCCESS, MPIR_ERR_RECOVERABLE,
87 myname, __LINE__, MPI_ERR_IO,
88 "**iosplitcoll", 0);
89 error_code = MPIO_Err_return_file(fh, error_code);
90 goto fn_exit;
91 }
92 /* --END ERROR HANDLING-- */
93
94 fh->split_coll_count = 1;
95
96 MPI_Type_size(datatype, &datatype_size);
97 /* --BEGIN ERROR HANDLING-- */
98 MPIO_CHECK_INTEGRAL_ETYPE(fh, count, datatype_size, myname, error_code);
99 MPIO_CHECK_COUNT_SIZE(fh, count, datatype_size, myname, error_code);
100 /* --END ERROR HANDLING-- */
101
102
103 xbuf = (void *)buf;
104 if (fh->is_external32) {
105 error_code = MPIU_external32_buffer_setup(buf, count, datatype, &e32buf);
106 if (error_code != MPI_SUCCESS)
107 goto fn_exit;
108
109 xbuf = e32buf;
110 }
111
112 fh->split_datatype = datatype;
113 ADIO_WriteStridedColl(fh, xbuf, count, datatype, file_ptr_type,
114 offset, &fh->split_status, &error_code);
115
116 /* --BEGIN ERROR HANDLING-- */
117 if (error_code != MPI_SUCCESS)
118 error_code = MPIO_Err_return_file(fh, error_code);
119 /* --END ERROR HANDLING-- */
120
121 fn_exit:
122 if ( e32buf != NULL) ADIOI_Free(e32buf);
123 MPIU_THREAD_CS_EXIT(ALLFUNC,);
124
125 return error_code;
126 }
127 #endif
128