ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

I hate waiting on the airports. SO I start doing something usefull ...

Просмотр исходного кода 
I remove a lot of inter-dependence, I use the struct_t type.
BEWARE not all the function are ready.

This commit was SVN r3524.
Этот коммит содержится в:
George Bosilca 2004-11-05 07:52:30 +00:00
родитель 90d79bb1d1
Коммит 9659288e74
161 изменённых файлов: 277 добавлений и 298 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

4
src/attribute/attribute.c
Просмотреть файл

@ -5,9 +5,11 @@
#include "ompi_config.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#include "threads/mutex.h"
#include "include/constants.h"
#include "datatype/datatype.h"
#include "communicator/communicator.h"
#include "win/win.h"
/*
* Macros

4
src/attribute/attribute.h
Просмотреть файл

@ -15,12 +15,10 @@
#include "mpi.h"
#include "ompi_config.h"
#include "include/constants.h"
#include "class/ompi_object.h"
#include "class/ompi_bitmap.h"
#include "class/ompi_hash_table.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#include "win/win.h"
#define ATTR_HASH_SIZE 10

16
src/communicator/comm.c
Просмотреть файл

@ -7,26 +7,18 @@
#include <stdio.h>
#include "mpi.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#include "include/constants.h"
#include "proc/proc.h"
#include "threads/mutex.h"
#include "util/bit_ops.h"
#include "include/constants.h"
#include "mca/pcm/pcm.h"
#include "mca/pml/pml.h"
#include "mca/coll/coll.h"
#include "mca/coll/base/base.h"
#include "mca/topo/topo.h"
#include "mca/topo/base/base.h"
#include "mca/ns/base/base.h"
#include "mca/pml/pml.h"
#include "mca/ptl/ptl.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#include "mca/ptl/base/ptl_base_comm.h"
#include "mca/ptl/base/ptl_base_recvfrag.h"
#include "mca/ptl/base/ptl_base_header.h"
#include "mca/ptl/base/ptl_base_match.h"
/*

6
src/communicator/comm_init.c
Просмотреть файл

@ -8,17 +8,15 @@
#include "mpi.h"
#include "communicator/communicator.h"
#include "util/bit_ops.h"
#include "include/constants.h"
#include "mca/pml/pml.h"
#include "mca/coll/coll.h"
#include "mca/coll/base/base.h"
#include "mca/topo/topo.h"
#include "mca/topo/base/base.h"
#include "mca/ns/base/base.h"
#include "mpi/runtime/params.h"
#include "communicator/communicator.h"
#include "attribute/attribute.h"
/*
** Table for Fortran <-> C communicator handle conversion

5
src/communicator/communicator.h
Просмотреть файл

@ -6,17 +6,16 @@
#define OMPI_COMMUNICATOR_H
#include "class/ompi_object.h"
#include "class/ompi_hash_table.h"
#include "errhandler/errhandler.h"
#include "threads/mutex.h"
#include "threads/mutex.h"
#include "util/output.h"
#include "mpi.h"
#include "group/group.h"
#include "mca/coll/coll.h"
#include "mca/topo/topo.h"
#include "class/ompi_hash_table.h"
#include "attribute/attribute.h"
#include "request/request.h"
#include "threads/mutex.h"
#if defined(c_plusplus) || defined(__cplusplus)
extern "C" {

1
src/errhandler/errcode-internal.c
Просмотреть файл

@ -8,7 +8,6 @@
#include <string.h>
#include "mpi.h"
#include "include/constants.h"
#include "errhandler/errcode-internal.h"
/* Table holding all error codes */

9
src/file/file.c
Просмотреть файл

@ -8,7 +8,8 @@
#include "class/ompi_list.h"
#include "mpi/runtime/params.h"
#include "mca/io/base/base.h"
#include "info/info.h"
#include "util/output.h"
/*
* Table for Fortran <-> C file handle conversion
@ -65,8 +66,8 @@ int ompi_file_init(void)
/*
* Back end to MPI_FILE_OPEN
*/
int ompi_file_open(ompi_communicator_t *comm, char *filename,
int amode, ompi_info_t *info, ompi_file_t **fh)
int ompi_file_open(struct ompi_communicator_t *comm, char *filename,
int amode, struct ompi_info_t *info, ompi_file_t **fh)
{
int ret;
ompi_file_t *file;
@ -178,7 +179,7 @@ int ompi_file_finalize(void)
we're destroying everything, it isn't worth it */
}
if (num_unnamed > 0) {
ompi_output(0, "WANRING: %d unnamed MPI_File handles still allocated at MPI_FINALIZE", num_unnamed);
ompi_output(0, "WARNING: %d unnamed MPI_File handles still allocated at MPI_FINALIZE", num_unnamed);
}
OBJ_DESTRUCT(&ompi_file_f_to_c_table);

13
src/file/file.h
Просмотреть файл

