X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/08b0207634111339deda63fa368c42be87b6dc13..e595b191c3e10a96a9d896f6ecec9c4df6707aef:/src/msg/msg_io.cpp diff --git a/src/msg/msg_io.cpp b/src/msg/msg_io.cpp index b4791450a6..776adfe90b 100644 --- a/src/msg/msg_io.cpp +++ b/src/msg/msg_io.cpp @@ -200,10 +200,7 @@ int MSG_file_close(msg_file_t fd) */ msg_error_t MSG_file_unlink(msg_file_t fd) { - /* Find the host where the file is physically located (remote or local)*/ - msg_storage_t storage_src = simgrid::s4u::Storage::byName(fd->storageId); - msg_host_t attached_host = storage_src->getHost(); - fd->unlink(attached_host); + fd->unlink(); delete fd; return MSG_OK; } @@ -326,7 +323,7 @@ msg_error_t MSG_file_rcopy (msg_file_t file, msg_host_t host, const char* fullpa /* Create file on remote host, write it and close it */ msg_file_t fd = new simgrid::s4u::File(fullpath, dst_host, nullptr); - fd->write(read_size, dst_host); + fd->write(read_size); delete fd; return MSG_OK; } @@ -391,7 +388,14 @@ sg_size_t MSG_storage_get_used_size(msg_storage_t storage) xbt_dict_t MSG_storage_get_properties(msg_storage_t storage) { xbt_assert((storage != nullptr), "Invalid parameters (storage is nullptr)"); - return storage->getProperties(); + xbt_dict_t as_dict = xbt_dict_new_homogeneous(xbt_free_f); + std::map* props = storage->getProperties(); + if (props == nullptr) + return nullptr; + for (auto elm : *props) { + xbt_dict_set(as_dict, elm.first.c_str(), xbt_strdup(elm.second.c_str()), nullptr); + } + return as_dict; } /** \ingroup msg_storage_management @@ -473,14 +477,14 @@ void *MSG_storage_get_data(msg_storage_t storage) xbt_dict_t MSG_storage_get_content(msg_storage_t storage) { std::map* content = storage->getContent(); - xbt_dict_t content_dict = xbt_dict_new_homogeneous(&free); + xbt_dict_t content_as_dict = xbt_dict_new_homogeneous(xbt_free_f); for (auto entry : *content) { sg_size_t* psize = static_cast(malloc(sizeof(sg_size_t))); *psize = entry.second; - xbt_dict_set(content_dict, entry.first.c_str(), psize, nullptr); + xbt_dict_set(content_as_dict, entry.first.c_str(), psize, nullptr); } - return content_dict; + return content_as_dict; } /** \ingroup msg_storage_management