X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c77b7752704cc065993f337238a81c9f6d2cf20a..4d140762b2b9c8746cdd3b0680a7167867ba0ad9:/src/smpi/smpi_win.hpp diff --git a/src/smpi/smpi_win.hpp b/src/smpi/smpi_win.hpp deleted file mode 100644 index e219be5588..0000000000 --- a/src/smpi/smpi_win.hpp +++ /dev/null @@ -1,97 +0,0 @@ -/* Copyright (c) 2010, 2013-2017. The SimGrid Team. - * All rights reserved. */ - -/* This program is free software; you can redistribute it and/or modify it - * under the terms of the license (GNU LGPL) which comes with this package. */ - -#ifndef SMPI_WIN_HPP_INCLUDED -#define SMPI_WIN_HPP_INCLUDED - -#include "src/smpi/smpi_keyvals.hpp" -#include "xbt/synchro.h" - -#include -#include - -namespace simgrid{ -namespace smpi{ - -class Win : public F2C, public Keyval { - private : - void* base_; - MPI_Aint size_; - int disp_unit_; - int assert_; - MPI_Info info_; - MPI_Comm comm_; - std::vector *requests_; - xbt_mutex_t mut_; - msg_bar_t bar_; - MPI_Win* connected_wins_; - char* name_; - int opened_; - MPI_Group group_; - int count_; //for ordering the accs - xbt_mutex_t lock_mut_; - xbt_mutex_t atomic_mut_; - std::list lockers_; - int rank_; // to identify owner for barriers in MPI_COMM_WORLD - int mode_; // exclusive or shared lock - int allocated_; - int dynamic_; - -public: - static std::unordered_map keyvals_; - static int keyval_id_; - - Win(void *base, MPI_Aint size, int disp_unit, MPI_Info info, MPI_Comm comm, int allocated = 0, int dynamic = 0); - Win(MPI_Info info, MPI_Comm comm) : Win(MPI_BOTTOM, 0, 1, info, comm, 0, 1) {}; - ~Win(); - int attach (void *base, MPI_Aint size); - int detach (void *base); - void get_name( char* name, int* length); - void get_group( MPI_Group* group); - void set_name( char* name); - int rank(); - int dynamic(); - int start(MPI_Group group, int assert); - int post(MPI_Group group, int assert); - int complete(); - MPI_Info info(); - void set_info( MPI_Info info); - int wait(); - MPI_Aint size(); - void* base(); - int disp_unit(); - int fence(int assert); - int put( 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_Request* request=nullptr); - int 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_Request* request=nullptr); - int accumulate( 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_Op op, MPI_Request* request=nullptr); - int get_accumulate( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, void *result_addr, - int result_count, MPI_Datatype result_datatype, int target_rank, MPI_Aint target_disp, int target_count, - MPI_Datatype target_datatype, MPI_Op op, MPI_Request* request=nullptr); - int compare_and_swap(void *origin_addr, void *compare_addr, - void *result_addr, MPI_Datatype datatype, int target_rank, - MPI_Aint target_disp); - static Win* f2c(int id); - - int lock(int lock_type, int rank, int assert); - int unlock(int rank); - int lock_all(int assert); - int unlock_all(); - int flush(int rank); - int flush_local(int rank); - int flush_all(); - int flush_local_all(); - int finish_comms(); - int finish_comms(int rank); -}; - - -} -} - -#endif