X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ecd5f7562caf1d443bf22788fa5f4fac408776ec..d37695654af494c87f28017306376b8c229aaec0:/src/smpi/include/smpi_keyvals.hpp diff --git a/src/smpi/include/smpi_keyvals.hpp b/src/smpi/include/smpi_keyvals.hpp index 48f60ac4a4..a23be10fa3 100644 --- a/src/smpi/include/smpi_keyvals.hpp +++ b/src/smpi/include/smpi_keyvals.hpp @@ -1,4 +1,4 @@ -/* 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. */ @@ -14,17 +14,24 @@ struct smpi_delete_fn { MPI_Comm_delete_attr_function *comm_delete_fn; MPI_Type_delete_attr_function *type_delete_fn; MPI_Win_delete_attr_function *win_delete_fn; + MPI_Comm_delete_attr_function_fort *comm_delete_fn_fort; + MPI_Type_delete_attr_function_fort *type_delete_fn_fort; + MPI_Win_delete_attr_function_fort *win_delete_fn_fort; }; struct smpi_copy_fn { MPI_Comm_copy_attr_function *comm_copy_fn; MPI_Type_copy_attr_function *type_copy_fn; MPI_Win_copy_attr_function *win_copy_fn; + MPI_Comm_copy_attr_function_fort *comm_copy_fn_fort; + MPI_Type_copy_attr_function_fort *type_copy_fn_fort; + MPI_Win_copy_attr_function_fort *win_copy_fn_fort; }; struct s_smpi_key_elem_t { smpi_copy_fn copy_fn; smpi_delete_fn delete_fn; + void* extra_state; int refcount; }; @@ -42,7 +49,9 @@ class Keyval{ // Each subclass should have two members, as we want to separate the ones for Win, Comm, and Datatypes : // static std::unordered_map keyvals_; // static int keyval_id_; - template static int keyval_create(smpi_copy_fn copy_fn, smpi_delete_fn delete_fn, int* keyval, void* extra_statee); + template + static int keyval_create(const smpi_copy_fn& copy_fn, const smpi_delete_fn& delete_fn, int* keyval, + void* extra_state); template static int keyval_free(int* keyval); template int attr_delete(int keyval); template int attr_get(int keyval, void* attr_value, int* flag); @@ -51,12 +60,14 @@ class Keyval{ template void cleanup_attr(); }; -template int Keyval::keyval_create(smpi_copy_fn copy_fn, smpi_delete_fn delete_fn, int* keyval, void* extra_state){ - +template +int Keyval::keyval_create(const smpi_copy_fn& copy_fn, const smpi_delete_fn& delete_fn, int* keyval, void* extra_state) +{ smpi_key_elem value = new s_smpi_key_elem_t; value->copy_fn=copy_fn; value->delete_fn=delete_fn; + value->extra_state=extra_state; value->refcount=1; *keyval = T::keyval_id_; @@ -124,15 +135,15 @@ template int Keyval::attr_put(int keyval, void* attr_value){ if(elem==nullptr) return MPI_ERR_ARG; elem->refcount++; - void * value = nullptr; int flag=0; - this->attr_get(keyval, &value, &flag); - if(flag!=0){ - int ret = call_deleter((T*)this, elem, keyval,value,&flag); + auto p = attributes()->insert({keyval, attr_value}); + if (!p.second) { + int ret = call_deleter((T*)this, elem, keyval,p.first->second,&flag); + // overwrite previous value + p.first->second = attr_value; if(ret!=MPI_SUCCESS) - return ret; + return ret; } - attributes()->insert({keyval, attr_value}); return MPI_SUCCESS; } @@ -147,7 +158,7 @@ template void Keyval::cleanup_attr(){ call_deleter((T*)this, elem, it.first,it.second,&flag); } } else { - //already deleted, not a problem; + // already deleted, not a problem flag=0; } }