X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1ecbb4c88462e9ec9be0c830a257da6e9b774a25..20bce0939a53dd9bb3c6ea68107e9529372db19b:/src/msg/host.c diff --git a/src/msg/host.c b/src/msg/host.c index 20541bc96a..eef179c87b 100644 --- a/src/msg/host.c +++ b/src/msg/host.c @@ -55,9 +55,7 @@ m_host_t __MSG_host_create(smx_host_t workstation, void *data) } SIMIX_req_host_set_data(workstation, host); - - /* Update global variables */ - xbt_fifo_unshift(msg_global->host, host); + xbt_lib_set(host_lib,name,MSG_HOST_LEVEL,host); return host; } @@ -71,8 +69,8 @@ m_host_t __MSG_host_create(smx_host_t workstation, void *data) */ MSG_error_t MSG_host_set_data(m_host_t host, void *data) { - xbt_assert0((host != NULL), "Invalid parameters"); - xbt_assert0((host->data == NULL), "Data already set"); + xbt_assert((host != NULL), "Invalid parameters"); + xbt_assert((host->data == NULL), "Data already set"); /* Assign data */ host->data = data; @@ -90,7 +88,7 @@ MSG_error_t MSG_host_set_data(m_host_t host, void *data) void *MSG_host_get_data(m_host_t host) { - xbt_assert0((host != NULL), "Invalid parameters"); + xbt_assert((host != NULL), "Invalid parameters"); /* Return data */ return (host->data); @@ -106,7 +104,7 @@ void *MSG_host_get_data(m_host_t host) const char *MSG_host_get_name(m_host_t host) { - xbt_assert0((host != NULL) + xbt_assert((host != NULL) && (host->simdata != NULL), "Invalid parameters"); /* Return data */ @@ -125,7 +123,6 @@ m_host_t MSG_host_self(void) /* * Real function to destroy a host. * MSG_host_destroy is just a front_end that also removes it from - * msg_global->host */ void __MSG_host_destroy(m_host_t host) { @@ -133,7 +130,7 @@ void __MSG_host_destroy(m_host_t host) int i = 0; char alias[MAX_ALIAS_NAME + 1] = { 0 }; /* buffer used to build the key of the mailbox */ - xbt_assert0((host != NULL), "Invalid parameters"); + xbt_assert((host != NULL), "Invalid parameters"); /* Clean Simulator data */ /* SIMIX host will be cleaned when MSG_clean calls SIMIX_clean */ @@ -153,8 +150,6 @@ void __MSG_host_destroy(m_host_t host) /* Clean host structure */ free(host->name); free(host); - - } /** \ingroup m_host_management @@ -162,7 +157,7 @@ void __MSG_host_destroy(m_host_t host) */ int MSG_get_host_number(void) { - return (xbt_fifo_size(msg_global->host)); + return host_lib->count; } /** \ingroup m_host_management @@ -170,7 +165,23 @@ int MSG_get_host_number(void) */ m_host_t *MSG_get_host_table(void) { - return ((m_host_t *) xbt_fifo_to_array(msg_global->host)); + void **array; + int i = 0; + xbt_lib_cursor_t cursor; + char *key; + void **data; + + if (host_lib->count == 0) + return NULL; + else + array = xbt_new0(void *, host_lib->count); + + xbt_lib_foreach(host_lib, cursor, key, data) { + if(get_network_element_type(key) == SURF_NETWORK_ELEMENT_HOST) + array[i++] = data[MSG_HOST_LEVEL]; + } + + return (m_host_t *)array; } /** \ingroup m_host_management @@ -179,7 +190,7 @@ m_host_t *MSG_get_host_table(void) */ int MSG_get_host_msgload(m_host_t h) { - xbt_assert0((h != NULL), "Invalid parameters"); + xbt_assert((h != NULL), "Invalid parameters"); xbt_die( "Not implemented yet"); return (0); @@ -191,7 +202,7 @@ int MSG_get_host_msgload(m_host_t h) */ double MSG_get_host_speed(m_host_t h) { - xbt_assert0((h != NULL), "Invalid parameters"); + xbt_assert((h != NULL), "Invalid parameters"); return (SIMIX_req_host_get_speed(h->simdata->smx_host)); } @@ -216,7 +227,7 @@ const char *MSG_host_get_property_value(m_host_t host, const char *name) */ xbt_dict_t MSG_host_get_properties(m_host_t host) { - xbt_assert0((host != NULL), "Invalid parameters (host is NULL)"); + xbt_assert((host != NULL), "Invalid parameters (host is NULL)"); return (SIMIX_req_host_get_properties(host->simdata->smx_host)); } @@ -229,6 +240,6 @@ xbt_dict_t MSG_host_get_properties(m_host_t host) */ int MSG_host_is_avail(m_host_t h) { - xbt_assert0((h != NULL), "Invalid parameters (host is NULL)"); + xbt_assert((h != NULL), "Invalid parameters (host is NULL)"); return (SIMIX_req_host_get_state(h->simdata->smx_host)); }