X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1f9e1424e8bfd8214561ba0675276f91ebc308c2..212a22112855f8531e29e54f0db872ec4f0f4b7e:/src/msg/private.h diff --git a/src/msg/private.h b/src/msg/private.h index 45352e09a5..697381fba0 100644 --- a/src/msg/private.h +++ b/src/msg/private.h @@ -16,6 +16,7 @@ #include "xbt/dict.h" #include "xbt/context.h" #include "xbt/config.h" +#include "xbt/mallocator.h" /**************** datatypes **********************************/ @@ -87,6 +88,8 @@ typedef struct MSG_Global { int paje_maxPID; int PID; int session; + xbt_mallocator_t task_mallocator; + xbt_mallocator_t task_simdata_mallocator; } s_MSG_Global_t, *MSG_Global_t; extern MSG_Global_t msg_global; @@ -117,12 +120,16 @@ void __MSG_task_execute(m_process_t process, m_task_t task); MSG_error_t __MSG_wait_for_computation(m_process_t process, m_task_t task); MSG_error_t __MSG_task_wait_event(m_process_t process, m_task_t task); -int __MSG_process_block(double max_duration); +int __MSG_process_block(double max_duration, const char *info); MSG_error_t __MSG_process_unblock(m_process_t process); int __MSG_process_isBlocked(m_process_t process); void __MSG_display_process_status(void); +m_task_t task_mallocator_new_f(void); +void task_mallocator_free_f(m_task_t task); +void task_mallocator_reset_f(m_task_t task); + #ifdef ALVIN_SPECIAL_LOGING #define PAJE_PROCESS_STATE(process,state)\ if(msg_global->paje_output) \