X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ca8f76da2b1e18b55a714168f71bdeae99386425..3fc3df9c2436f1d43646969194d96f73ea3d4915:/src/msg/msg_private.h diff --git a/src/msg/msg_private.h b/src/msg/msg_private.h index d0c49706c4..0f35f3b21f 100644 --- a/src/msg/msg_private.h +++ b/src/msg/msg_private.h @@ -7,31 +7,28 @@ #ifndef METASIMGRID_PRIVATE_H #define METASIMGRID_PRIVATE_H -#include -#include - #include "simgrid/msg.h" -#include "simgrid/simix.h" -#include "src/include/surf/surf.h" -#include "xbt/base.h" -#include "xbt/fifo.h" -#include "xbt/dynar.h" -#include "xbt/swag.h" -#include "xbt/dict.h" -#include "xbt/config.h" -#include "src/instr/instr_private.h" #include "src/kernel/activity/SynchroExec.hpp" #include "src/kernel/activity/SynchroComm.hpp" +#include + SG_BEGIN_DECL() /**************** datatypes **********************************/ -/********************************* Host **************************************/ -typedef struct s_msg_host_priv { - - std::vector *file_descriptor_table; -} s_msg_host_priv_t; +/**************************** Host Extension *********************************/ +namespace simgrid { +class MsgHostExt { +public: + static simgrid::xbt::Extension EXTENSION_ID; + + ~MsgHostExt() { + delete file_descriptor_table; + } + std::vector* file_descriptor_table = nullptr; // Created lazily on need +}; +} /********************************* Task **************************************/ typedef struct simdata_task { @@ -76,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 { @@ -108,16 +102,6 @@ typedef struct msg_comm { msg_error_t status; /* status of the communication once finished */ } s_msg_comm_t; -/******************************* VM *************************************/ -typedef struct dirty_page { - double prev_clock; - double prev_remaining; - msg_task_t task; -} s_dirty_page, *dirty_page_t; - -XBT_PUBLIC_DATA(msg_vm_t) MSG_vm_get_by_name(const char *name); -XBT_PUBLIC_DATA(const char*) MSG_vm_get_name(msg_vm_t vm); - /************************** Global variables ********************************/ typedef struct MSG_Global { int debug_multiple_use; /* whether we want an error message when reusing the same Task for 2 things */ @@ -132,7 +116,6 @@ XBT_PUBLIC_DATA(MSG_Global_t) msg_global; /*************************************************************/ XBT_PRIVATE msg_host_t __MSG_host_create(sg_host_t host); XBT_PRIVATE msg_storage_t __MSG_storage_create(smx_storage_t storage); -XBT_PRIVATE void __MSG_host_priv_free(msg_host_priv_t priv); XBT_PRIVATE void __MSG_storage_destroy(msg_storage_priv_t host); XBT_PRIVATE void __MSG_file_destroy(msg_file_priv_t host); @@ -173,19 +156,6 @@ XBT_PRIVATE void TRACE_msg_process_resume(msg_process_t process); XBT_PRIVATE void TRACE_msg_process_sleep_in(msg_process_t process); //called from msg/gos.c XBT_PRIVATE void TRACE_msg_process_sleep_out(msg_process_t process); -/* declaration of instrumentation functions from instr_msg_vm.c */ -XBT_PRIVATE char *instr_vm_id(msg_vm_t vm, char *str, int len); -XBT_PRIVATE char *instr_vm_id_2(const char *vm_name, char *str, int len); -XBT_PRIVATE void TRACE_msg_vm_change_host(msg_vm_t vm, msg_host_t old_host, msg_host_t new_host); -XBT_PRIVATE void TRACE_msg_vm_start(msg_vm_t vm); -XBT_PRIVATE void TRACE_msg_vm_create(const char *vm_name, msg_host_t host); -XBT_PRIVATE void TRACE_msg_vm_kill(msg_vm_t process); -XBT_PRIVATE void TRACE_msg_vm_suspend(msg_vm_t vm); -XBT_PRIVATE void TRACE_msg_vm_resume(msg_vm_t vm); -XBT_PRIVATE void TRACE_msg_vm_save(msg_vm_t vm); -XBT_PRIVATE void TRACE_msg_vm_restore(msg_vm_t vm); -XBT_PRIVATE void TRACE_msg_vm_end(msg_vm_t vm); - SG_END_DECL() XBT_PUBLIC(msg_process_t) MSG_process_create_with_environment(