Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
f2877f2684120b871d96a20cd2621a08e917026e
[simgrid.git] / src / kernel / resource / DiskImpl.cpp
1 /* Copyright (c) 2019. The SimGrid Team. All rights reserved.          */
2
3 /* This program is free software; you can redistribute it and/or modify it
4  * under the terms of the license (GNU LGPL) which comes with this package. */
5
6 #include "DiskImpl.hpp"
7
8 #include "simgrid/s4u/Engine.hpp"
9 #include "src/kernel/EngineImpl.hpp"
10 #include "src/kernel/lmm/maxmin.hpp"
11
12 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(disk_kernel, surf, "Logging specific to the disk kernel resource");
13
14 simgrid::kernel::resource::DiskModel* surf_disk_model = nullptr;
15
16 namespace simgrid {
17 namespace kernel {
18 namespace resource {
19
20 /*********
21  * Model *
22  *********/
23
24 DiskModel::DiskModel() : Model(Model::UpdateAlgo::FULL)
25 {
26   set_maxmin_system(new simgrid::kernel::lmm::System(true /* selective update */));
27 }
28
29 DiskModel::~DiskModel()
30 {
31   surf_disk_model = nullptr;
32 }
33
34 /************
35  * Resource *
36  ************/
37
38 DiskImpl::DiskImpl(kernel::resource::Model* model, const std::string& name, kernel::lmm::System* maxminSystem,
39                    double read_bw, double write_bw)
40     : Resource(model, name, maxminSystem->constraint_new(this, std::max(read_bw, write_bw))), piface_(name, this)
41 {
42   DiskImpl::turn_on();
43   XBT_DEBUG("Create resource with read_bw '%f' write_bw '%f'", read_bw, write_bw);
44   constraint_read_  = maxminSystem->constraint_new(this, read_bw);
45   constraint_write_ = maxminSystem->constraint_new(this, write_bw);
46 }
47
48 DiskImpl::~DiskImpl()
49 {
50   xbt_assert(currently_destroying_, "Don't delete Disks directly. Call destroy() instead.");
51 }
52
53 /** @brief Fire the required callbacks and destroy the object
54  *
55  * Don't delete directly a Disk, call d->destroy() instead.
56  */
57 void DiskImpl::destroy()
58 {
59   if (not currently_destroying_) {
60     currently_destroying_ = true;
61     s4u::Disk::on_destruction(this->piface_);
62     delete this;
63   }
64 }
65
66 bool DiskImpl::is_used()
67 {
68   THROW_UNIMPLEMENTED;
69 }
70
71 void DiskImpl::apply_event(kernel::profile::Event* /*event*/, double /*value*/)
72 {
73   THROW_UNIMPLEMENTED;
74 }
75
76 void DiskImpl::turn_on()
77 {
78   if (not is_on()) {
79     Resource::turn_on();
80     s4u::Disk::on_state_change(this->piface_);
81   }
82 }
83 void DiskImpl::turn_off()
84 {
85   if (is_on()) {
86     Resource::turn_off();
87     s4u::Disk::on_state_change(this->piface_);
88   }
89 }
90
91 xbt::signal<void(DiskAction const&, kernel::resource::Action::State, kernel::resource::Action::State)>
92     DiskAction::on_state_change;
93
94 /**********
95  * Action *
96  **********/
97 void DiskAction::set_state(Action::State state)
98 {
99   Action::State old = get_state();
100   Action::set_state(state);
101   on_state_change(*this, old, state);
102 }
103 } // namespace resource
104 } // namespace kernel
105 } // namespace simgrid