Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Implement I/O as asynchronous activities
[simgrid.git] / include / simgrid / s4u / Io.hpp
1 /* Copyright (c) 2017-2018. 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 #ifndef SIMGRID_S4U_IO_HPP
7 #define SIMGRID_S4U_IO_HPP
8
9 #include <simgrid/forward.h>
10 #include <simgrid/s4u/Activity.hpp>
11
12 #include <atomic>
13
14 namespace simgrid {
15 namespace s4u {
16
17 class XBT_PUBLIC Io : public Activity {
18   Io() : Activity() {}
19 public:
20   friend XBT_PUBLIC void intrusive_ptr_release(simgrid::s4u::Io* i);
21   friend XBT_PUBLIC void intrusive_ptr_add_ref(simgrid::s4u::Io* i);
22   friend Storage; // Factory of IOs
23
24   ~Io() = default;
25
26   Activity* start() override;
27   Activity* wait() override;
28   Activity* wait(double timeout) override;
29   Activity* cancel() override;
30
31   double get_remaining() override;
32
33 private:
34   sg_size_t size_       = 0;
35   sg_storage_t storage_ = nullptr;
36   std::atomic_int_fast32_t refcount_{0};
37 }; // class
38 }
39 }; // Namespace simgrid::s4u
40
41 #endif /* SIMGRID_S4U_IO_HPP */