X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f12b085d941522c6c45e47db742a7fdfedb832da..2d37e348a09783cda723c7019640ee69de168324:/src/smpi/bindings/smpi_f77.cpp diff --git a/src/smpi/bindings/smpi_f77.cpp b/src/smpi/bindings/smpi_f77.cpp index ad40a6b49e..9f3ce44427 100644 --- a/src/smpi/bindings/smpi_f77.cpp +++ b/src/smpi/bindings/smpi_f77.cpp @@ -1,19 +1,19 @@ -/* Copyright (c) 2010-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2010-2019. 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. */ -#include "private.h" +#include "private.hpp" #include "smpi_comm.hpp" #include "smpi_datatype.hpp" #include "smpi_op.hpp" -#include "smpi_process.hpp" #include "smpi_request.hpp" #include "smpi_win.hpp" +#include "src/smpi/include/smpi_actor.hpp" static int running_processes = 0; -static void smpi_init_fortran_types(){ +void smpi_init_fortran_types(){ if(simgrid::smpi::F2C::lookup() == nullptr){ MPI_COMM_WORLD->add_f(); MPI_BYTE->add_f();//MPI_BYTE @@ -79,9 +79,6 @@ void mpi_init_(int* ierr) { void mpi_finalize_(int* ierr) { *ierr = MPI_Finalize(); running_processes--; - if(running_processes==0){ - simgrid::smpi::F2C::delete_lookup(); - } } void mpi_abort_(int* comm, int* errorcode, int* ierr) { @@ -117,8 +114,11 @@ void mpi_get_count_(MPI_Status * status, int* datatype, int *count, int* ierr){ *ierr = MPI_Get_count(FORT_STATUS_IGNORE(status), simgrid::smpi::Datatype::f2c(*datatype), count); } -void mpi_attr_get_(int* comm, int* keyval, void* attr_value, int* flag, int* ierr ){ - *ierr = MPI_Attr_get(simgrid::smpi::Comm::f2c(*comm), *keyval, attr_value, flag); +void mpi_attr_get_(int* comm, int* keyval, int* attr_value, int* flag, int* ierr ){ + int* value = nullptr; + *ierr = MPI_Attr_get(simgrid::smpi::Comm::f2c(*comm), *keyval, &value, flag); + if(*flag == 1) + *attr_value=*value; } void mpi_error_string_(int* errorcode, char* string, int* resultlen, int* ierr){ @@ -226,12 +226,17 @@ void mpi_win_get_group_(int* win, int* group, int* ierr){ } } -void mpi_win_get_attr_(int* win, int* type_keyval, void* attribute_val, int* flag, int* ierr){ - *ierr = MPI_Win_get_attr(simgrid::smpi::Win::f2c(*win), *type_keyval, attribute_val, flag); +void mpi_win_get_attr_(int* win, int* type_keyval, int* attribute_val, int* flag, int* ierr){ + int* value = nullptr; + *ierr = MPI_Win_get_attr(simgrid::smpi::Win::f2c(*win), *type_keyval, &value, flag); + if (*flag == 1) + *attribute_val = *value; } -void mpi_win_set_attr_(int* win, int* type_keyval, void* att, int* ierr){ - *ierr = MPI_Win_set_attr(simgrid::smpi::Win::f2c(*win), *type_keyval, att); +void mpi_win_set_attr_(int* win, int* type_keyval, int* att, int* ierr){ + int* val = (int*)xbt_malloc(sizeof(int)); + *val=*att; + *ierr = MPI_Win_set_attr(simgrid::smpi::Win::f2c(*win), *type_keyval, val); } void mpi_win_delete_attr_(int* win, int* comm_keyval, int* ierr){ @@ -239,8 +244,9 @@ void mpi_win_delete_attr_(int* win, int* comm_keyval, int* ierr){ } void mpi_win_create_keyval_(void* copy_fn, void* delete_fn, int* keyval, void* extra_state, int* ierr){ - *ierr = MPI_Win_create_keyval(reinterpret_cast(copy_fn), reinterpret_cast(delete_fn), - keyval, extra_state) ; + smpi_copy_fn _copy_fn={nullptr,nullptr,nullptr,nullptr,nullptr,(*(int*)copy_fn) == 0 ? nullptr : reinterpret_cast(copy_fn)}; + smpi_delete_fn _delete_fn={nullptr,nullptr,nullptr,nullptr,nullptr,(*(int*)delete_fn) == 0 ? nullptr : reinterpret_cast(delete_fn)}; + *ierr = simgrid::smpi::Keyval::keyval_create(_copy_fn, _delete_fn, keyval, extra_state); } void mpi_win_free_keyval_(int* keyval, int* ierr){ @@ -399,8 +405,9 @@ void mpi_fetch_and_op_( int *origin_addr, int* result_addr, int* datatype, int* *target_disp, simgrid::smpi::Op::f2c(*op), simgrid::smpi::Win::f2c(*win)); } -void mpi_compare_and_swap_( int *origin_addr, int* compare_addr, int* result_addr, - int* datatype, int* target_rank, MPI_Aint* target_disp, int* win, int* ierr){ +void mpi_compare_and_swap_(int* origin_addr, int* compare_addr, int* result_addr, int* datatype, int* target_rank, + MPI_Aint* target_disp, int* win, int* ierr) +{ *ierr = MPI_Compare_and_swap( static_cast(origin_addr),static_cast(compare_addr), static_cast(result_addr), simgrid::smpi::Datatype::f2c(*datatype),*target_rank, *target_disp, simgrid::smpi::Win::f2c(*win)); @@ -409,20 +416,22 @@ void mpi_compare_and_swap_( int *origin_addr, int* compare_addr, int* result_add void mpi_get_accumulate_(int *origin_addr, int* origin_count, int* origin_datatype, int* result_addr, int* result_count, int* result_datatype, int* target_rank, MPI_Aint* target_disp, int* target_count, int* target_datatype, int* op, int* win, int* ierr){ - *ierr = MPI_Get_accumulate( static_cast(origin_addr), *origin_count, simgrid::smpi::Datatype::f2c(*origin_datatype), - static_cast(result_addr), *result_count, simgrid::smpi::Datatype::f2c(*result_datatype), - *target_rank, *target_disp, *target_count, simgrid::smpi::Datatype::f2c(*target_datatype), - simgrid::smpi::Op::f2c(*op), simgrid::smpi::Win::f2c(*win)); + *ierr = + MPI_Get_accumulate(static_cast(origin_addr), *origin_count, simgrid::smpi::Datatype::f2c(*origin_datatype), + static_cast(result_addr), *result_count, simgrid::smpi::Datatype::f2c(*result_datatype), + *target_rank, *target_disp, *target_count, simgrid::smpi::Datatype::f2c(*target_datatype), + simgrid::smpi::Op::f2c(*op), simgrid::smpi::Win::f2c(*win)); } void mpi_rget_accumulate_(int *origin_addr, int* origin_count, int* origin_datatype, int* result_addr, int* result_count, int* result_datatype, int* target_rank, MPI_Aint* target_disp, int* target_count, int* target_datatype, int* op, int* win, int* request, int* ierr){ MPI_Request req; - *ierr = MPI_Rget_accumulate( static_cast(origin_addr), *origin_count, simgrid::smpi::Datatype::f2c(*origin_datatype), - static_cast(result_addr), *result_count, simgrid::smpi::Datatype::f2c(*result_datatype), - *target_rank, *target_disp, *target_count, simgrid::smpi::Datatype::f2c(*target_datatype), - simgrid::smpi::Op::f2c(*op), simgrid::smpi::Win::f2c(*win), &req); + *ierr = MPI_Rget_accumulate(static_cast(origin_addr), *origin_count, + simgrid::smpi::Datatype::f2c(*origin_datatype), static_cast(result_addr), + *result_count, simgrid::smpi::Datatype::f2c(*result_datatype), *target_rank, *target_disp, + *target_count, simgrid::smpi::Datatype::f2c(*target_datatype), + simgrid::smpi::Op::f2c(*op), simgrid::smpi::Win::f2c(*win), &req); if(*ierr == MPI_SUCCESS) { *request = req->add_f(); } @@ -430,7 +439,6 @@ void mpi_rget_accumulate_(int *origin_addr, int* origin_count, int* origin_datat //following are automatically generated, and have to be checked void mpi_finalized_ (int * flag, int* ierr){ - *ierr = MPI_Finalized(flag); } @@ -441,7 +449,6 @@ void mpi_init_thread_ (int* required, int *provided, int* ierr){ } void mpi_query_thread_ (int *provided, int* ierr){ - *ierr = MPI_Query_thread(provided); } @@ -705,12 +712,16 @@ void mpi_attr_delete_ (int* comm, int* keyval, int* ierr) { *ierr = MPI_Attr_delete(simgrid::smpi::Comm::f2c(*comm), *keyval); } -void mpi_attr_put_ (int* comm, int* keyval, void* attr_value, int* ierr) { - *ierr = MPI_Attr_put(simgrid::smpi::Comm::f2c(*comm), *keyval, attr_value); +void mpi_attr_put_ (int* comm, int* keyval, int* attr_value, int* ierr) { + int* val = (int*)xbt_malloc(sizeof(int)); + *val=*attr_value; + *ierr = MPI_Attr_put(simgrid::smpi::Comm::f2c(*comm), *keyval, val); } void mpi_keyval_create_ (void* copy_fn, void* delete_fn, int* keyval, void* extra_state, int* ierr) { - *ierr = MPI_Keyval_create(reinterpret_cast(copy_fn),reinterpret_cast(delete_fn), keyval, extra_state); + smpi_copy_fn _copy_fn={nullptr,nullptr,nullptr,(*(int*)copy_fn) == 0 ? nullptr : reinterpret_cast(copy_fn),nullptr,nullptr}; + smpi_delete_fn _delete_fn={nullptr,nullptr,nullptr,(*(int*)delete_fn) == 0 ? nullptr : reinterpret_cast(delete_fn),nullptr,nullptr}; + *ierr = simgrid::smpi::Keyval::keyval_create(_copy_fn, _delete_fn, keyval, extra_state); } void mpi_keyval_free_ (int* keyval, int* ierr) {