X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/99383eeb636e1bdf5c62954179c28251d45e18ac..43dc8ea1eae96e9d084aaabeed9beef568a7dea6:/src/s4u/s4u_Host.cpp diff --git a/src/s4u/s4u_Host.cpp b/src/s4u/s4u_Host.cpp index fa9d46c29f..589438ce47 100644 --- a/src/s4u/s4u_Host.cpp +++ b/src/s4u/s4u_Host.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-2021. The SimGrid Team. All rights reserved. */ /* 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. */ @@ -6,6 +6,7 @@ #include "simgrid/host.h" #include "simgrid/kernel/routing/NetPoint.hpp" #include "simgrid/s4u/Actor.hpp" +#include "simgrid/s4u/Comm.hpp" #include "simgrid/s4u/Engine.hpp" #include "simgrid/s4u/Exec.hpp" #include "simgrid/s4u/VirtualMachine.hpp" @@ -44,7 +45,6 @@ Host::~Host() if (pimpl_netpoint_ != nullptr) // not removed yet by a children class Engine::get_instance()->netpoint_unregister(pimpl_netpoint_); delete pimpl_cpu; - delete mounts_; } /** @brief Fire the required callbacks and destroy the object @@ -96,7 +96,7 @@ void Host::turn_on() void Host::turn_off() { if (is_on()) { - kernel::actor::ActorImpl* self = kernel::actor::ActorImpl::self(); + const kernel::actor::ActorImpl* self = kernel::actor::ActorImpl::self(); kernel::actor::simcall([this, self] { for (VirtualMachine* const& vm : vm::VirtualMachineImpl::allVms_) if (vm->get_pm() == this) { @@ -180,12 +180,9 @@ void Host::sendto(Host* dest, double byte_amount) sendto_async(dest, byte_amount)->wait(); } -ActivityPtr Host::sendto_async(Host* dest, double byte_amount) +CommPtr Host::sendto_async(Host* dest, double byte_amount) { - std::vector m_host_list = {this, dest}; - std::vector flops_amount = {0, 0}; - std::vector bytes_amount = {0, byte_amount, 0, 0}; - return this_actor::exec_init(m_host_list, flops_amount, bytes_amount)->start(); + return Comm::sendto_async(this, dest, byte_amount); } /** Get the properties assigned to a host */ @@ -267,7 +264,7 @@ std::vector Host::get_disks() const return kernel::actor::simcall([this] { return this->pimpl_->get_disks(); }); } -void Host::add_disk(Disk* disk) +void Host::add_disk(const Disk* disk) { kernel::actor::simcall([this, disk] { this->pimpl_->add_disk(disk); }); } @@ -276,24 +273,6 @@ void Host::remove_disk(const std::string& disk_name) { kernel::actor::simcall([this, disk_name] { this->pimpl_->remove_disk(disk_name); }); } -/** - * @ingroup simix_storage_management - * @brief Returns the list of storages attached to a host. - * @return a vector containing all storages attached to the host - */ -std::vector Host::get_attached_storages() const -{ - return kernel::actor::simcall([this] { return this->pimpl_->get_attached_storages(); }); -} - -std::unordered_map const& Host::get_mounted_storages() -{ - kernel::actor::simcall([this] { - if (mounts_ == nullptr) - mounts_ = pimpl_->get_mounted_storages(); - }); - return *mounts_; -} ExecPtr Host::exec_async(double flops) const { @@ -398,7 +377,7 @@ void sg_host_user_destroy(sg_host_t host) // XBT_ATTRIB_DEPRECATED_v328 host->set_data(nullptr); } -// ========= storage related functions ============ +// ========= Disk related functions ============ void sg_host_get_disks(const_sg_host_t host, unsigned int* disk_count, sg_disk_t** disks) { std::vector list = host->get_disks(); @@ -408,28 +387,6 @@ void sg_host_get_disks(const_sg_host_t host, unsigned int* disk_count, sg_disk_t (*disks)[i] = list[i]; } -xbt_dict_t sg_host_get_mounted_storage_list(sg_host_t host) // XBT_ATTRIB_DEPRECATED_v330 -{ - xbt_assert((host != nullptr), "Invalid parameters"); - xbt_dict_t res = xbt_dict_new_homogeneous(nullptr); - for (auto const& elm : host->get_mounted_storages()) { - const char* mount_name = elm.first.c_str(); - const simgrid::s4u::Storage* storage = elm.second; - xbt_dict_set(res, mount_name, (void*)storage->get_cname()); - } - - return res; -} - -xbt_dynar_t sg_host_get_attached_storage_list(const_sg_host_t host) -{ - xbt_dynar_t storage_dynar = xbt_dynar_new(sizeof(const char*), nullptr); - std::vector storage_vector = host->get_attached_storages(); - for (auto const& name : storage_vector) - xbt_dynar_push(storage_dynar, &name); - return storage_dynar; -} - // =========== user-level functions =============== // ================================================ /** @brief Returns the total speed of a host */