new surf::HostImpl(this);
}
-Host::~Host()
+Host* Host::set_netpoint(kernel::routing::NetPoint* netpoint)
{
- xbt_assert(currently_destroying_, "Please call h->destroy() instead of manually deleting it.");
+ pimpl_netpoint_ = netpoint;
+ return this;
+}
+Host::~Host()
+{
delete pimpl_;
if (pimpl_netpoint_ != nullptr) // not removed yet by a children class
Engine::get_instance()->netpoint_unregister(pimpl_netpoint_);
*/
void Host::destroy()
{
- if (not currently_destroying_) {
- currently_destroying_ = true;
- on_destruction(*this);
- Engine::get_instance()->host_unregister(std::string(name_));
- delete this;
- }
+ on_destruction(*this);
+ Engine::get_instance()->host_unregister(std::string(name_));
+ delete this;
}
Host* Host::by_name(const std::string& name)
return this->pimpl_->get_property(key);
}
-void Host::set_property(const std::string& key, const std::string& value)
+Host* Host::set_property(const std::string& key, const std::string& value)
{
kernel::actor::simcall([this, &key, &value] { this->pimpl_->set_property(key, value); });
+ return this;
}
-void Host::set_properties(const std::unordered_map<std::string, std::string>& properties)
+Host* Host::set_properties(const std::unordered_map<std::string, std::string>& properties)
{
kernel::actor::simcall([this, &properties] { this->pimpl_->set_properties(properties); });
+ return this;
}
/** Specify a profile turning the host on and off according to an exhaustive list or a stochastic law.
return this->pimpl_cpu->get_core_count();
}
+Host* Host::set_core_count(int core_count)
+{
+ this->pimpl_cpu->set_core_count(core_count);
+ return this;
+}
+
/** @brief Set the pstate at which the host should run */
void Host::set_pstate(int pstate_index)
{
return kernel::actor::simcall([this] { return this->pimpl_->get_disks(); });
}
+Disk* Host::create_disk(const std::string& name, double read_bandwidth, double write_bandwidth)
+{
+ return surf_disk_model->create_disk(name, read_bandwidth, write_bandwidth)->set_host(this)->get_iface();
+}
+
void Host::add_disk(const Disk* disk)
{
kernel::actor::simcall([this, disk] { this->pimpl_->add_disk(disk); });
void Host::execute(double flops, double priority) const
{
- this_actor::exec_init(flops)->set_priority(1 / priority)->start()->wait();
+ this_actor::exec_init(flops)->set_priority(1 / priority)->vetoable_start()->wait();
}
} // namespace s4u
std::vector<simgrid::s4u::Host*> hosts = e->get_all_hosts();
sg_host_t* res = xbt_new(sg_host_t, hosts.size());
- memcpy(res, hosts.data(), sizeof(sg_host_t) * hosts.size());
+ std::copy(begin(hosts), end(hosts), res);
return res;
}
{
std::vector<sg_disk_t> list = host->get_disks();
*disk_count = list.size();
- *disks = static_cast<sg_disk_t*>(xbt_malloc(sizeof(sg_disk_t) * (*disk_count)));
- for (size_t i = 0; i < *disk_count; i++)
- (*disks)[i] = list[i];
+ *disks = xbt_new(sg_disk_t, list.size());
+ std::copy(begin(list), end(list), *disks);
}
// =========== user-level functions ===============