Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 1 | #pragma once |
| 2 | |
Patrick Venture | 3d6d318 | 2018-08-31 09:33:09 -0700 | [diff] [blame^] | 3 | #include "sdevent/event.hpp" |
| 4 | #include "sdevent/source.hpp" |
| 5 | |
| 6 | #include <systemd/sd-event.h> |
| 7 | |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 8 | #include <chrono> |
| 9 | #include <functional> |
| 10 | #include <memory> |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 11 | |
| 12 | // TODO: openbmc/openbmc#1720 - add error handling for sd_event API failures |
| 13 | |
| 14 | namespace sdevent |
| 15 | { |
| 16 | namespace event |
| 17 | { |
| 18 | namespace timer |
| 19 | { |
| 20 | |
| 21 | /** @class Timer |
| 22 | * @brief Provides C++ bindings to the sd_event_source* timer functions. |
| 23 | */ |
| 24 | class Timer |
| 25 | { |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 26 | public: |
| 27 | /* Define all of the basic class operations: |
| 28 | * Not allowed: |
| 29 | * - Default constructor to avoid nullptrs. |
| 30 | * - Copy operations due to internal unique_ptr. |
| 31 | * Allowed: |
| 32 | * - Move operations. |
| 33 | * - Destructor. |
| 34 | */ |
| 35 | Timer() = delete; |
| 36 | Timer(const Timer&) = delete; |
| 37 | Timer& operator=(const Timer&) = delete; |
| 38 | Timer(Timer&&) = default; |
| 39 | Timer& operator=(Timer&&) = default; |
| 40 | ~Timer() = default; |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 41 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 42 | using Callback = std::function<void(source::Source&)>; |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 43 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 44 | /** @brief Register a timer callback. |
| 45 | * |
| 46 | * @param[in] event - The event to register on. |
| 47 | * @param[in] expires - The initial timer expiration time. |
| 48 | * @param[in] callback - The callback method. |
| 49 | */ |
| 50 | Timer(sdevent::event::Event& event, |
| 51 | const std::chrono::steady_clock::time_point& expires, |
| 52 | Callback callback) : |
| 53 | src(nullptr), |
| 54 | cb(std::make_unique<Callback>(std::move(callback))) |
| 55 | { |
| 56 | using namespace std::chrono; |
| 57 | auto epoch = expires.time_since_epoch(); |
| 58 | auto time = duration_cast<microseconds>(epoch); |
| 59 | sd_event_source* source = nullptr; |
| 60 | sd_event_add_time(event.get(), &source, CLOCK_MONOTONIC, time.count(), |
| 61 | 0, callCallback, cb.get()); |
| 62 | // **INDENT-OFF** |
| 63 | src = decltype(src){source, std::false_type()}; |
| 64 | // **INDENT-ON** |
| 65 | } |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 66 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 67 | /** @brief Register a disabled timer callback. |
| 68 | * |
| 69 | * @param[in] event - The event to register on. |
| 70 | * @param[in] callback - The callback method. |
| 71 | */ |
| 72 | Timer(sdevent::event::Event& event, Callback callback) : |
| 73 | src(nullptr), cb(std::make_unique<Callback>(std::move(callback))) |
| 74 | { |
| 75 | sd_event_source* source = nullptr; |
| 76 | sd_event_add_time(event.get(), &source, CLOCK_MONOTONIC, ULLONG_MAX, 0, |
| 77 | callCallback, cb.get()); |
| 78 | // **INDENT-OFF** |
| 79 | src = decltype(src){source, std::false_type()}; |
| 80 | // **INDENT-ON** |
| 81 | } |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 82 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 83 | /** @brief Set the timer expiration time. */ |
| 84 | void setTime(const std::chrono::steady_clock::time_point& expires) |
| 85 | { |
| 86 | src.setTime(expires); |
| 87 | } |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 88 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 89 | /** @brief Get the timer expiration time. */ |
| 90 | auto getTime() |
| 91 | { |
| 92 | return src.getTime(); |
| 93 | } |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 94 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 95 | /** @brief Set the timer source enable state. */ |
| 96 | void enable(int enable) |
| 97 | { |
| 98 | src.enable(enable); |
| 99 | } |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 100 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 101 | /** @brief Query timer state. */ |
| 102 | auto enabled() |
| 103 | { |
| 104 | return src.enabled(); |
| 105 | } |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 106 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 107 | private: |
| 108 | source::Source src; |
| 109 | std::unique_ptr<Callback> cb = nullptr; |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 110 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 111 | static int callCallback(sd_event_source* s, uint64_t usec, void* context) |
| 112 | { |
| 113 | source::Source source(s); |
| 114 | auto c = static_cast<Callback*>(context); |
| 115 | (*c)(source); |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 116 | |
Brad Bishop | d1eac88 | 2018-03-29 10:34:05 -0400 | [diff] [blame] | 117 | return 0; |
| 118 | } |
Brad Bishop | 605662d | 2017-05-30 12:39:09 -0400 | [diff] [blame] | 119 | }; |
| 120 | } // namespace timer |
| 121 | } // namespace event |
| 122 | } // namespace sdevent |