From 3fc3df9c2436f1d43646969194d96f73ea3d4915 Mon Sep 17 00:00:00 2001 From: Martin Quinson Date: Thu, 16 Feb 2017 00:07:44 +0100 Subject: [PATCH] move two severly misnamed identifiers to make them static --- src/msg/msg_host.cpp | 18 ------------------ src/msg/msg_io.cpp | 23 +++++++++++++++++++++-- src/msg/msg_private.h | 3 --- 3 files changed, 21 insertions(+), 23 deletions(-) diff --git a/src/msg/msg_host.cpp b/src/msg/msg_host.cpp index edd0280535..ade4a6371c 100644 --- a/src/msg/msg_host.cpp +++ b/src/msg/msg_host.cpp @@ -7,8 +7,6 @@ #include "simgrid/s4u/host.hpp" #include "src/msg/msg_private.h" -#include - XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(msg); simgrid::xbt::Extension simgrid::MsgHostExt::EXTENSION_ID; @@ -283,19 +281,3 @@ xbt_dict_t MSG_host_get_storage_content(msg_host_t host) xbt_dict_free(&storage_list); return contents; } - -int __MSG_host_get_file_descriptor_id(msg_host_t host){ - simgrid::MsgHostExt* priv = host->extension(); - if (priv->file_descriptor_table == nullptr) { - priv->file_descriptor_table = new std::vector(sg_storage_max_file_descriptors); - std::iota (priv->file_descriptor_table->rbegin(), priv->file_descriptor_table->rend(), 0); // Fill with ..., 1, 0. - } - xbt_assert(!priv->file_descriptor_table->empty(), "Too much files are opened! Some have to be closed."); - int desc = priv->file_descriptor_table->back(); - priv->file_descriptor_table->pop_back(); - return desc; -} - -void __MSG_host_release_file_descriptor_id(msg_host_t host, int id){ - host->extension()->file_descriptor_table->push_back(id); -} diff --git a/src/msg/msg_io.cpp b/src/msg/msg_io.cpp index aff8c7e884..2552c9888e 100644 --- a/src/msg/msg_io.cpp +++ b/src/msg/msg_io.cpp @@ -5,6 +5,7 @@ #include "simgrid/s4u/host.hpp" #include "src/msg/msg_private.h" +#include XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_io, msg, "Logging specific to MSG (io)"); @@ -31,6 +32,24 @@ void __MSG_file_get_info(msg_file_t fd){ xbt_dynar_free_container(&info); } +static int MSG_host_get_file_descriptor_id(msg_host_t host) +{ + simgrid::MsgHostExt* priv = host->extension(); + if (priv->file_descriptor_table == nullptr) { + priv->file_descriptor_table = new std::vector(sg_storage_max_file_descriptors); + std::iota(priv->file_descriptor_table->rbegin(), priv->file_descriptor_table->rend(), 0); // Fill with ..., 1, 0. + } + xbt_assert(!priv->file_descriptor_table->empty(), "Too much files are opened! Some have to be closed."); + int desc = priv->file_descriptor_table->back(); + priv->file_descriptor_table->pop_back(); + return desc; +} + +static void MSG_host_release_file_descriptor_id(msg_host_t host, int id) +{ + host->extension()->file_descriptor_table->push_back(id); +} + /** \ingroup msg_file * * \brief Set the user data of a #msg_file_t. @@ -196,7 +215,7 @@ msg_file_t MSG_file_open(const char* fullpath, void* data) priv->fullpath = xbt_strdup(fullpath); priv->simdata = xbt_new0(s_simdata_file_t,1); priv->simdata->smx_file = simcall_file_open(fullpath, MSG_host_self()); - priv->desc_id = __MSG_host_get_file_descriptor_id(MSG_host_self()); + priv->desc_id = MSG_host_get_file_descriptor_id(MSG_host_self()); name = bprintf("%s:%s:%d", priv->fullpath, MSG_host_self()->cname(), priv->desc_id); @@ -223,7 +242,7 @@ int MSG_file_close(msg_file_t fd) int res = simcall_file_close(priv->simdata->smx_file, MSG_host_self()); name = bprintf("%s:%s:%d", priv->fullpath, MSG_host_self()->cname(), priv->desc_id); - __MSG_host_release_file_descriptor_id(MSG_host_self(), priv->desc_id); + MSG_host_release_file_descriptor_id(MSG_host_self(), priv->desc_id); xbt_lib_unset(file_lib, name, MSG_FILE_LEVEL, 1); xbt_free(name); return res; diff --git a/src/msg/msg_private.h b/src/msg/msg_private.h index e675c36740..0f35f3b21f 100644 --- a/src/msg/msg_private.h +++ b/src/msg/msg_private.h @@ -73,9 +73,6 @@ typedef struct simdata_file { smx_file_t smx_file; } s_simdata_file_t; -XBT_PRIVATE int __MSG_host_get_file_descriptor_id(msg_host_t host); -XBT_PRIVATE void __MSG_host_release_file_descriptor_id(msg_host_t host, int id); - /******************************* Process *************************************/ typedef struct simdata_process { -- 2.20.1