X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/51568df0f325c38dca2ac96d3a126de8b225716a..08ce0edd12b2c42378cc228a91d37613bbc2acbc:/src/simix/private.h diff --git a/src/simix/private.h b/src/simix/private.h index 0630a01612..2008f9c1eb 100644 --- a/src/simix/private.h +++ b/src/simix/private.h @@ -12,6 +12,7 @@ #include "xbt/fifo.h" #include "xbt/swag.h" #include "xbt/dict.h" +#include "xbt/mallocator.h" #include "xbt/config.h" #include "xbt/function_types.h" #include "xbt/ex_interface.h" @@ -23,27 +24,26 @@ #include "synchro_private.h" #include "simix/context.h" -/********************************** Simix Global ******************************/ - +/* Define only for SimGrid benchmarking purposes */ +#undef TIME_BENCH +/********************************** Simix Global ******************************/ typedef struct s_smx_global { smx_context_factory_t context_factory; - xbt_dict_t host; xbt_dynar_t process_to_run; + xbt_dynar_t process_that_ran; xbt_swag_t process_list; xbt_swag_t process_to_destroy; smx_process_t maestro_process; xbt_dict_t registered_functions; smx_creation_func_t create_process_function; - void_f_pvoid_t kill_process_function; + void_pfn_smxprocess_t kill_process_function; void_pfn_smxprocess_t cleanup_process_function; -#ifdef HAVE_LATENCY_BOUND_TRACKING - xbt_dict_t latency_limited_dict; -#endif + xbt_mallocator_t action_mallocator; } s_smx_global_t, *smx_global_t; extern smx_global_t simix_global; - +extern unsigned long simix_process_maxpid; /*********************************** Time ************************************/ @@ -92,6 +92,7 @@ typedef struct s_smx_action { e_smx_comm_type_t type; /* Type of the communication (SIMIX_COMM_SEND or SIMIX_COMM_RECEIVE) */ smx_rdv_t rdv; /* Rendez-vous where the comm is queued */ int refcount; /* Number of processes involved in the cond */ + int detached; /* If detached or not */ /* Surf action data */ surf_action_t surf_comm; /* The Surf communication action encapsulated */ @@ -150,11 +151,11 @@ static XBT_INLINE e_smx_state_t SIMIX_action_map_state(e_surf_action_state_t sta } } - - void SIMIX_context_mod_init(void); void SIMIX_context_mod_exit(void); +XBT_INLINE void SIMIX_context_set_current(smx_context_t context); +XBT_INLINE smx_context_t SIMIX_context_get_current(void); /* All factories init */ void SIMIX_ctx_thread_factory_init(smx_context_factory_t *factory); @@ -230,12 +231,11 @@ static XBT_INLINE void SIMIX_context_suspend(smx_context_t context) } /** - \brief executes all the processes (in parallel if possible) - \param processes the dynar of processes to execute + \brief Executes all the processes to run (in parallel if possible). */ -static XBT_INLINE void SIMIX_context_runall(xbt_dynar_t processes) +static XBT_INLINE void SIMIX_context_runall() { - (*(simix_global->context_factory->runall)) (processes); + (*(simix_global->context_factory->runall)) (); } /**