X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e709643ef0c5b61c6c878016c418bffa2b1b20cd..5a897f62cb4a09de7541022ed02344f9a8bf6e53:/src/smpi/bindings/smpi_f77.cpp diff --git a/src/smpi/bindings/smpi_f77.cpp b/src/smpi/bindings/smpi_f77.cpp index 4d108c298c..530487b303 100644 --- a/src/smpi/bindings/smpi_f77.cpp +++ b/src/smpi/bindings/smpi_f77.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2010-2021. 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. */ @@ -13,6 +13,8 @@ #include "smpi_win.hpp" #include "src/smpi/include/smpi_actor.hpp" +#include + static int running_processes = 0; void smpi_init_fortran_types() @@ -75,6 +77,7 @@ void smpi_init_fortran_types() MPI_LB->add_f(); MPI_UB->add_f(); + simgrid::smpi::F2C::finish_initialization(); } } @@ -157,9 +160,6 @@ void mpi_win_free_(int* win, int* ierr) { MPI_Win tmp = simgrid::smpi::Win::f2c(*win); *ierr = MPI_Win_free(&tmp); - if(*ierr == MPI_SUCCESS) { - simgrid::smpi::F2C::free_f(*win); - } } void mpi_win_create_(int* base, MPI_Aint* size, int* disp_unit, int* info, int* comm, int* win, int* ierr) @@ -167,7 +167,7 @@ void mpi_win_create_(int* base, MPI_Aint* size, int* disp_unit, int* info, int* MPI_Win tmp; *ierr = MPI_Win_create( static_cast(base), *size, *disp_unit, simgrid::smpi::Info::f2c(*info), simgrid::smpi::Comm::f2c(*comm),&tmp); if (*ierr == MPI_SUCCESS) { - *win = tmp->add_f(); + *win = tmp->c2f(); } } @@ -200,11 +200,8 @@ void mpi_win_set_name_(int* win, char* name, int* ierr, int size) size--; name++; } - char* tname = xbt_new(char,size+1); - strncpy(tname, name, size); - tname[size]='\0'; - *ierr = MPI_Win_set_name(simgrid::smpi::Win::f2c(*win), tname); - xbt_free(tname); + std::string tname(name, size); + *ierr = MPI_Win_set_name(simgrid::smpi::Win::f2c(*win), tname.c_str()); } void mpi_win_get_name_(int* win, char* name, int* len, int* ierr) @@ -220,7 +217,7 @@ void mpi_win_allocate_(MPI_Aint* size, int* disp_unit, int* info, int* comm, voi *ierr = MPI_Win_allocate(*size, *disp_unit, simgrid::smpi::Info::f2c(*info), simgrid::smpi::Comm::f2c(*comm), base, &tmp); if(*ierr == MPI_SUCCESS) { - *win = tmp->add_f(); + *win = tmp->c2f(); } } @@ -234,7 +231,7 @@ void mpi_win_create_dynamic_(int* info, int* comm, int* win, int* ierr) MPI_Win tmp; *ierr = MPI_Win_create_dynamic( simgrid::smpi::Info::f2c(*info), simgrid::smpi::Comm::f2c(*comm),&tmp); if(*ierr == MPI_SUCCESS) { - *win = tmp->add_f(); + *win = tmp->c2f(); } } @@ -253,7 +250,7 @@ void mpi_win_get_info_(int* win, int* info, int* ierr) MPI_Info tmp; *ierr = MPI_Win_get_info(simgrid::smpi::Win::f2c(*win), &tmp); if (*ierr == MPI_SUCCESS) { - *info = tmp->add_f(); + *info = tmp->c2f(); } } @@ -262,7 +259,7 @@ void mpi_win_get_group_(int* win, int* group, int* ierr) MPI_Group tmp; *ierr = MPI_Win_get_group(simgrid::smpi::Win::f2c(*win), &tmp); if (*ierr == MPI_SUCCESS) { - *group = tmp->add_f(); + *group = tmp->c2f(); } } @@ -276,9 +273,9 @@ void mpi_win_get_attr_(int* win, int* type_keyval, MPI_Aint* attribute_val, int* void mpi_win_set_attr_(int* win, int* type_keyval, MPI_Aint* att, int* ierr) { - MPI_Aint* val = (MPI_Aint*)xbt_malloc(sizeof(MPI_Aint)); - *val = *att; - *ierr = MPI_Win_set_attr(simgrid::smpi::Win::f2c(*win), *type_keyval, val); + auto* val = static_cast(xbt_malloc(sizeof(MPI_Aint))); + *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) @@ -358,7 +355,7 @@ void mpi_info_create_(int* info, int* ierr) MPI_Info tmp; *ierr = MPI_Info_create(&tmp); if(*ierr == MPI_SUCCESS) { - *info = tmp->add_f(); + *info = tmp->c2f(); } } @@ -371,9 +368,7 @@ void mpi_info_set_(int* info, char* key, char* value, int* ierr, unsigned int ke keylen--; key++; } - char* tkey = xbt_new(char,keylen+1); - strncpy(tkey, key, keylen); - tkey[keylen]='\0'; + std::string tkey(key, keylen); while(value[valuelen-1]==' ') valuelen--; @@ -381,13 +376,9 @@ void mpi_info_set_(int* info, char* key, char* value, int* ierr, unsigned int ke valuelen--; value++; } - char* tvalue = xbt_new(char,valuelen+1); - strncpy(tvalue, value, valuelen); - tvalue[valuelen]='\0'; + std::string tvalue(value, valuelen); - *ierr = MPI_Info_set( simgrid::smpi::Info::f2c(*info), tkey, tvalue); - xbt_free(tkey); - xbt_free(tvalue); + *ierr = MPI_Info_set(simgrid::smpi::Info::f2c(*info), tkey.c_str(), tvalue.c_str()); } void mpi_info_get_(int* info, char* key, int* valuelen, char* value, int* flag, int* ierr, unsigned int keylen) @@ -398,15 +389,11 @@ void mpi_info_get_(int* info, char* key, int* valuelen, char* value, int* flag, keylen--; key++; } - char* tkey = xbt_new(char,keylen+1); - strncpy(tkey, key, keylen); - tkey[keylen]='\0'; - *ierr = MPI_Info_get(simgrid::smpi::Info::f2c(*info),tkey,*valuelen, value, flag); - xbt_free(tkey); + std::string tkey(key, keylen); + *ierr = MPI_Info_get(simgrid::smpi::Info::f2c(*info), tkey.c_str(), *valuelen, value, flag); if(*flag!=0){ int replace=0; - int i=0; - for (i=0; i<*valuelen; i++){ + for (int i = 0; i < *valuelen; i++) { if(value[i]=='\0') replace=1; if(replace) @@ -438,7 +425,7 @@ void mpi_rget_(int* origin_addr, int* origin_count, int* origin_datatype, int* t *ierr = MPI_Rget( static_cast(origin_addr),*origin_count, simgrid::smpi::Datatype::f2c(*origin_datatype),*target_rank, *target_disp, *target_count, simgrid::smpi::Datatype::f2c(*tarsmpi_type_f2c), simgrid::smpi::Win::f2c(*win), &req); if(*ierr == MPI_SUCCESS) { - *request = req->add_f(); + *request = req->c2f(); } } @@ -457,7 +444,7 @@ void mpi_raccumulate_(int* origin_addr, int* origin_count, int* origin_datatype, *ierr = MPI_Raccumulate( static_cast(origin_addr),*origin_count, simgrid::smpi::Datatype::f2c(*origin_datatype),*target_rank, *target_disp, *target_count, simgrid::smpi::Datatype::f2c(*tarsmpi_type_f2c), simgrid::smpi::Op::f2c(*op), simgrid::smpi::Win::f2c(*win),&req); if(*ierr == MPI_SUCCESS) { - *request = req->add_f(); + *request = req->c2f(); } } @@ -475,7 +462,7 @@ void mpi_rput_(int* origin_addr, int* origin_count, int* origin_datatype, int* t *ierr = MPI_Rput( static_cast(origin_addr),*origin_count, simgrid::smpi::Datatype::f2c(*origin_datatype),*target_rank, *target_disp, *target_count, simgrid::smpi::Datatype::f2c(*tarsmpi_type_f2c), simgrid::smpi::Win::f2c(*win),&req); if(*ierr == MPI_SUCCESS) { - *request = req->add_f(); + *request = req->c2f(); } } @@ -517,7 +504,7 @@ void mpi_rget_accumulate_(int* origin_addr, int* origin_count, int* origin_datat *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(); + *request = req->c2f(); } } @@ -565,7 +552,7 @@ void mpi_op_create_(void* function, int* commute, int* op, int* ierr) *ierr = MPI_Op_create(reinterpret_cast(function), *commute, &tmp); if (*ierr == MPI_SUCCESS) { tmp->set_fortran_op(); - *op = tmp->add_f(); + *op = tmp->c2f(); } } @@ -573,9 +560,6 @@ void mpi_op_free_(int* op, int* ierr) { MPI_Op tmp= simgrid::smpi::Op::f2c(*op); *ierr = MPI_Op_free(& tmp); - if(*ierr == MPI_SUCCESS) { - simgrid::smpi::F2C::free_f(*op); - } } void mpi_op_commutative_(int* op, int* commute, int* ierr) @@ -588,7 +572,6 @@ void mpi_group_free_(int* group, int* ierr) MPI_Group tmp = simgrid::smpi::Group::f2c(*group); if(tmp != MPI_COMM_WORLD->group() && tmp != MPI_GROUP_EMPTY){ simgrid::smpi::Group::unref(tmp); - simgrid::smpi::F2C::free_f(*group); } *ierr = MPI_SUCCESS; } @@ -618,7 +601,7 @@ void mpi_group_union_(int* group1, int* group2, int* newgroup, int* ierr) MPI_Group tmp; *ierr = MPI_Group_union(simgrid::smpi::Group::f2c(*group1), simgrid::smpi::Group::f2c(*group2), &tmp); if (*ierr == MPI_SUCCESS) { - *newgroup = tmp->add_f(); + *newgroup = tmp->c2f(); } } @@ -627,7 +610,7 @@ void mpi_group_intersection_(int* group1, int* group2, int* newgroup, int* ierr) MPI_Group tmp; *ierr = MPI_Group_intersection(simgrid::smpi::Group::f2c(*group1), simgrid::smpi::Group::f2c(*group2), &tmp); if (*ierr == MPI_SUCCESS) { - *newgroup = tmp->add_f(); + *newgroup = tmp->c2f(); } } @@ -636,7 +619,7 @@ void mpi_group_difference_(int* group1, int* group2, int* newgroup, int* ierr) MPI_Group tmp; *ierr = MPI_Group_difference(simgrid::smpi::Group::f2c(*group1), simgrid::smpi::Group::f2c(*group2), &tmp); if (*ierr == MPI_SUCCESS) { - *newgroup = tmp->add_f(); + *newgroup = tmp->c2f(); } } @@ -645,7 +628,7 @@ void mpi_group_excl_(int* group, int* n, int* ranks, int* newgroup, int* ierr) MPI_Group tmp; *ierr = MPI_Group_excl(simgrid::smpi::Group::f2c(*group), *n, ranks, &tmp); if (*ierr == MPI_SUCCESS) { - *newgroup = tmp->add_f(); + *newgroup = tmp->c2f(); } } @@ -654,7 +637,7 @@ void mpi_group_range_incl_ (int* group, int* n, int ranges[][3], int* newgroup, MPI_Group tmp; *ierr = MPI_Group_range_incl(simgrid::smpi::Group::f2c(*group), *n, ranges, &tmp); if (*ierr == MPI_SUCCESS) { - *newgroup = tmp->add_f(); + *newgroup = tmp->c2f(); } } @@ -663,16 +646,13 @@ void mpi_group_range_excl_ (int* group, int* n, int ranges[][3], int* newgroup, MPI_Group tmp; *ierr = MPI_Group_range_excl(simgrid::smpi::Group::f2c(*group), *n, ranges, &tmp); if(*ierr == MPI_SUCCESS) { - *newgroup = tmp->add_f(); + *newgroup = tmp->c2f(); } } void mpi_request_free_ (int* request, int* ierr){ MPI_Request tmp=simgrid::smpi::Request::f2c(*request); *ierr = MPI_Request_free(&tmp); - if(*ierr == MPI_SUCCESS) { - simgrid::smpi::Request::free_f(*request); - } } void mpi_pack_size_ (int* incount, int* datatype, int* comm, int* size, int* ierr) { @@ -687,7 +667,7 @@ void mpi_cart_create_ (int* comm_old, int* ndims, int* dims, int* periods, int* MPI_Comm tmp; *ierr = MPI_Cart_create(simgrid::smpi::Comm::f2c(*comm_old), *ndims, dims, periods, *reorder, &tmp); if(*ierr == MPI_SUCCESS) { - *comm_cart = tmp->add_f(); + *comm_cart = tmp->c2f(); } } @@ -711,7 +691,7 @@ void mpi_cart_sub_ (int* comm, int* remain_dims, int* comm_new, int* ierr) { MPI_Comm tmp; *ierr = MPI_Cart_sub(simgrid::smpi::Comm::f2c(*comm), remain_dims, &tmp); if(*ierr == MPI_SUCCESS) { - *comm_new = tmp->add_f(); + *comm_new = tmp->c2f(); } } @@ -723,7 +703,7 @@ void mpi_graph_create_ (int* comm_old, int* nnodes, int* index, int* edges, int* MPI_Comm tmp; *ierr = MPI_Graph_create(simgrid::smpi::Comm::f2c(*comm_old), *nnodes, index, edges, *reorder, &tmp); if(*ierr == MPI_SUCCESS) { - *comm_graph = tmp->add_f(); + *comm_graph = tmp->c2f(); } } @@ -804,7 +784,7 @@ void mpi_intercomm_create_ (int* local_comm, int *local_leader, int* peer_comm, *ierr = MPI_Intercomm_create(simgrid::smpi::Comm::f2c(*local_comm), *local_leader, simgrid::smpi::Comm::f2c(*peer_comm), *remote_leader, *tag, &tmp); if(*ierr == MPI_SUCCESS) { - *comm_out = tmp->add_f(); + *comm_out = tmp->c2f(); } } @@ -812,7 +792,7 @@ void mpi_intercomm_merge_ (int* comm, int* high, int* comm_out, int* ierr) { MPI_Comm tmp; *ierr = MPI_Intercomm_merge(simgrid::smpi::Comm::f2c(*comm), *high, &tmp); if(*ierr == MPI_SUCCESS) { - *comm_out = tmp->add_f(); + *comm_out = tmp->c2f(); } } @@ -821,9 +801,9 @@ void mpi_attr_delete_ (int* comm, int* keyval, int* ierr) { } 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); + auto* val = static_cast(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) { @@ -864,7 +844,7 @@ void mpi_info_dup_ (int* info, int* newinfo, int* ierr){ MPI_Info tmp; *ierr = MPI_Info_dup(simgrid::smpi::Info::f2c(*info), &tmp); if(*ierr==MPI_SUCCESS){ - *newinfo= tmp->add_f(); + *newinfo= tmp->c2f(); } } @@ -875,11 +855,8 @@ void mpi_info_get_valuelen_ ( int* info, char *key, int *valuelen, int *flag, in keylen--; key++; } - char* tkey = xbt_new(char, keylen+1); - strncpy(tkey, key, keylen); - tkey[keylen]='\0'; - *ierr = MPI_Info_get_valuelen( simgrid::smpi::Info::f2c(*info), tkey, valuelen, flag); - xbt_free(tkey); + std::string tkey(key, keylen); + *ierr = MPI_Info_get_valuelen(simgrid::smpi::Info::f2c(*info), tkey.c_str(), valuelen, flag); } void mpi_info_delete_ (int* info, char *key, int* ierr, unsigned int keylen){ @@ -889,11 +866,8 @@ void mpi_info_delete_ (int* info, char *key, int* ierr, unsigned int keylen){ keylen--; key++; } - char* tkey = xbt_new(char, keylen+1); - strncpy(tkey, key, keylen); - tkey[keylen]='\0'; - *ierr = MPI_Info_delete(simgrid::smpi::Info::f2c(*info), tkey); - xbt_free(tkey); + std::string tkey(key, keylen); + *ierr = MPI_Info_delete(simgrid::smpi::Info::f2c(*info), tkey.c_str()); } void mpi_info_get_nkeys_ ( int* info, int *nkeys, int* ierr){ @@ -902,8 +876,7 @@ void mpi_info_get_nkeys_ ( int* info, int *nkeys, int* ierr){ void mpi_info_get_nthkey_ ( int* info, int* n, char *key, int* ierr, unsigned int keylen){ *ierr = MPI_Info_get_nthkey( simgrid::smpi::Info::f2c(*info), *n, key); - unsigned int i = 0; - for (i=strlen(key); i(strlen(key)); i < keylen; i++) key[i]=' '; } @@ -924,7 +897,7 @@ void mpi_grequest_start_ ( void *query_fn, void *free_fn, void *cancel_fn, void *ierr = MPI_Grequest_start( reinterpret_cast(query_fn), reinterpret_cast(free_fn), reinterpret_cast(cancel_fn), extra_state, &tmp); if(*ierr == MPI_SUCCESS) { - *request = tmp->add_f(); + *request = tmp->c2f(); } }