X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/47b02c768e720ce83e3b0395ed1e3433a7de162d..2d30a417c2362b797b83c98f038a47a655a07180:/src/s4u/s4u_Disk.cpp diff --git a/src/s4u/s4u_Disk.cpp b/src/s4u/s4u_Disk.cpp index 3c7334d4a1..07c2012222 100644 --- a/src/s4u/s4u_Disk.cpp +++ b/src/s4u/s4u_Disk.cpp @@ -74,27 +74,27 @@ void Disk::set_property(const std::string& key, const std::string& value) kernel::actor::simcall([this, &key, &value] { this->pimpl_->set_property(key, value); }); } -IoPtr Disk::io_init(sg_size_t size, Io::OpType type) +IoPtr Disk::io_init(sg_size_t size, Io::OpType type) const { return Io::init()->set_disk(this)->set_size(size)->set_op_type(type); } -IoPtr Disk::read_async(sg_size_t size) +IoPtr Disk::read_async(sg_size_t size) const { return IoPtr(io_init(size, Io::OpType::READ))->vetoable_start(); } -sg_size_t Disk::read(sg_size_t size) +sg_size_t Disk::read(sg_size_t size) const { return IoPtr(io_init(size, Io::OpType::READ))->vetoable_start()->wait()->get_performed_ioops(); } -IoPtr Disk::write_async(sg_size_t size) +IoPtr Disk::write_async(sg_size_t size) const { return IoPtr(io_init(size, Io::OpType::WRITE)->vetoable_start()); } -sg_size_t Disk::write(sg_size_t size) +sg_size_t Disk::write(sg_size_t size) const { return IoPtr(io_init(size, Io::OpType::WRITE))->vetoable_start()->wait()->get_performed_ioops(); } @@ -130,11 +130,11 @@ double sg_disk_write_bandwidth(const_sg_disk_t disk) return disk->get_write_bandwidth(); } -sg_size_t sg_disk_read(sg_disk_t disk, sg_size_t size) +sg_size_t sg_disk_read(const_sg_disk_t disk, sg_size_t size) { return disk->read(size); } -sg_size_t sg_disk_write(sg_disk_t disk, sg_size_t size) +sg_size_t sg_disk_write(const_sg_disk_t disk, sg_size_t size) { return disk->write(size); }