X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/78f2b1a0a46589cd083afd39fb84a90c4c043288..a88a4036e14334a7a01fc40a7d547687ba6dee38:/include/simgrid/simix.h diff --git a/include/simgrid/simix.h b/include/simgrid/simix.h index 8f31a42b4b..9beaaf80c3 100644 --- a/include/simgrid/simix.h +++ b/include/simgrid/simix.h @@ -32,24 +32,26 @@ namespace simix { class Process; class Context; class ContextFactory; - + class Mutex; } } typedef simgrid::simix::Context *smx_context_t; typedef simgrid::simix::Process *smx_process_t; +/** + * \ingroup simix_synchro_management + */ +typedef simgrid::simix::Mutex *smx_mutex_t; + #else typedef struct s_smx_context *smx_context_t; typedef struct s_smx_process *smx_process_t; +typedef struct s_smx_mutex *smx_mutex_t; #endif - - -SG_BEGIN_DECL() - /**************************** Scalar Values **********************************/ typedef union u_smx_scalar u_smx_scalar_t; @@ -83,10 +85,7 @@ typedef enum { /** @} */ /* ******************************** Synchro ************************************ */ -/** - * \ingroup simix_synchro_management - */ -typedef struct s_smx_mutex *smx_mutex_t; + /** * \ingroup simix_synchro_management */ @@ -111,31 +110,6 @@ typedef enum { } smx_process_exit_status_t; /** @} */ - -/* - * Type of function that creates a process. - * The function must accept the following parameters: - * void* process: the process created will be stored there - * const char *name: a name for the object. It is for user-level information and can be NULL - * xbt_main_func_t code: is a function describing the behavior of the process - * void *data: data a pointer to any data one may want to attach to the new object. - * sg_host_t host: the location where the new process is executed - * int argc, char **argv: parameters passed to code - * xbt_dict_t pros: properties - */ -typedef smx_process_t (*smx_creation_func_t) ( - /* name */ const char*, - /* code */ xbt_main_func_t, - /* userdata */ void*, - /* hostname */ const char*, - /* kill_time */ double, - /* argc */ int, - /* argv */ char**, - /* props */ xbt_dict_t, - /* auto_restart */ int, - /* parent_process */ smx_process_t); - - /******************************* Networking ***********************************/ /** * \ingroup simix_mbox_management @@ -152,6 +126,8 @@ extern int smx_context_stack_size_was_set; extern int smx_context_guard_size; extern int smx_context_guard_size_was_set; +SG_BEGIN_DECL() + XBT_PUBLIC(xbt_dynar_t) SIMIX_process_get_runnable(void); XBT_PUBLIC(smx_process_t) SIMIX_process_from_PID(int PID); XBT_PUBLIC(xbt_dynar_t) SIMIX_processes_as_dynar(void); @@ -178,7 +154,6 @@ XBT_PUBLIC(void) SIMIX_global_init(int *argc, char **argv); XBT_PUBLIC(void) SIMIX_set_maestro(void (*code)(void*), void* data); XBT_PUBLIC(void) SIMIX_function_register_process_cleanup(void_pfn_smxprocess_t function); -XBT_PUBLIC(void) SIMIX_function_register_process_create(smx_creation_func_t function); XBT_PUBLIC(void) SIMIX_function_register_process_kill(void_pfn_smxprocess_t function); /* Simulation execution */ @@ -239,6 +214,8 @@ XBT_PUBLIC(void) SIMIX_host_self_set_data(void *data); XBT_PUBLIC(void*) SIMIX_host_self_get_data(void); /********************************* Process ************************************/ +XBT_PUBLIC(smx_process_t) SIMIX_process_ref(smx_process_t process); +XBT_PUBLIC(void) SIMIX_process_unref(smx_process_t process); XBT_PUBLIC(int) SIMIX_process_count(void); XBT_PUBLIC(smx_process_t) SIMIX_process_self(void); XBT_PUBLIC(const char*) SIMIX_process_self_get_name(void); @@ -249,7 +226,6 @@ XBT_PUBLIC(void) SIMIX_process_set_context(smx_process_t p,smx_context_t c); XBT_PUBLIC(int) SIMIX_process_has_pending_comms(smx_process_t process); XBT_PUBLIC(void) SIMIX_process_on_exit_runall(smx_process_t process); XBT_PUBLIC(void) SIMIX_process_on_exit(smx_process_t process, int_f_pvoid_pvoid_t fun, void *data); -XBT_PUBLIC(xbt_main_func_t) SIMIX_process_get_code(void); /****************************** Communication *********************************/ XBT_PUBLIC(void) SIMIX_comm_set_copy_data_callback(void (*callback) (smx_synchro_t, void*, size_t)); @@ -400,13 +376,15 @@ XBT_PUBLIC(void) simcall_set_category(smx_synchro_t synchro, const char *categor /************************** Synchro simcalls **********************************/ XBT_PUBLIC(smx_mutex_t) simcall_mutex_init(void); -XBT_PUBLIC(void) SIMIX_mutex_destroy(smx_mutex_t mutex); +XBT_PUBLIC(smx_mutex_t) SIMIX_mutex_ref(smx_mutex_t mutex); +XBT_PUBLIC(void) SIMIX_mutex_unref(smx_mutex_t mutex); XBT_PUBLIC(void) simcall_mutex_lock(smx_mutex_t mutex); XBT_PUBLIC(int) simcall_mutex_trylock(smx_mutex_t mutex); XBT_PUBLIC(void) simcall_mutex_unlock(smx_mutex_t mutex); XBT_PUBLIC(smx_cond_t) simcall_cond_init(void); -XBT_PUBLIC(void) SIMIX_cond_destroy(smx_cond_t cond); +XBT_PUBLIC(void) SIMIX_cond_unref(smx_cond_t cond); +XBT_PUBLIC(smx_cond_t) SIMIX_cond_ref(smx_cond_t cond); XBT_PUBLIC(void) simcall_cond_signal(smx_cond_t cond); XBT_PUBLIC(void) simcall_cond_wait(smx_cond_t cond, smx_mutex_t mutex); XBT_PUBLIC(void) simcall_cond_wait_timeout(smx_cond_t cond,