X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e509955c811a80b2d03f306fa04316a6b050dbcf..022fcd4dab24301e12c127f24f04c05d90d2d39a:/src/surf/HostImpl.cpp diff --git a/src/surf/HostImpl.cpp b/src/surf/HostImpl.cpp index e5c64670ae..3d6f18003e 100644 --- a/src/surf/HostImpl.cpp +++ b/src/surf/HostImpl.cpp @@ -3,10 +3,11 @@ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ +#include "simgrid/kernel/routing/NetPoint.hpp" #include "simgrid/s4u/Engine.hpp" #include "simgrid/s4u/Host.hpp" +#include "src/kernel/EngineImpl.hpp" #include "src/plugins/vm/VirtualMachineImpl.hpp" -#include "src/simix/smx_private.hpp" #include @@ -45,7 +46,7 @@ HostImpl::~HostImpl() for (auto const& actor : actor_list_) msg += "\n\t" + std::string(actor.get_name()); - simix_global->display_all_actor_status(); + kernel::EngineImpl::get_instance()->display_all_actor_status(); xbt_die("%s", msg.c_str()); } for (auto const& arg : actors_at_boot_) @@ -75,8 +76,9 @@ void HostImpl::turn_on() const { for (auto const& arg : actors_at_boot_) { XBT_DEBUG("Booting Actor %s(%s) right now", arg->name.c_str(), arg->host->get_cname()); - simgrid::kernel::actor::ActorImplPtr actor = simgrid::kernel::actor::ActorImpl::create( - arg->name, arg->code, nullptr, arg->host, arg->properties.get(), nullptr); + simgrid::kernel::actor::ActorImplPtr actor = + simgrid::kernel::actor::ActorImpl::create(arg->name, arg->code, nullptr, arg->host, nullptr); + actor->set_properties(arg->properties); if (arg->on_exit) *actor->on_exit = *arg->on_exit; if (arg->kill_time >= 0) @@ -127,11 +129,11 @@ std::vector HostImpl::get_disks() const return disks; } -void HostImpl::set_disks(const std::vector& disks, s4u::Host* host) +s4u::Disk* HostImpl::create_disk(const std::string& name, double read_bandwidth, double write_bandwidth) { - disks_ = disks; - for (auto d : disks_) - d->set_host(host); + auto disk = piface_.get_netpoint()->get_englobing_zone()->get_disk_model()->create_disk(name, read_bandwidth, + write_bandwidth); + return disk->set_host(&piface_)->get_iface(); } void HostImpl::add_disk(const s4u::Disk* disk) @@ -153,7 +155,16 @@ void HostImpl::remove_disk(const std::string& disk_name) void HostImpl::seal() { + if (sealed_) { + return; + } + // seals host's CPU + get_iface()->pimpl_cpu->seal(); sealed_ = true; + + /* seal its disks */ + for (auto* disk : disks_) + disk->seal(); } } // namespace surf } // namespace simgrid