}
// ========== Simix layer =============
+#include "src/simix/smx_host_private.h"
smx_host_priv_t sg_host_simix(sg_host_t host){
- return (smx_host_priv_t) host->extension(SIMIX_HOST_LEVEL);
+ return host->extension<simgrid::simix::Host>();
}
void sg_host_simix_set(sg_host_t host, smx_host_priv_t smx_host) {
- host->extension_set(SIMIX_HOST_LEVEL, smx_host);
+ host->extension_set<simgrid::simix::Host>(smx_host);
}
void sg_host_simix_destroy(sg_host_t host) {
- host->extension_set(SIMIX_HOST_LEVEL, nullptr);
+ host->extension_set<simgrid::simix::Host>(nullptr);
}
// ========= storage related functions ============
namespace simgrid {
namespace simix {
+ simgrid::xbt::Extension<simgrid::s4u::Host, Host> Host::EXTENSION_ID;
+
Host::Host()
{
+ if (!EXTENSION_ID.valid())
+ EXTENSION_ID = simgrid::s4u::Host::extension_create<simgrid::simix::Host>();
+
simgrid::simix::ActorImpl act;
process_list = xbt_swag_new(xbt_swag_offset(act, host_proc_hookup));
}
+
+ Host::~Host()
+ {
+ /* Clean Simulator data */
+ if (xbt_swag_size(process_list) != 0) {
+ char *msg = xbt_strdup("Shutting down host, but it's not empty:");
+ char *tmp;
+ smx_actor_t process = nullptr;
+
+ xbt_swag_foreach(process, process_list) {
+ tmp = bprintf("%s\n\t%s", msg, process->name.c_str());
+ free(msg);
+ msg = tmp;
+ }
+ SIMIX_display_process_status();
+ THROWF(arg_error, 0, "%s", msg);
+ }
+ xbt_dynar_free(&auto_restart_processes);
+ xbt_dynar_free(&boot_processes);
+ xbt_swag_free(process_list);
+ }
}
}
}
}
-/**
- * \brief Internal function to destroy a SIMIX host.
- *
- * \param h the host to destroy (a sg_host_t)
- */
-void SIMIX_host_destroy(void *h)
-{
- smx_host_priv_t host = static_cast<smx_host_priv_t>(h);
-
- xbt_assert((host != nullptr), "Invalid parameters");
-
- /* Clean Simulator data */
- if (xbt_swag_size(host->process_list) != 0) {
- char *msg = xbt_strdup("Shutting down host, but it's not empty:");
- char *tmp;
- smx_actor_t process = nullptr;
-
- xbt_swag_foreach(process, host->process_list) {
- tmp = bprintf("%s\n\t%s", msg, process->name.c_str());
- free(msg);
- msg = tmp;
- }
- SIMIX_display_process_status();
- THROWF(arg_error, 0, "%s", msg);
- }
- xbt_dynar_free(&host->auto_restart_processes);
- xbt_dynar_free(&host->boot_processes);
- xbt_swag_free(host->process_list);
-
- /* Clean host structure */
- delete host;
-}
-
sg_host_t SIMIX_host_self()
{
smx_actor_t process = SIMIX_process_self();
#include <functional>
#include <xbt/base.h>
+#include <xbt/Extendable.hpp>
#include "simgrid/simix.h"
#include "popping_private.h"
namespace simix {
class Host {
public:
+ static simgrid::xbt::Extension<simgrid::s4u::Host, Host> EXTENSION_ID;
+
explicit Host();
+ virtual ~Host();
xbt_swag_t process_list;
xbt_dynar_t auto_restart_processes = nullptr;
XBT_PRIVATE void _SIMIX_host_free_process_arg(void *);
XBT_PRIVATE void SIMIX_host_create(sg_host_t host);
-XBT_PRIVATE void SIMIX_host_destroy(void *host);
XBT_PRIVATE void SIMIX_host_add_auto_restart_process(sg_host_t host,
const char *name,