X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/8d9b5170925fd2a7873c619c5d6cdff8616f9bfc..d800adcfdddbc6283a830288babe78a59a3ae079:/src/s4u/s4u_Disk.cpp diff --git a/src/s4u/s4u_Disk.cpp b/src/s4u/s4u_Disk.cpp index ab870db20b..29adfd31d4 100644 --- a/src/s4u/s4u_Disk.cpp +++ b/src/s4u/s4u_Disk.cpp @@ -20,10 +20,14 @@ xbt::signal Disk::on_creation; xbt::signal Disk::on_destruction; xbt::signal Disk::on_state_change; -Disk* Disk::set_name(const std::string& name) +const std::string& Disk::get_name() const { - name_ = name; - return this; + return pimpl_->get_name(); +} + +const char* Disk::get_cname() const +{ + return pimpl_->get_cname(); } Disk* Disk::set_read_bandwidth(double read_bw) @@ -69,9 +73,37 @@ const char* Disk::get_property(const std::string& key) const return pimpl_->get_property(key); } -void Disk::set_property(const std::string& key, const std::string& value) +Disk* Disk::set_property(const std::string& key, const std::string& value) { kernel::actor::simcall([this, &key, &value] { this->pimpl_->set_property(key, value); }); + return this; +} + +Disk* Disk::set_properties(const std::unordered_map& properties) +{ + kernel::actor::simcall([this, properties] { this->pimpl_->set_properties(properties); }); + return this; +} + +Disk* Disk::set_state_profile(kernel::profile::Profile* profile) +{ + xbt_assert(not pimpl_->is_sealed(), "Cannot set a state profile once the Disk is sealed"); + kernel::actor::simcall([this, profile]() { this->pimpl_->set_state_profile(profile); }); + return this; +} + +Disk* Disk::set_read_bandwidth_profile(kernel::profile::Profile* profile) +{ + xbt_assert(not pimpl_->is_sealed(), "Cannot set a bandwidth profile once the Disk is sealed"); + kernel::actor::simcall([this, profile]() { this->pimpl_->set_read_bandwidth_profile(profile); }); + return this; +} + +Disk* Disk::set_write_bandwidth_profile(kernel::profile::Profile* profile) +{ + xbt_assert(not pimpl_->is_sealed(), "Cannot set a bandwidth profile once the Disk is sealed"); + kernel::actor::simcall([this, profile]() { this->pimpl_->set_write_bandwidth_profile(profile); }); + return this; } IoPtr Disk::io_init(sg_size_t size, Io::OpType type) const @@ -99,10 +131,20 @@ sg_size_t Disk::write(sg_size_t size) const return IoPtr(io_init(size, Io::OpType::WRITE))->vetoable_start()->wait()->get_performed_ioops(); } +Disk* Disk::set_sharing_policy(Disk::Operation op, Disk::SharingPolicy policy, const NonLinearResourceCb& cb) +{ + kernel::actor::simcall([this, op, policy, &cb] { pimpl_->set_sharing_policy(op, policy, cb); }); + return this; +} + +Disk::SharingPolicy Disk::get_sharing_policy(Operation op) const +{ + return this->pimpl_->get_sharing_policy(op); +} + Disk* Disk::seal() { kernel::actor::simcall([this]{ pimpl_->seal(); }); - get_host()->add_disk(this); Disk::on_creation(*this); return this; }