X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/95d328f9ca4dd6ccd2065c6c84aca83d43001804..dff9e15c44ab6340d27215957c56fa72fad246a2:/src/gras/Msg/gras_msg_mod.c?ds=sidebyside diff --git a/src/gras/Msg/gras_msg_mod.c b/src/gras/Msg/gras_msg_mod.c index 580a29909e..63d259d7fd 100644 --- a/src/gras/Msg/gras_msg_mod.c +++ b/src/gras/Msg/gras_msg_mod.c @@ -19,78 +19,83 @@ extern xbt_set_t _gras_msgtype_set; /* * Creating procdata for this module */ -static void *gras_msg_procdata_new(void) { - gras_msg_procdata_t res = xbt_new(s_gras_msg_procdata_t,1); - - res->name = xbt_strdup("gras_msg"); - res->name_len = 0; - res->msg_queue = xbt_dynar_new(sizeof(s_gras_msg_t), NULL); - res->msg_waitqueue = xbt_dynar_new(sizeof(s_gras_msg_t), NULL); - res->cbl_list = xbt_dynar_new(sizeof(gras_cblist_t *),gras_cbl_free); - res->timers = xbt_dynar_new(sizeof(s_gras_timer_t), NULL); - res->msg_to_receive_queue = xbt_fifo_new(); - res->msg_to_receive_queue_meas = xbt_fifo_new(); - res->msg_received = xbt_queue_new(0,sizeof(s_gras_msg_t)); - - return (void*)res; +static void *gras_msg_procdata_new(void) +{ + gras_msg_procdata_t res = xbt_new(s_gras_msg_procdata_t, 1); + + res->name = xbt_strdup("gras_msg"); + res->name_len = 0; + res->msg_queue = xbt_dynar_new(sizeof(s_gras_msg_t), NULL); + res->msg_waitqueue = xbt_dynar_new(sizeof(s_gras_msg_t), NULL); + res->cbl_list = xbt_dynar_new(sizeof(gras_cblist_t *), gras_cbl_free); + res->timers = xbt_dynar_new(sizeof(s_gras_timer_t), NULL); + res->msg_to_receive_queue = xbt_fifo_new(); + res->msg_to_receive_queue_meas = xbt_fifo_new(); + res->msg_received = xbt_queue_new(0, sizeof(s_gras_msg_t)); + + return (void *) res; } /* * Freeing procdata for this module */ -static void gras_msg_procdata_free(void *data) { - gras_msg_procdata_t res = (gras_msg_procdata_t)data; - - xbt_dynar_free(&( res->msg_queue )); - xbt_dynar_free(&( res->msg_waitqueue )); - xbt_dynar_free(&( res->cbl_list )); - xbt_dynar_free(&( res->timers )); - xbt_fifo_free( res->msg_to_receive_queue ); - xbt_fifo_free( res->msg_to_receive_queue_meas ); - - free(res->name); - free(res); +static void gras_msg_procdata_free(void *data) +{ + gras_msg_procdata_t res = (gras_msg_procdata_t) data; + + xbt_dynar_free(&(res->msg_queue)); + xbt_dynar_free(&(res->msg_waitqueue)); + xbt_dynar_free(&(res->cbl_list)); + xbt_dynar_free(&(res->timers)); + xbt_fifo_free(res->msg_to_receive_queue); + xbt_fifo_free(res->msg_to_receive_queue_meas); + + free(res->name); + free(res); } /* * Module registration */ int gras_msg_libdata_id; -void gras_msg_register() { - gras_msg_libdata_id = gras_procdata_add("gras_msg",gras_msg_procdata_new, gras_msg_procdata_free); +void gras_msg_register() +{ + gras_msg_libdata_id = + gras_procdata_add("gras_msg", gras_msg_procdata_new, + gras_msg_procdata_free); } /* * Initialize this submodule. */ -void gras_msg_init(void) { - /* only initialize once */ - if (_gras_msgtype_set != NULL) - return; +void gras_msg_init(void) +{ + /* only initialize once */ + if (_gras_msgtype_set != NULL) + return; - VERB0("Initializing Msg"); + VERB0("Initializing Msg"); - _gras_msgtype_set = xbt_set_new(); + _gras_msgtype_set = xbt_set_new(); - memcpy(_GRAS_header,"GRAS", 4); - _GRAS_header[4]=GRAS_PROTOCOL_VERSION; - _GRAS_header[5]=(char)GRAS_THISARCH; + memcpy(_GRAS_header, "GRAS", 4); + _GRAS_header[4] = GRAS_PROTOCOL_VERSION; + _GRAS_header[5] = (char) GRAS_THISARCH; - gras_msg_ctx_mallocator = - xbt_mallocator_new(1000, - gras_msg_ctx_mallocator_new_f, - gras_msg_ctx_mallocator_free_f, - gras_msg_ctx_mallocator_reset_f); + gras_msg_ctx_mallocator = + xbt_mallocator_new(1000, + gras_msg_ctx_mallocator_new_f, + gras_msg_ctx_mallocator_free_f, + gras_msg_ctx_mallocator_reset_f); } /* * Finalize the msg module */ -void -gras_msg_exit(void) { - VERB0("Exiting Msg"); - xbt_set_free(&_gras_msgtype_set); +void gras_msg_exit(void) +{ + VERB0("Exiting Msg"); + xbt_set_free(&_gras_msgtype_set); - xbt_mallocator_free(gras_msg_ctx_mallocator); + xbt_mallocator_free(gras_msg_ctx_mallocator); } -