X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/60449c1d78a05619fe3d1a77fa1d7d0c20a79dba..72b97973d4520d580ad2253c77935b86eedf3706:/src/smpi/private.h diff --git a/src/smpi/private.h b/src/smpi/private.h index 13f2e76189..cd4fdcb92f 100644 --- a/src/smpi/private.h +++ b/src/smpi/private.h @@ -180,6 +180,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 +400,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 +449,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 +565,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); @@ -759,10 +770,9 @@ 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; int SIMIX_process_get_PID(smx_process_t self);