c4c69b4ddf
Add support for MPI_Count type and MPI_COUNT datatype and add the required MPI-3 functions MPI_Get_elements_x, MPI_Status_set_elements_x, MPI_Type_get_extent_x, MPI_Type_get_true_extent_x, and MPI_Type_size_x. This commit adds only the C bindings. Fortran bindins will be added in another commit. For now the MPI_Count type is define to have the same size as MPI_Offset. The type is required to be at least as large as MPI_Offset and MPI_Aint. The type was initially intended to be a ssize_t (if it was the same size as a long long) but there were issues compiling romio with that definition (despite the inclusion of stddef.h). I updated the datatype engine to use size_t instead of uint32_t to support large datatypes. This will require some review to make sure that 1) the changes are beneficial, 2) nothing was broken by the change (I doubt anything was), and 3) there are no performance regressions due to this change. Increase the maximum number of predifined datatypes to support MPI_Count Put common get_elements code to ompi/datatype/ompi_datatype_get_elements.c Update MPI_Get_count to reflect changes in MPI-3 (return MPI_UNDEFINED when the count is too large for an int) This commit was SVN r28932.
328 строки
9.9 KiB
C
328 строки
9.9 KiB
C
/*
|
|
* Copyright (c) 2007-2008 Cisco Systems, Inc. All rights reserved.
|
|
* Copyright (c) 2004-2013 The University of Tennessee and The University
|
|
* of Tennessee Research Foundation. All rights
|
|
* reserved.
|
|
* $COPYRIGHT$
|
|
*
|
|
* Additional copyrights may follow
|
|
*
|
|
* $HEADER$
|
|
*/
|
|
|
|
/**********************************************************************
|
|
* Copyright (C) 2000-2004 by Etnus, LLC.
|
|
* Copyright (C) 1999 by Etnus, Inc.
|
|
* Copyright (C) 1997-1998 Dolphin Interconnect Solutions Inc.
|
|
*
|
|
* Permission is hereby granted to use, reproduce, prepare derivative
|
|
* works, and to redistribute to others.
|
|
*
|
|
* DISCLAIMER
|
|
*
|
|
* Neither Dolphin Interconnect Solutions, Etnus LLC, nor any of their
|
|
* employees, makes any warranty express or implied, or assumes any
|
|
* legal liability or responsibility for the accuracy, completeness,
|
|
* or usefulness of any information, apparatus, product, or process
|
|
* disclosed, or represents that its use would not infringe privately
|
|
* owned rights.
|
|
*
|
|
* This code was written by
|
|
* James Cownie: Dolphin Interconnect Solutions. <jcownie@dolphinics.com>
|
|
* Etnus LLC <jcownie@etnus.com>
|
|
**********************************************************************/
|
|
|
|
#ifndef OMPI_COMMON_DLL_DEFS_H
|
|
#define OMPI_COMMON_DLL_DEFS_H
|
|
|
|
#include "msgq_interface.h"
|
|
|
|
/***********************************************************************
|
|
* Information associated with a specific executable image. Common
|
|
* across all DLLs.
|
|
*/
|
|
typedef struct
|
|
{
|
|
/* Functions needed here */
|
|
const struct mqs_image_callbacks * image_callbacks;
|
|
|
|
/* basic structures */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int opal_list_next;
|
|
} offset;
|
|
} opal_list_item_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int opal_list_sentinel;
|
|
} offset;
|
|
} opal_list_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
} ompi_free_list_item_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int fl_frag_class; /* opal_class_t* */
|
|
int fl_mpool; /* struct mca_mpool_base_module_t* */
|
|
int fl_frag_size; /* size_t */
|
|
int fl_frag_alignment; /* size_t */
|
|
int fl_allocations; /* opal_list_t */
|
|
int fl_max_to_alloc; /* size_t */
|
|
int fl_num_per_alloc; /* size_t */
|
|
int fl_num_allocated; /* size_t */
|
|
} offset;
|
|
} ompi_free_list_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int ht_table;
|
|
int ht_table_size;
|
|
int ht_size;
|
|
int ht_mask;
|
|
} offset;
|
|
} opal_hash_table_t;
|
|
/* requests structures */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int req_type;
|
|
int req_status;
|
|
int req_complete;
|
|
int req_state;
|
|
int req_f_to_c_index;
|
|
} offset;
|
|
} ompi_request_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int req_addr;
|
|
int req_count;
|
|
int req_peer;
|
|
int req_tag;
|
|
int req_comm;
|
|
int req_datatype;
|
|
int req_proc;
|
|
int req_sequence;
|
|
int req_type;
|
|
int req_pml_complete;
|
|
} offset;
|
|
} mca_pml_base_request_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int req_addr;
|
|
int req_bytes_packed;
|
|
int req_send_mode;
|
|
} offset;
|
|
} mca_pml_base_send_request_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int req_bytes_packed;
|
|
} offset;
|
|
} mca_pml_base_recv_request_t;
|
|
#if 0
|
|
/* fragments for unexpected messages (as well as theirs headers) */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int hdr;
|
|
int request;
|
|
} offset;
|
|
} mca_pml_ob1_recv_frag_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int hdr_type;
|
|
int hdr_flags;
|
|
} offset;
|
|
} mca_pml_ob1_common_hdr_t;
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int hdr_common;
|
|
int hdr_ctx;
|
|
int hdr_src;
|
|
int hdr_tag;
|
|
int hdr_seq;
|
|
} offset;
|
|
} mca_pml_ob1_match_hdr_t;
|
|
#endif
|
|
/* opal_pointer_array structure */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int lowest_free;
|
|
int number_free;
|
|
int size;
|
|
int addr;
|
|
} offset;
|
|
} opal_pointer_array_t;
|
|
/* group structure */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int grp_proc_count;
|
|
int grp_proc_pointers;
|
|
int grp_my_rank;
|
|
int grp_flags;
|
|
} offset;
|
|
} ompi_group_t;
|
|
/* communicator structure */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int c_name;
|
|
int c_contextid;
|
|
int c_my_rank;
|
|
int c_local_group;
|
|
int c_remote_group;
|
|
int c_flags;
|
|
int c_f_to_c_index;
|
|
int c_topo;
|
|
int c_keyhash;
|
|
} offset;
|
|
} ompi_communicator_t;
|
|
/* base topology information in a communicator */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
struct {
|
|
int ndims;
|
|
int dims;
|
|
int periods;
|
|
} mtc_cart;
|
|
struct {
|
|
int nnodes;
|
|
int index;
|
|
int edges;
|
|
} mtc_graph;
|
|
struct {
|
|
int in;
|
|
int inw;
|
|
int out;
|
|
int outw;
|
|
int indegree;
|
|
int outdegree;
|
|
int weighted;
|
|
} mtc_dist_graph;
|
|
int reorder;
|
|
} offset;
|
|
} ompi_mca_topo_base_module_t;
|
|
/* MPI_Status */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int MPI_SOURCE;
|
|
int MPI_TAG;
|
|
int MPI_ERROR;
|
|
int _cancelled;
|
|
size_t _ucount;
|
|
} offset;
|
|
} ompi_status_public_t;
|
|
/* datatype structure */
|
|
struct {
|
|
mqs_type *type;
|
|
int size;
|
|
struct {
|
|
int size;
|
|
int name;
|
|
} offset;
|
|
} ompi_datatype_t;
|
|
|
|
/* For the caller to hang their own stuff */
|
|
void *extra;
|
|
} mpi_image_info;
|
|
|
|
/***********************************************************************/
|
|
/* Information for a single process. Common across all DLLs.
|
|
*/
|
|
typedef struct
|
|
{
|
|
const struct mqs_process_callbacks * process_callbacks; /* Functions needed here */
|
|
|
|
mqs_target_type_sizes sizes; /* Process architecture information */
|
|
|
|
/* For the caller to hang their own stuff */
|
|
void *extra;
|
|
} mpi_process_info;
|
|
|
|
/**********************************************************************/
|
|
/* Macros to make it transparent that we're calling the TV functions
|
|
* through function pointers.
|
|
*/
|
|
#define mqs_malloc (mqs_basic_entrypoints->mqs_malloc_fp)
|
|
#define mqs_free (mqs_basic_entrypoints->mqs_free_fp)
|
|
#define mqs_prints (mqs_basic_entrypoints->mqs_dprints_fp)
|
|
#define mqs_put_image_info (mqs_basic_entrypoints->mqs_put_image_info_fp)
|
|
#define mqs_get_image_info (mqs_basic_entrypoints->mqs_get_image_info_fp)
|
|
#define mqs_put_process_info (mqs_basic_entrypoints->mqs_put_process_info_fp)
|
|
#define mqs_get_process_info (mqs_basic_entrypoints->mqs_get_process_info_fp)
|
|
|
|
/* These macros *RELY* on the function already having set up the conventional
|
|
* local variables i_info or p_info.
|
|
*/
|
|
#define mqs_find_type (i_info->image_callbacks->mqs_find_type_fp)
|
|
#define mqs_field_offset (i_info->image_callbacks->mqs_field_offset_fp)
|
|
#define mqs_sizeof (i_info->image_callbacks->mqs_sizeof_fp)
|
|
#define mqs_get_type_sizes (i_info->image_callbacks->mqs_get_type_sizes_fp)
|
|
#define mqs_find_function (i_info->image_callbacks->mqs_find_function_fp)
|
|
#define mqs_find_symbol (i_info->image_callbacks->mqs_find_symbol_fp)
|
|
|
|
#define mqs_get_image (p_info->process_callbacks->mqs_get_image_fp)
|
|
#define mqs_get_global_rank (p_info->process_callbacks->mqs_get_global_rank_fp)
|
|
#define mqs_fetch_data (p_info->process_callbacks->mqs_fetch_data_fp)
|
|
#define mqs_target_to_host (p_info->process_callbacks->mqs_target_to_host_fp)
|
|
|
|
/* Basic callbacks into the debugger */
|
|
extern const mqs_basic_callbacks *mqs_basic_entrypoints;
|
|
|
|
/* OMPI-specific functions */
|
|
int ompi_fill_in_type_info(mqs_image *image, char **message);
|
|
|
|
/* Fetch a pointer from the process */
|
|
mqs_taddr_t ompi_fetch_pointer(mqs_process *proc, mqs_taddr_t addr,
|
|
mpi_process_info *p_info);
|
|
|
|
/* Fetch an int from the process */
|
|
mqs_tword_t ompi_fetch_int(mqs_process *proc, mqs_taddr_t addr,
|
|
mpi_process_info *p_info);
|
|
|
|
/* Fetch a bool from the process */
|
|
mqs_tword_t ompi_fetch_bool(mqs_process *proc, mqs_taddr_t addr,
|
|
mpi_process_info *p_info);
|
|
|
|
/* Fetch a size_t from the process */
|
|
mqs_taddr_t ompi_fetch_size_t(mqs_process *proc, mqs_taddr_t addr,
|
|
mpi_process_info *p_info);
|
|
|
|
/* Helpers to fetch stuff from an opal_pointer_array_t */
|
|
int ompi_fetch_opal_pointer_array_info(mqs_process *proc, mqs_taddr_t addr,
|
|
mpi_process_info *p_info,
|
|
int *size, int *lowest_free,
|
|
int *number_free);
|
|
int ompi_fetch_opal_pointer_array_item(mqs_process *proc, mqs_taddr_t addr,
|
|
mpi_process_info *p_info, int index,
|
|
mqs_taddr_t *item);
|
|
#endif
|