X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/59251ff676c562b79573e3561166e4351e4ad11e..1f6a008d060e1ffc86348cfa7a9750688d871314:/src/s4u/s4u_Disk.cpp diff --git a/src/s4u/s4u_Disk.cpp b/src/s4u/s4u_Disk.cpp index c64af72c22..b95164d7c1 100644 --- a/src/s4u/s4u_Disk.cpp +++ b/src/s4u/s4u_Disk.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2019-2021. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2019-2022. 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. */ @@ -126,6 +126,15 @@ sg_size_t Disk::read(sg_size_t size) const return IoPtr(io_init(size, Io::OpType::READ))->vetoable_start()->wait()->get_performed_ioops(); } +sg_size_t Disk::read(sg_size_t size, double priority) const +{ + return IoPtr(io_init(size, Io::OpType::READ)) + ->set_priority(priority) + ->vetoable_start() + ->wait() + ->get_performed_ioops(); +} + IoPtr Disk::write_async(sg_size_t size) const { return IoPtr(io_init(size, Io::OpType::WRITE)->vetoable_start()); @@ -136,6 +145,15 @@ sg_size_t Disk::write(sg_size_t size) const return IoPtr(io_init(size, Io::OpType::WRITE))->vetoable_start()->wait()->get_performed_ioops(); } +sg_size_t Disk::write(sg_size_t size, double priority) const +{ + return IoPtr(io_init(size, Io::OpType::WRITE)) + ->set_priority(priority) + ->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); }); @@ -195,7 +213,7 @@ sg_size_t sg_disk_write(const_sg_disk_t disk, sg_size_t size) void* sg_disk_get_data(const_sg_disk_t disk) { - return disk->get_data(); + return disk->get_data(); } void sg_disk_set_data(sg_disk_t disk, void* data)