1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
#include <chrono>
#include <systemd/sd-event.h>
#include <phosphor-logging/log.hpp>
#include "timer.hpp"
namespace phosphor
{
namespace watchdog
{
// Initializes the timer object
void Timer::initialize()
{
// This can not be called more than once.
if (eventSource.get())
{
// TODO: Need to throw elog exception stating its already added.
throw std::runtime_error("Timer already initialized");
}
// Add infinite expiration time
decltype(eventSource.get()) sourcePtr = nullptr;
auto r = sd_event_add_time(event.get(),
&sourcePtr,
CLOCK_MONOTONIC, // Time base
UINT64_MAX, // Expire time - way long time
0, // Use default event accuracy
timeoutHandler, // Callback handler on timeout
this); // User data
eventSource.reset(sourcePtr);
if (r < 0)
{
// TODO: throw elog exception
throw std::runtime_error("Timer initialization failed");
}
// Disable the timer for now
setEnabled<std::false_type>();
}
// callback handler on timeout
int Timer::timeoutHandler(sd_event_source* eventSource,
uint64_t usec, void* userData)
{
using namespace phosphor::logging;
log<level::INFO>("Timer Expired");
auto timer = static_cast<Timer*>(userData);
timer->expire = true;
// Call an optional callback function
if(timer->userCallBack)
{
timer->userCallBack();
}
return 0;
}
// Gets the time from steady_clock
std::chrono::microseconds Timer::getCurrentTime()
{
using namespace std::chrono;
auto usec = steady_clock::now().time_since_epoch();
return duration_cast<microseconds>(usec);
}
// Sets the expiration time and arms the timer
void Timer::start(std::chrono::microseconds usec)
{
// Get the current MONOTONIC time and add the delta
auto expireTime = getCurrentTime() + usec;
// Set the time
auto r = sd_event_source_set_time(eventSource.get(),
expireTime.count());
if (r < 0)
{
// TODO throw elog exception
throw std::runtime_error("Error setting the expiration time");
}
}
// Returns current timer enablement type
int Timer::getEnabled() const
{
int enabled{};
auto r = sd_event_source_get_enabled(eventSource.get(), &enabled);
if (r < 0)
{
// TODO: Need to throw elog exception
throw std::runtime_error("Error geting current time enablement state");
}
return enabled;
}
// Enables / disables the timer
void Timer::setEnabled(int type)
{
auto r = sd_event_source_set_enabled(eventSource.get(), type);
if (r < 0)
{
// TODO: Need to throw elog exception
throw std::runtime_error("Error altering enabled property");
}
}
// Returns time remaining before expiration
std::chrono::microseconds Timer::getRemaining() const
{
uint64_t next = 0;
auto r = sd_event_source_get_time(eventSource.get(), &next);
if (r < 0)
{
// TODO: Need to throw elog exception
throw std::runtime_error("Error altering enabled property");
}
return std::chrono::microseconds(next);
}
} // namespace watchdog
} // namespace phosphor
|
