Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Reindent everything (possibly breaking all branches, but for the last time)
[simgrid.git] / src / simix / smx_host.c
index e26ffb6..9df094f 100644 (file)
@@ -9,13 +9,14 @@
 #include "private.h"
 #include "xbt/sysdep.h"
 #include "xbt/log.h"
+#include "xbt/dict.h"
 
 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_host, simix,
-                               "Logging specific to SIMIX (hosts)");
+                                "Logging specific to SIMIX (hosts)");
 
 /********************************* Host **************************************/
 smx_host_t __SIMIX_host_create(const char *name,
-                              void *workstation, void *data)
+                               void *workstation, void *data)
 {
   smx_simdata_host_t simdata = xbt_new0(s_smx_simdata_host_t, 1);
   smx_host_t host = xbt_new0(s_smx_host_t, 1);
@@ -29,10 +30,10 @@ smx_host_t __SIMIX_host_create(const char *name,
   simdata->host = workstation;
 
   simdata->process_list =
-      xbt_swag_new(xbt_swag_offset(proc, host_proc_hookup));
+    xbt_swag_new(xbt_swag_offset(proc, host_proc_hookup));
   /* Update global variables */
 
-  xbt_fifo_unshift(simix_global->host, host);
+  xbt_dict_set(simix_global->host, host->name, host, &__SIMIX_host_destroy);
 
   return host;
 }
@@ -80,7 +81,7 @@ const char *SIMIX_host_get_name(smx_host_t host)
 {
 
   xbt_assert0((host != NULL)
-             && (host->simdata != NULL), "Invalid parameters");
+              && (host->simdata != NULL), "Invalid parameters");
 
   /* Return data */
   return (host->name);
@@ -102,8 +103,9 @@ smx_host_t SIMIX_host_self(void)
  * MSG_host_destroy is just  a front_end that also removes it from 
  * msg_global->host
  */
-void __SIMIX_host_destroy(smx_host_t host)
+void __SIMIX_host_destroy(void *h)
 {
+  smx_host_t host = (smx_host_t) h;
   smx_simdata_host_t simdata = NULL;
 
   xbt_assert0((host != NULL), "Invalid parameters");
@@ -114,7 +116,7 @@ void __SIMIX_host_destroy(smx_host_t host)
 
   if (xbt_swag_size(simdata->process_list) != 0) {
     char *msg =
-       bprintf("Shutting down host %s, but it's not empty:", host->name);
+      bprintf("Shutting down host %s, but it's not empty:", host->name);
     char *tmp;
     smx_process_t process = NULL;
 
@@ -144,19 +146,38 @@ void __SIMIX_host_destroy(smx_host_t host)
  */
 int SIMIX_host_get_number(void)
 {
-  return (xbt_fifo_size(simix_global->host));
+  return (xbt_dict_size(simix_global->host));
 }
 
+
 /**
- * \brief Return a array of all the #smx_host_t.
+ * \brief Return an array of all the #smx_host_t.
  *
- * \return List of all hosts
+ * \return List of all hosts (in a newly allocated table)
  */
 smx_host_t *SIMIX_host_get_table(void)
 {
-  return ((smx_host_t *) xbt_fifo_to_array(simix_global->host));
+  smx_host_t *res = xbt_new(smx_host_t, xbt_dict_size(simix_global->host));
+  smx_host_t h;
+  xbt_dict_cursor_t c;
+  char *name;
+  int i = 0;
+
+  xbt_dict_foreach(simix_global->host, c, name, h)
+    res[i++] = h;
+
+  return res;
 }
 
+/**
+ * \brief Return a dict of all the #smx_host_t.
+ *
+ * \return List of all hosts (as a #xbt_dict_t)
+ */
+xbt_dict_t SIMIX_host_get_dict(void)
+{
+  return simix_global->host;
+}
 
 /**
  * \brief Return the speed of the processor.
@@ -169,8 +190,8 @@ double SIMIX_host_get_speed(smx_host_t host)
 {
   xbt_assert0((host != NULL), "Invalid parameters");
 
-  return (surf_workstation_model->
-         extension_public->get_speed(host->simdata->host, 1.0));
+  return (surf_workstation_model->extension_public->
+          get_speed(host->simdata->host, 1.0));
 }
 
 /**
@@ -183,8 +204,8 @@ double SIMIX_host_get_available_speed(smx_host_t host)
 {
   xbt_assert0((host != NULL), "Invalid parameters");
 
-  return (surf_workstation_model->
-         extension_public->get_available_speed(host->simdata->host));
+  return (surf_workstation_model->extension_public->
+          get_available_speed(host->simdata->host));
 }
 
 /**
@@ -196,18 +217,10 @@ double SIMIX_host_get_available_speed(smx_host_t host)
  */
 smx_host_t SIMIX_host_get_by_name(const char *name)
 {
-  xbt_fifo_item_t i = NULL;
-  smx_host_t host = NULL;
-
   xbt_assert0(((simix_global != NULL)
-              && (simix_global->host != NULL)),
-             "Environment not set yet");
+               && (simix_global->host != NULL)), "Environment not set yet");
 
-  xbt_fifo_foreach(simix_global->host, i, host, smx_host_t) {
-    if (strcmp(host->name, name) == 0)
-      return host;
-  }
-  return NULL;
+  return xbt_dict_get_or_null(simix_global->host, name);
 }
 
 /**
@@ -220,8 +233,8 @@ xbt_dict_t SIMIX_host_get_properties(smx_host_t host)
 {
   xbt_assert0((host != NULL), "Invalid parameters");
 
-  return (surf_workstation_model->
-         common_public->get_properties(host->simdata->host));
+  return (surf_workstation_model->common_public->
+          get_properties(host->simdata->host));
 
 }
 
@@ -237,7 +250,7 @@ int SIMIX_host_get_state(smx_host_t host)
 {
   xbt_assert0((host != NULL), "Invalid parameters");
 
-  return (surf_workstation_model->
-         extension_public->get_state(host->simdata->host));
+  return (surf_workstation_model->extension_public->
+          get_state(host->simdata->host));
 
 }