X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/60449c1d78a05619fe3d1a77fa1d7d0c20a79dba..b3b356352e87ae00a20f737c48e19b0c8413455a:/src/smpi/private.h diff --git a/src/smpi/private.h b/src/smpi/private.h index 13f2e76189..c911cac20f 100644 --- a/src/smpi/private.h +++ b/src/smpi/private.h @@ -1,4 +1,4 @@ -/* Copyright (c) 2007, 2009-2014. The SimGrid Team. +/* Copyright (c) 2007, 2009-2015. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -108,10 +108,8 @@ typedef struct s_smpi_mpi_request { MPI_Request detached_sender; int refcount; MPI_Op op; -#ifdef HAVE_TRACING int send; int recv; -#endif } s_smpi_mpi_request_t; typedef struct s_smpi_mpi_comm_key_elem { @@ -180,6 +178,8 @@ smx_rdv_t smpi_process_mailbox(void); smx_rdv_t smpi_process_remote_mailbox(int index); smx_rdv_t smpi_process_mailbox_small(void); smx_rdv_t smpi_process_remote_mailbox_small(int index); +xbt_mutex_t smpi_process_mailboxes_mutex(void); +xbt_mutex_t smpi_process_remote_mailboxes_mutex(int index); xbt_os_timer_t smpi_process_timer(void); void smpi_process_simulated_start(void); double smpi_process_simulated_elapsed(void); @@ -398,6 +398,11 @@ void smpi_mpi_win_set_name(MPI_Win win, char* name); int smpi_mpi_win_fence( int assert, MPI_Win win); +int smpi_mpi_win_post(MPI_Group group, int assert, MPI_Win win); +int smpi_mpi_win_start(MPI_Group group, int assert, MPI_Win win); +int smpi_mpi_win_complete(MPI_Win win); +int smpi_mpi_win_wait(MPI_Win win); + int smpi_mpi_get( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank, MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Win win); int smpi_mpi_put( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank, @@ -442,8 +447,8 @@ int smpi_type_keyval_free(int* keyval); extern double smpi_cpu_threshold; extern double smpi_running_power; extern int smpi_privatize_global_variables; -extern char* start_data_exe; //start of the data+bss segment of the executable -extern int size_data_exe; //size of the data+bss segment of the executable +extern char* smpi_start_data_exe; //start of the data+bss segment of the executable +extern int smpi_size_data_exe; //size of the data+bss segment of the executable void smpi_switch_data_segment(int dest); @@ -558,6 +563,10 @@ void mpi_win_free_( int* win, int* ierr); void mpi_win_create_( int *base, MPI_Aint* size, int* disp_unit, int* info, int* comm, int *win, int* ierr); void mpi_win_set_name_ (int* win, char * name, int* ierr, int size); void mpi_win_get_name_ (int* win, char * name, int* len, int* ierr); +void mpi_win_post_(int* group, int assert, int* win, int* ierr); +void mpi_win_start_(int* group, int assert, int* win, int* ierr); +void mpi_win_complete_(int* win, int* ierr); +void mpi_win_wait_(int* win, int* ierr); void mpi_info_create_( int *info, int* ierr); void mpi_info_set_( int *info, char *key, char *value, int* ierr, unsigned int keylen, unsigned int valuelen); void mpi_info_free_(int* info, int* ierr); @@ -727,7 +736,6 @@ void mpi_comm_spawn_multiple_ ( int* count, char *array_of_commands, char** arra void mpi_comm_get_parent_ ( int*parent, int* ierr); -#ifdef HAVE_TRACING /********** Tracing **********/ /* from smpi_instr.c */ void TRACE_internal_smpi_set_category (const char *category); @@ -750,7 +758,6 @@ void TRACE_smpi_send(int rank, int src, int dst, int size); void TRACE_smpi_recv(int rank, int src, int dst); void TRACE_smpi_init(int rank); void TRACE_smpi_finalize(int rank); -#endif const char* encode_datatype(MPI_Datatype datatype, int* known); @@ -759,11 +766,11 @@ const char* encode_datatype(MPI_Datatype datatype, int* known); typedef struct s_smpi_privatisation_region { void* address; int file_descriptor; -} *smpi_privatisation_region_t; +} s_smpi_privatisation_region_t, *smpi_privatisation_region_t; extern smpi_privatisation_region_t smpi_privatisation_regions; - extern int smpi_loaded_page; +extern int smpi_universe_size; int SIMIX_process_get_PID(smx_process_t self);