@ -7,12 +7,9 @@
#include "mpi.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#include "threads/mutex.h"
#include "info/info.h"
#include "mca/io/io.h"
/*
* Flags
*/
@ -31,7 +28,7 @@ struct ompi_file_t {
ompi_object_t super;
/** Communicator that this file was created with */
ompi_communicator_t *f_comm;
struct ompi_communicator_t *f_comm;
/** Filename that this file was created with */
char *f_filename;
@ -40,7 +37,7 @@ struct ompi_file_t {
int f_amode;
/** MPI_Info that this file was created with */
ompi_info_t *f_info;
struct ompi_info_t *f_info;
/** Bit flags */
int32_t f_flags;
@ -51,7 +48,7 @@ struct ompi_file_t {
/** Error handler. This field does not have the "f_" prefix so
that the OMPI_ERRHDL_* macros can find it, regardless of
whether it's a comm, window, or file. */
ompi_errhandler_t *error_handler;
struct ompi_errhandler_t *error_handler;
/** Type of the error handler. This field does not have the "f_"
prefix for the same reason as the field error_handler. */
@ -115,8 +112,8 @@ OMPI_DECLSPEC extern ompi_pointer_array_t ompi_file_f_to_c_table;
* mainly calls OBJ_RELEASE() but also does some other error
* handling as well.
*/
int ompi_file_open(ompi_communicator_t *comm, char *filename,
int amode, ompi_info_t *info,
int ompi_file_open(struct ompi_communicator_t *comm, char *filename,
int amode, struct ompi_info_t *info,
ompi_file_t **fh);
/**

3
src/group/group.c
Просмотреть файл

@ -7,14 +7,13 @@
#include "include/constants.h"
#include "mpi.h"
int ompi_group_translate_ranks ( ompi_group_t *group1,
int n_ranks, int *ranks1,
ompi_group_t *group2,
int *ranks2)
{
int rank, proc, proc2;
ompi_proc_t *proc1_pointer, *proc2_pointer;
struct ompi_proc_t *proc1_pointer, *proc2_pointer;
/* loop over all ranks */
for (proc = 0; proc < n_ranks; proc++) {

7
src/group/group.h
Просмотреть файл

@ -13,7 +13,6 @@
#include "util/output.h"
#include "mpi.h"
#include "proc/proc.h"
#include "class/ompi_pointer_array.h"
#if defined(c_plusplus) || defined(__cplusplus)
extern "C" {
@ -27,7 +26,7 @@ struct ompi_group_t {
int grp_my_rank; /**< rank in group */
int grp_f_to_c_index; /**< index in Fortran <-> C translation array */
uint32_t grp_flags; /**< flags, e.g. freed, cannot be freed etc.*/
ompi_proc_t **grp_proc_pointers;
struct ompi_proc_t **grp_proc_pointers;
/**< list of pointers to ompi_proc_t structures
for each process in the group */
};
@ -44,7 +43,7 @@ OMPI_DECLSPEC OBJ_CLASS_DECLARATION(ompi_group_t);
/**
* Table for Fortran <-> C group handle conversion
*/
OMPI_DECLSPEC extern ompi_pointer_array_t *ompi_group_f_to_c_table;
OMPI_DECLSPEC extern struct ompi_pointer_array_t *ompi_group_f_to_c_table;
OMPI_DECLSPEC extern ompi_group_t ompi_mpi_group_null;
@ -123,7 +122,7 @@ static inline int ompi_group_rank(ompi_group_t *group)
*
* @return Error code
*/
void ompi_set_group_rank(ompi_group_t *group, ompi_proc_t *proc_pointer);
void ompi_set_group_rank(ompi_group_t *group, struct ompi_proc_t *proc_pointer);
/**
* Abstracting MPI_Group_translate_ranks to an ompi function for internal use

4
src/group/mpi_group_init.c
Просмотреть файл

@ -46,8 +46,8 @@ ompi_group_t *ompi_group_allocate(int group_size)
} else {
/* allocate array of (ompi_proc_t *)'s, one for each
* process in the group */
new_group->grp_proc_pointers = (ompi_proc_t **)
malloc(sizeof(ompi_proc_t *) * group_size);
new_group->grp_proc_pointers = (struct ompi_proc_t **)
malloc(sizeof(struct ompi_proc_t *) * group_size);
if (0 < group_size) {
/* non-empty group */
if (!new_group->grp_proc_pointers) {

2
src/group/mpi_set_group_rank.c
Просмотреть файл

@ -9,7 +9,7 @@
/*
* Set group rank in a group structure.
*/
void ompi_set_group_rank(ompi_group_t *group, ompi_proc_t *proc_pointer)
void ompi_set_group_rank(ompi_group_t *group, struct ompi_proc_t *proc_pointer)
{
/* local variables */
int proc;

7
src/include/types.h
Просмотреть файл

@ -95,3 +95,10 @@ typedef socklen_t ompi_socklen_t;
typedef int ompi_socklen_t;
#endif
#endif
/* Predefine some internal types so we dont need all the include dependencies. */
struct ompi_communicator_t;
struct ompi_datatype_t;
struct ompi_convertor_t;
struct ompi_bitmap_t;

1
src/info/info.c
Просмотреть файл

@ -4,7 +4,6 @@
#include "ompi_config.h"
#include "info/info.h"
#include "include/constants.h"
#include "mpi/runtime/params.h"
#include "util/output.h"

2
src/mca/allocator/base/allocator_base_open.c
Просмотреть файл

@ -5,13 +5,13 @@
#include "ompi_config.h"
#include <stdio.h>
#include <string.h>
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/allocator/allocator.h"
#include "mca/allocator/base/base.h"
/*
* The following file was created by configure. It contains extern
* statements and the definition of an array of pointers to each

2
src/mca/base/mca_base_close.c
Просмотреть файл

@ -7,7 +7,7 @@
#include "util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "include/constants.h"
/*
* Main MCA shutdown.

2
src/mca/base/mca_base_components_close.c
Просмотреть файл

@ -8,7 +8,7 @@
#include "util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "include/constants.h"
int mca_base_components_close(int output_id,
ompi_list_t *components_available,

2
src/mca/base/mca_base_components_open.c
Просмотреть файл

@ -14,7 +14,7 @@
#include "util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "include/constants.h"
struct component_name_t {
ompi_list_item_t super;

2
src/mca/base/mca_base_msgbuf.c
Просмотреть файл

@ -7,7 +7,7 @@
#include "util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "include/constants.h"
#include "mca/base/mca_base_msgbuf_internal.h"
/*

2
src/mca/base/mca_base_open.c
Просмотреть файл

@ -10,12 +10,12 @@
#if HAVE_SYSLOG_H
#include <syslog.h>
#endif
#include "include/constants.h"
#include "util/output.h"
#include "util/printf.h"
#include "mca/mca.h"
#include "mca/base/base.h"
/*
* Public variables
*/

2
src/mca/base/mca_base_parse_paramfile.c
Просмотреть файл

@ -5,7 +5,9 @@
#include "ompi_config.h"
#include <stdio.h>
#include <string.h>
#include "include/constants.h"
#include "class/ompi_list.h"
#include "util/output.h"
#include "mca/mca.h"

1
src/mca/coll/base/coll_base_find_available.c
Просмотреть файл

@ -6,6 +6,7 @@
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "mpi.h"
#include "include/constants.h"

1
src/mca/coll/base/coll_base_open.c
Просмотреть файл

@ -6,6 +6,7 @@
#include "ompi_config.h"
#include <stdio.h>
#include "include/constants.h"
#include "util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"

2
src/mca/coll/coll.h
Просмотреть файл

@ -39,7 +39,7 @@ typedef int (*mca_coll_base_module_allgather_fn_t)
void *rbuf, int rcount, struct ompi_datatype_t *rdtype,
struct ompi_communicator_t *comm);
typedef int (*mca_coll_base_module_allgatherv_fn_t)
(void *sbuf, int scount, ompi_datatype_t *sdtype,
(void *sbuf, int scount, struct ompi_datatype_t *sdtype,
void * rbuf, int *rcounts, int *disps, struct ompi_datatype_t *rdtype,
struct ompi_communicator_t *comm);
typedef int (*mca_coll_base_module_allreduce_fn_t)

31
src/mca/io/base/io_base_delete.c
Просмотреть файл

@ -10,15 +10,14 @@
#include "mpi.h"
#include "file/file.h"
#include "util/argv.h"
#include "class/ompi_list.h"
#include "class/ompi_object.h"
#include "util/argv.h"
#include "util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/io/io.h"
#include "mca/io/base/base.h"
/*
* Local types
*/
@ -37,19 +36,19 @@ typedef struct avail_io_t avail_io_t;
* Local functions
*/
static ompi_list_t *check_components(ompi_list_t *components,
char *filename, ompi_info_t *info,
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, ompi_info_t *info);
char *filename, struct ompi_info_t *info);
static avail_io_t *query(const mca_base_component_t *component,
char *filename, ompi_info_t *info);
char *filename, struct ompi_info_t *info);
static avail_io_t *query_1_0_0(const mca_io_base_component_1_0_0_t *io_component,
char *filename, ompi_info_t *info);
char *filename, struct ompi_info_t *info);
static void unquery(avail_io_t *avail, char *filename, ompi_info_t *info);
static void unquery(avail_io_t *avail, char *filename, struct ompi_info_t *info);
static int delete_file(avail_io_t *avail, char *filename, ompi_info_t *info);
static int delete_file(avail_io_t *avail, char *filename, struct ompi_info_t *info);
/*
@ -60,7 +59,7 @@ static OBJ_CLASS_INSTANCE(avail_io_t, ompi_list_item_t, NULL, NULL);
/*
*/
int mca_io_base_delete(char *filename, ompi_info_t *info)
int mca_io_base_delete(char *filename, struct ompi_info_t *info)
{
int err, num_names;
char *names, **name_array;
@ -172,7 +171,7 @@ int mca_io_base_delete(char *filename, ompi_info_t *info)
* priority order.
*/
static ompi_list_t *check_components(ompi_list_t *components,
char *filename, ompi_info_t *info,
char *filename, struct ompi_info_t *info,
char **names, int num_names)
{
int i;
@ -265,7 +264,7 @@ static ompi_list_t *check_components(ompi_list_t *components,
* Check a single component
*/
static avail_io_t *check_one_component(const mca_base_component_t *component,
char *filename, ompi_info_t *info)
char *filename, struct ompi_info_t *info)
{
avail_io_t *avail;
@ -298,7 +297,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, ompi_info_t *info)
char *filename, struct ompi_info_t *info)
{
const mca_io_base_component_1_0_0_t *ioc_100;
@ -319,7 +318,7 @@ static avail_io_t *query(const mca_base_component_t *component,
static avail_io_t *query_1_0_0(const mca_io_base_component_1_0_0_t *component,
char *filename, ompi_info_t *info)
char *filename, struct ompi_info_t *info)
{
bool usable;
int priority, ret;
@ -349,7 +348,7 @@ static avail_io_t *query_1_0_0(const mca_io_base_component_1_0_0_t *component,
* Unquery functions
**************************************************************************/
static void unquery(avail_io_t *avail, char *filename, ompi_info_t *info)
static void unquery(avail_io_t *avail, char *filename, struct ompi_info_t *info)
{
const mca_io_base_component_1_0_0_t *ioc_100;
@ -374,7 +373,7 @@ static void unquery(avail_io_t *avail, char *filename, ompi_info_t *info)
/*
* Invoke the component's delete function
*/
static int delete_file(avail_io_t *avail, char *filename, ompi_info_t *info)
static int delete_file(avail_io_t *avail, char *filename, struct ompi_info_t *info)
{
const mca_io_base_component_1_0_0_t *ioc_100;

1
src/mca/io/base/io_base_file_select.c
Просмотреть файл

@ -11,6 +11,7 @@
#include "mpi.h"
#include "file/file.h"
#include "util/argv.h"
#include "util/output.h"
#include "class/ompi_list.h"
#include "class/ompi_object.h"
#include "mca/mca.h"

168
src/mca/io/romio/src/io_romio.h
Просмотреть файл

@ -53,212 +53,212 @@ typedef struct mca_io_romio_data_t mca_io_romio_data_t;
* ROMIO_PREFIX(MPI_File_XXX)
*/
/* Section 9.2 */
int mca_io_romio_file_open (ompi_communicator_t *comm,
int mca_io_romio_file_open (struct ompi_communicator_t *comm,
char *filename,
int amode,
ompi_info_t *info,
struct ompi_info_t *info,
ompi_file_t *fh);
int mca_io_romio_file_close (ompi_file_t *fh);
int mca_io_romio_file_close (struct ompi_file_t *fh);
int mca_io_romio_file_delete (char *filename,
ompi_info_t *info);
int mca_io_romio_file_set_size (ompi_file_t *fh,
struct ompi_info_t *info);
int mca_io_romio_file_set_size (struct ompi_file_t *fh,
MPI_Offset size);
int mca_io_romio_file_preallocate (ompi_file_t *fh,
int mca_io_romio_file_preallocate (struct ompi_file_t *fh,
MPI_Offset size);
int mca_io_romio_file_get_size (ompi_file_t *fh,
int mca_io_romio_file_get_size (struct ompi_file_t *fh,
MPI_Offset * size);
int mca_io_romio_file_get_amode (ompi_file_t *fh,
int mca_io_romio_file_get_amode (struct ompi_file_t *fh,
int *amode);
int mca_io_romio_file_set_info (ompi_file_t *fh,
ompi_info_t *info);
int mca_io_romio_file_get_info (ompi_file_t *fh,
ompi_info_t ** info_used);
int mca_io_romio_file_set_info (struct ompi_file_t *fh,
struct ompi_info_t *info);
int mca_io_romio_file_get_info (struct ompi_file_t *fh,
struct ompi_info_t ** info_used);
/* Section 9.3 */
int mca_io_romio_file_set_view (ompi_file_t *fh,
int mca_io_romio_file_set_view (struct ompi_file_t *fh,
MPI_Offset disp,
ompi_datatype_t *etype,
ompi_datatype_t *filetype,
struct ompi_datatype_t *etype,
struct ompi_datatype_t *filetype,
char *datarep,
ompi_info_t *info);
int mca_io_romio_file_get_view (ompi_file_t *fh,
struct ompi_info_t *info);
int mca_io_romio_file_get_view (struct ompi_file_t *fh,
MPI_Offset * disp,
ompi_datatype_t ** etype,
ompi_datatype_t ** filetype,
struct ompi_datatype_t ** etype,
struct ompi_datatype_t ** filetype,
char *datarep);
/* Section 9.4.2 */
int mca_io_romio_file_read_at (ompi_file_t *fh,
int mca_io_romio_file_read_at (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_read_at_all (ompi_file_t *fh,
int mca_io_romio_file_read_at_all (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_write_at (ompi_file_t *fh,
int mca_io_romio_file_write_at (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_write_at_all (ompi_file_t *fh,
int mca_io_romio_file_write_at_all (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_iread_at (ompi_file_t *fh,
int mca_io_romio_file_iread_at (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
mca_io_base_request_t * request);
int mca_io_romio_file_iwrite_at (ompi_file_t *fh,
int mca_io_romio_file_iwrite_at (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
mca_io_base_request_t * request);
/* Section 9.4.3 */
int mca_io_romio_file_read (ompi_file_t *fh,
int mca_io_romio_file_read (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_read_all (ompi_file_t *fh,
int mca_io_romio_file_read_all (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_write (ompi_file_t *fh,
int mca_io_romio_file_write (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_write_all (ompi_file_t *fh,
int mca_io_romio_file_write_all (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_iread (ompi_file_t *fh,
int mca_io_romio_file_iread (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
mca_io_base_request_t * request);
int mca_io_romio_file_iwrite (ompi_file_t *fh,
int mca_io_romio_file_iwrite (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
mca_io_base_request_t * request);
int mca_io_romio_file_seek (ompi_file_t *fh,
int mca_io_romio_file_seek (struct ompi_file_t *fh,
MPI_Offset offset,
int whence);
int mca_io_romio_file_get_position (ompi_file_t *fh,
int mca_io_romio_file_get_position (struct ompi_file_t *fh,
MPI_Offset * offset);
int mca_io_romio_file_get_byte_offset (ompi_file_t *fh,
int mca_io_romio_file_get_byte_offset (struct ompi_file_t *fh,
MPI_Offset offset,
MPI_Offset * disp);
/* Section 9.4.4 */
int mca_io_romio_file_read_shared (ompi_file_t *fh,
int mca_io_romio_file_read_shared (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_write_shared (ompi_file_t *fh,
int mca_io_romio_file_write_shared (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_iread_shared (ompi_file_t *fh,
int mca_io_romio_file_iread_shared (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
mca_io_base_request_t * request);
int mca_io_romio_file_iwrite_shared (ompi_file_t *fh,
int mca_io_romio_file_iwrite_shared (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
mca_io_base_request_t * request);
int mca_io_romio_file_read_ordered (ompi_file_t *fh,
int mca_io_romio_file_read_ordered (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_write_ordered (ompi_file_t *fh,
int mca_io_romio_file_write_ordered (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
ompi_status_public_t * status);
int mca_io_romio_file_seek_shared (ompi_file_t *fh,
int mca_io_romio_file_seek_shared (struct ompi_file_t *fh,
MPI_Offset offset,
int whence);
int mca_io_romio_file_get_position_shared (ompi_file_t *fh,
int mca_io_romio_file_get_position_shared (struct ompi_file_t *fh,
MPI_Offset * offset);
/* Section 9.4.5 */
int mca_io_romio_file_read_at_all_begin (ompi_file_t *fh,
int mca_io_romio_file_read_at_all_begin (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype);
int mca_io_romio_file_read_at_all_end (ompi_file_t *fh,
struct ompi_datatype_t *datatype);
int mca_io_romio_file_read_at_all_end (struct ompi_file_t *fh,
void *buf,
ompi_status_public_t * status);
int mca_io_romio_file_write_at_all_begin (ompi_file_t *fh,
int mca_io_romio_file_write_at_all_begin (struct ompi_file_t *fh,
MPI_Offset offset,
void *buf,
int count,
ompi_datatype_t *datatype);
int mca_io_romio_file_write_at_all_end (ompi_file_t *fh,
struct ompi_datatype_t *datatype);
int mca_io_romio_file_write_at_all_end (struct ompi_file_t *fh,
void *buf,
ompi_status_public_t * status);
int mca_io_romio_file_read_all_begin (ompi_file_t *fh,
int mca_io_romio_file_read_all_begin (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype);
int mca_io_romio_file_read_all_end (ompi_file_t *fh,
struct ompi_datatype_t *datatype);
int mca_io_romio_file_read_all_end (struct ompi_file_t *fh,
void *buf,
ompi_status_public_t * status);
int mca_io_romio_file_write_all_begin (ompi_file_t *fh,
int mca_io_romio_file_write_all_begin (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype);
int mca_io_romio_file_write_all_end (ompi_file_t *fh,
struct ompi_datatype_t *datatype);
int mca_io_romio_file_write_all_end (struct ompi_file_t *fh,
void *buf,
ompi_status_public_t * status);
int mca_io_romio_file_read_ordered_begin (ompi_file_t *fh,
int mca_io_romio_file_read_ordered_begin (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype);
int mca_io_romio_file_read_ordered_end (ompi_file_t *fh,
struct ompi_datatype_t *datatype);
int mca_io_romio_file_read_ordered_end (struct ompi_file_t *fh,
void *buf,
ompi_status_public_t * status);
int mca_io_romio_file_write_ordered_begin (ompi_file_t *fh,
int mca_io_romio_file_write_ordered_begin (struct ompi_file_t *fh,
void *buf,
int count,
ompi_datatype_t *datatype);
int mca_io_romio_file_write_ordered_end (ompi_file_t *fh,
struct ompi_datatype_t *datatype);
int mca_io_romio_file_write_ordered_end (struct ompi_file_t *fh,
void *buf,
ompi_status_public_t * status);
struct ompi_status_public_t * status);
/* Section 9.5.1 */
int mca_io_romio_file_get_type_extent (ompi_file_t *fh,
ompi_datatype_t *datatype,
int mca_io_romio_file_get_type_extent (struct ompi_file_t *fh,
struct ompi_datatype_t *datatype,
MPI_Aint * extent);
/* Section 9.6.1 */
int mca_io_romio_file_set_atomicity (ompi_file_t *fh,
int mca_io_romio_file_set_atomicity (struct ompi_file_t *fh,
int flag);
int mca_io_romio_file_get_atomicity (ompi_file_t *fh,
int mca_io_romio_file_get_atomicity (struct ompi_file_t *fh,
int *flag);
int mca_io_romio_file_sync (ompi_file_t *fh);
int mca_io_romio_file_sync (struct ompi_file_t *fh);
/* End Prototypes */

1
src/mca/mpool/base/mpool_base_lookup.c
Просмотреть файл

@ -5,6 +5,7 @@
#include "ompi_config.h"
#include <stdio.h>
#include <string.h>
#include "mca/mca.h"
#include "mca/base/base.h"

2
src/mca/mpool/base/mpool_base_open.c
Просмотреть файл

@ -10,7 +10,7 @@
#include "mca/base/base.h"
#include "mca/mpool/mpool.h"
#include "mca/mpool/base/base.h"
#include "include/constants.h"
/*
* The following file was created by configure. It contains extern

1
src/mca/ns/base/ns_base_open.c
Просмотреть файл

@ -4,6 +4,7 @@
#include "ompi_config.h"
#include "include/constants.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/base/mca_base_param.h"

1
src/mca/oob/base/oob_base_init.c
Просмотреть файл

@ -5,6 +5,7 @@
#include "ompi_config.h"
#include <stdio.h>
#include <string.h>
#include "runtime/runtime.h"
#include "util/output.h"

1
src/mca/oob/base/oob_base_open.c
Просмотреть файл

@ -4,6 +4,7 @@
#include "ompi_config.h"
#include "include/constants.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/base/mca_base_param.h"

1
src/mca/pcmclient/base/pcmclient_base_open.c
Просмотреть файл

@ -4,6 +4,7 @@
#include "ompi_config.h"
#include "include/constants.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/pcmclient/pcmclient.h"

2
src/mca/pml/teg/src/pml_teg.c
Просмотреть файл

@ -6,6 +6,8 @@
#include <stdlib.h>
#include <string.h>
#include "class/ompi_bitmap.h"
#include "mca/pml/pml.h"
#include "mca/ptl/ptl.h"
#include "mca/ptl/base/base.h"

3
src/mca/ptl/prof/ptl_prof.c
Просмотреть файл

@ -1,11 +1,12 @@
#include "ompi_config.h"
#include "ptl_prof.h"
#include "class/ompi_bitmap.h"
static int ptl_prof_add_procs_fn( struct mca_ptl_base_module_t* ptl,
size_t nprocs,
struct ompi_proc_t** procs,
struct mca_ptl_base_peer_t** peer,
ompi_bitmap_t* reachable )
struct ompi_bitmap_t* reachable )
{
return 0;
}

7
src/mca/ptl/ptl.h
Просмотреть файл

@ -232,9 +232,8 @@
#include "mca/mca.h"
#include "include/ompi.h"
#include "class/ompi_list.h"
#include "proc/proc.h"
#include "mca/pml/pml.h"
#include "include/types.h"
/*
* PTL types
@ -251,7 +250,7 @@ struct mca_ptl_base_match_header_t;
typedef uint64_t mca_ptl_sequence_t;
typedef uint64_t mca_ptl_tstamp_t;
typedef ompi_list_t mca_ptl_queue_t;
typedef struct ompi_list_t mca_ptl_queue_t;
typedef enum {
MCA_PTL_ENABLE
@ -395,7 +394,7 @@ typedef int (*mca_ptl_base_module_add_procs_fn_t)(
size_t nprocs,
struct ompi_proc_t** procs,
struct mca_ptl_base_peer_t** peer,
ompi_bitmap_t* reachable
struct ompi_bitmap_t* reachable
);
/**

1
src/mca/ptl/self/ptl_self.c
Просмотреть файл

@ -23,6 +23,7 @@
#endif
#include "include/constants.h"
#include "class/ompi_bitmap.h"
#include "event/event.h"
#include "util/argv.h"
#include "util/output.h"

20
src/mca/ptl/self/ptl_self.h
Просмотреть файл

@ -25,15 +25,15 @@ extern "C" {
struct mca_ptl_self_component_t {
mca_ptl_base_component_1_0_0_t super; /**< base PTL component */
struct mca_ptl_base_module_t** self_ptl_modules; /**< array of available PTL modules */
uint32_t self_num_ptl_modules; /**< number of ptl modules actually used */
uint32_t self_max_ptl_modules; /**< maximum number of ptl modules */
uint32_t self_buf_size; /**< the size of the internal buffer used to pack/unpack the data */
uint32_t self_is_non_blocking; /**< how the memcopy operations are done segmented or not */
int32_t self_free_list_num; /**< initial size of free lists */
int32_t self_free_list_max; /**< maximum size of free lists */
int32_t self_free_list_inc; /**< number of elements to alloc when growing free lists */
ompi_free_list_t self_send_requests; /**< free list of self send requests -- sendreq + sendfrag */
ompi_proc_t* self_local; /**< the self proc instance corresponding to the local process */
uint32_t self_num_ptl_modules; /**< number of ptl modules actually used */
uint32_t self_max_ptl_modules; /**< maximum number of ptl modules */
uint32_t self_buf_size; /**< the size of the internal buffer used to pack/unpack the data */
uint32_t self_is_non_blocking; /**< how the memcopy operations are done segmented or not */
int32_t self_free_list_num; /**< initial size of free lists */
int32_t self_free_list_max; /**< maximum size of free lists */
int32_t self_free_list_inc; /**< number of elements to alloc when growing free lists */
ompi_free_list_t self_send_requests; /**< free list of self send requests -- sendreq + sendfrag */
struct ompi_proc_t* self_local; /**< the self proc instance corresponding to the local process */
};
typedef struct mca_ptl_self_component_t mca_ptl_self_component_t;
@ -76,7 +76,7 @@ extern mca_ptl_base_module_t** mca_ptl_self_component_init(
bool *have_hidden_threads
);
int mca_ptl_self_add_proc(struct mca_ptl_base_module_t* ptl, size_t nprocs, struct ompi_proc_t **ompi_proc, struct mca_ptl_base_peer_t** peer_ret, ompi_bitmap_t* reachable);
int mca_ptl_self_add_proc(struct mca_ptl_base_module_t* ptl, size_t nprocs, struct ompi_proc_t **ompi_proc, struct mca_ptl_base_peer_t** peer_ret, struct ompi_bitmap_t* reachable);
int mca_ptl_self_del_proc(struct mca_ptl_base_module_t* ptl, size_t nprocs, struct ompi_proc_t **proc, struct mca_ptl_base_peer_t** ptl_peer);
int mca_ptl_self_finalize(struct mca_ptl_base_module_t* ptl);
int mca_ptl_self_request_init(struct mca_ptl_base_module_t* ptl, struct mca_pml_base_send_request_t* request);

2
src/mca/ptl/sm/src/ptl_sm.h
Просмотреть файл

@ -194,7 +194,7 @@ extern int mca_ptl_sm_add_procs(
size_t nprocs,
struct ompi_proc_t **procs,
struct mca_ptl_base_peer_t** peers,
ompi_bitmap_t* reachability
struct ompi_bitmap_t* reachability
);

1
src/mca/ptl/tcp/src/ptl_tcp.c
Просмотреть файл

@ -4,6 +4,7 @@
#include "ompi_config.h"
#include <string.h>
#include "class/ompi_bitmap.h"
#include "util/output.h"
#include "util/if.h"
#include "mca/pml/pml.h"

2
src/mca/ptl/tcp/src/ptl_tcp.h
Просмотреть файл

@ -155,7 +155,7 @@ extern int mca_ptl_tcp_add_procs(
size_t nprocs,
struct ompi_proc_t **procs,
struct mca_ptl_base_peer_t** peers,
ompi_bitmap_t* reachable
struct ompi_bitmap_t* reachable
);

2
src/mca/ptl/tcp/src/ptl_tcp_component.c
Просмотреть файл

@ -192,7 +192,7 @@ int mca_ptl_tcp_component_open(void)
mca_ptl_tcp_param_register_int("max_frag_size", -1);
/* the tcp allocator will never allocate buffers with more than this size */
mca_ptl_tcp_component.tcp_frag_size =
mca_ptl_tcp_param_register_int("frag_size", 16*1024);
mca_ptl_tcp_param_register_int("frag_size", 64*1024);
/* adapt the first fragment size to fit with the allowed fragment size */
if( (mca_ptl_tcp_component.tcp_frag_size != 0) &&
(mca_ptl_tcp_module.super.ptl_first_frag_size > mca_ptl_tcp_component.tcp_frag_size) ) {

1
src/mca/svc/base/svc_base_open.c
Просмотреть файл

@ -6,6 +6,7 @@
#include <stdio.h>
#include "include/constants.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/svc/svc.h"

4
src/mca/svc/exec/svc_exec.c
Просмотреть файл

@ -1,4 +1,8 @@
#include "ompi_config.h"
#include <unistd.h>
#include "include/constants.h"
#include "mca/oob/oob.h"
#include "mca/oob/base/base.h"
#include "svc_exec.h"

2
src/mca/svc/exec/svc_exec_component.c
Просмотреть файл

@ -1,4 +1,6 @@
#include "ompi_config.h"
#include "include/constants.h"
#include "svc_exec.h"

3
src/mca/svc/sched/svc_sched_node.c
Просмотреть файл

@ -1,4 +1,7 @@
#include "ompi_config.h"
#include <string.h>
#include "svc_sched_node.h"

1
src/mca/svc/stdio/svc_stdio.c
Просмотреть файл

@ -1,4 +1,5 @@
#include "ompi_config.h"
#include "include/constants.h"
#include "mca/oob/oob.h"
#include "mca/oob/base/base.h"
#include "svc_stdio.h"

1
src/mca/svc/stdio/svc_stdio_component.c
Просмотреть файл

@ -1,4 +1,5 @@
#include "ompi_config.h"
#include "include/constants.h"
#include "svc_stdio.h"

2
src/mca/topo/base/topo_base_comm_select.c
Просмотреть файл

@ -4,6 +4,8 @@
#include "ompi_config.h"
#include <string.h>
#include "class/ompi_list.h"
#include "util/argv.h"
#include "runtime/runtime.h"

2
src/mca/topo/base/topo_base_open.c
Просмотреть файл

@ -3,8 +3,10 @@
*/
#include "ompi_config.h"
#include <stdio.h>
#include "include/constants.h"
#include "util/output.h"
#include "class/ompi_list.h"
#include "mca/mca.h"

1
src/mpi/c/allgather.c
Просмотреть файл

@ -9,6 +9,7 @@
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Allgather = PMPI_Allgather

1
src/mpi/c/allgatherv.c
Просмотреть файл

@ -9,6 +9,7 @@
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Allgatherv = PMPI_Allgatherv

1
src/mpi/c/alltoall.c
Просмотреть файл

@ -9,6 +9,7 @@
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Alltoall = PMPI_Alltoall

1
src/mpi/c/alltoallv.c
Просмотреть файл

@ -9,6 +9,7 @@
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Alltoallv = PMPI_Alltoallv

1
src/mpi/c/alltoallw.c
Просмотреть файл

@ -9,6 +9,7 @@
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Alltoallw = PMPI_Alltoallw

1
src/mpi/c/attr_delete.c
Просмотреть файл

@ -8,6 +8,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Attr_delete = PMPI_Attr_delete

1
src/mpi/c/attr_get.c
Просмотреть файл

@ -8,6 +8,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Attr_get = PMPI_Attr_get

1
src/mpi/c/attr_put.c
Просмотреть файл

@ -8,6 +8,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Attr_put = PMPI_Attr_put

1
src/mpi/c/bcast.c
Просмотреть файл

@ -8,6 +8,7 @@
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Bcast = PMPI_Bcast

1
src/mpi/c/comm_create_keyval.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Comm_create_keyval = PMPI_Comm_create_keyval

1
src/mpi/c/comm_delete_attr.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Comm_delete_attr = PMPI_Comm_delete_attr

1
src/mpi/c/comm_free_keyval.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Comm_free_keyval = PMPI_Comm_free_keyval

1
src/mpi/c/comm_get_attr.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Comm_get_attr = PMPI_Comm_get_attr

1
src/mpi/c/comm_set_attr.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Comm_set_attr = PMPI_Comm_set_attr

1
src/mpi/c/gather.c
Просмотреть файл

@ -8,6 +8,7 @@
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Gather = PMPI_Gather

2
src/mpi/c/gatherv.c
Просмотреть файл

@ -7,8 +7,8 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Gatherv = PMPI_Gatherv

2
src/mpi/c/get_count.c
Просмотреть файл

@ -7,7 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "communicator/communicator.h"
#include "errhandler/errhandler.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Get_count = PMPI_Get_count

2
src/mpi/c/get_elements.c
Просмотреть файл

@ -7,7 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "communicator/communicator.h"
#include "errhandler/errhandler.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Get_elements = PMPI_Get_elements

3
src/mpi/c/grequest_complete.c
Просмотреть файл

@ -8,7 +8,6 @@
#include "mpi/c/bindings.h"
#include "communicator/communicator.h"
#include "request/grequest.h"
#include "errhandler/errhandler.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Grequest_complete = PMPI_Grequest_complete
@ -33,7 +32,7 @@ int MPI_Grequest_complete(MPI_Request request)
}
switch(request->req_type) {
OMPI_REQUEST_GEN:
case OMPI_REQUEST_GEN:
rc = ompi_grequest_complete((ompi_grequest_t*)request);
break;
default:

2
src/mpi/c/intercomm_merge.c
Просмотреть файл

@ -3,7 +3,7 @@
*/
#include "ompi_config.h"
#include <string.h>
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "communicator/communicator.h"

1
src/mpi/c/keyval_create.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Keyval_create = PMPI_Keyval_create

1
src/mpi/c/keyval_free.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Keyval_free = PMPI_Keyval_free

2
src/mpi/c/scatter.c
Просмотреть файл

@ -7,8 +7,8 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Scatter = PMPI_Scatter

2
src/mpi/c/scatterv.c
Просмотреть файл

@ -7,8 +7,8 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "mca/coll/coll.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Scatterv = PMPI_Scatterv

2
src/mpi/c/type_c2f.c
Просмотреть файл

@ -8,7 +8,7 @@
#include "mpi/c/bindings.h"
#include "mpi/f77/fint_2_int.h"
#include "datatype/datatype.h"
#include "communicator/communicator.h"
/*#include "communicator/communicator.h"*/
#include "errhandler/errhandler.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES

1
src/mpi/c/type_create_keyval.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Type_create_keyval = PMPI_Type_create_keyval

2
src/mpi/c/type_delete_attr.c
Просмотреть файл

@ -7,6 +7,8 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Type_delete_attr = PMPI_Type_delete_attr

2
src/mpi/c/type_extent.c
Просмотреть файл

@ -6,8 +6,8 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Type_extent = PMPI_Type_extent

1
src/mpi/c/type_free_keyval.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Type_free_keyval = PMPI_Type_free_keyval

2
src/mpi/c/type_get_attr.c
Просмотреть файл

@ -7,6 +7,8 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Type_get_attr = PMPI_Type_get_attr

2
src/mpi/c/type_set_attr.c
Просмотреть файл

@ -7,6 +7,8 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Type_set_attr = PMPI_Type_set_attr

1
src/mpi/c/win_create_keyval.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Win_create_keyval = PMPI_Win_create_keyval

1
src/mpi/c/win_delete_attr.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "win/win.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Win_delete_attr = PMPI_Win_delete_attr

23
src/mpi/c/win_free_keyval.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Win_free_keyval = PMPI_Win_free_keyval
@ -21,18 +22,18 @@ static const char FUNC_NAME[] = "MPI_Win_free_keyval";
int MPI_Win_free_keyval(int *win_keyval)
{
int ret;
int ret;
/* Check for valid key pointer */
/* Check for valid key pointer */
if (MPI_PARAM_CHECK) {
OMPI_ERR_INIT_FINALIZE(FUNC_NAME);
if (NULL == win_keyval) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
FUNC_NAME);
}
}
if (MPI_PARAM_CHECK) {
OMPI_ERR_INIT_FINALIZE(FUNC_NAME);
if (NULL == win_keyval) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
FUNC_NAME);
}
}
ret = ompi_attr_free_keyval(WIN_ATTR, win_keyval, 0);
OMPI_ERRHANDLER_RETURN(ret, MPI_COMM_WORLD, MPI_ERR_OTHER, FUNC_NAME);
ret = ompi_attr_free_keyval(WIN_ATTR, win_keyval, 0);
OMPI_ERRHANDLER_RETURN(ret, MPI_COMM_WORLD, MPI_ERR_OTHER, FUNC_NAME);
}

1
src/mpi/c/win_get_attr.c
Просмотреть файл

@ -7,6 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "win/win.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Win_get_attr = PMPI_Win_get_attr

3
src/mpi/c/win_set_attr.c
Просмотреть файл

@ -7,8 +7,7 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "attribute/attribute.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#include "win/win.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Win_set_attr = PMPI_Win_set_attr

1
src/mpi/c/win_wait.c
Просмотреть файл

@ -6,7 +6,6 @@
#include "mpi.h"
#include "mpi/c/bindings.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES

1
src/mpi/f77/abort_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/accumulate_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/add_error_class_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/add_error_code_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

4
src/mpi/f77/add_error_string_f.c
Просмотреть файл

@ -6,12 +6,10 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/strings.h"
#include "mpi/f77/bindings.h"
#include "mpi/f77/constants.h"
#include "errhandler/errhandler.h"
#include "communicator/communicator.h"
#include "mpi/f77/strings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER
#pragma weak PMPI_ADD_ERROR_STRING = mpi_add_error_string_f

1
src/mpi/f77/address_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/allgather_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/allgatherv_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/alloc_mem_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/allreduce_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/alltoall_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/alltoallv_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

1
src/mpi/f77/alltoallw_f.c
Просмотреть файл

@ -6,7 +6,6 @@
#include <stdio.h>
#include "mpi.h"
#include "mpi/f77/bindings.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILE_LAYER

Некоторые файлы не были показаны из-за слишком большого количества измененных файлов Показать больше