#include "xbt/sysdep.h"
#include "xbt/log.h"
#include "xbt/dict.h"
+#include "msg/mailbox.h"
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_process, simix,
"Logging specific to SIMIX (process)");
smx_process_t process = xbt_new0(s_smx_process_t, 1);
smx_process_t self = NULL;
smx_host_t host = SIMIX_host_get_by_name(hostname);
-
+ /*char alias[MAX_ALIAS_NAME + 1] = {0};
+ msg_mailbox_t mailbox;*/
+
xbt_assert0(((code != NULL) && (host != NULL)), "Invalid parameters");
/* Simulator Data */
xbt_swag_insert(process, simix_global->process_list);
DEBUG2("Inserting %s(%s) in the to_run list", process->name, host->name);
xbt_swag_insert(process, simix_global->process_to_run);
+
+ /*sprintf(alias,"%s:%s",hostname,process->name);
+
+ mailbox = MSG_mailbox_new(alias);
+ MSG_mailbox_set_hostname(mailbox, hostname);*/
return process;
}
surf_workstation_model->common_public->suspend(dummy->simdata->surf_action);
SIMIX_register_action_to_condition(dummy, cond);
__SIMIX_cond_wait(cond);
- //SIMIX_action_destroy(dummy);
- //SIMIX_cond_destroy(cond);
+ SIMIX_unregister_action_to_condition(dummy, cond);
+ SIMIX_action_destroy(dummy);
+ SIMIX_cond_destroy(cond);
}
return;
}
}
+/**
+ * \brief Migrates an agent to another location.
+ *
+ * This function changes the value of the host on which \a process is running.
+ */
+void SIMIX_process_change_host(smx_process_t process, char *source, char *dest)
+{
+ smx_simdata_process_t p_simdata = process->simdata;
+ smx_host_t h1 = SIMIX_host_get_by_name(source);
+ smx_host_t h2 = SIMIX_host_get_by_name(dest);
+ p_simdata->smx_host = h2;
+ xbt_swag_remove(process, h1->simdata->process_list);
+ xbt_swag_insert(process, h2->simdata->process_list);
+}
+
/**
* \brief Returns true if the process is suspended .
*