-
Notifications
You must be signed in to change notification settings - Fork 8
/
PowerController.cpp
87 lines (75 loc) · 2.22 KB
/
PowerController.cpp
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
#include "PowerController.hpp"
#include <iostream>
#include <thread>
using namespace std::chrono_literals;
namespace
{
const auto kPin = 42;
const auto kTimeBetweenPulses = 1s;
const auto kTimeToWaitForPulse = 10s;
} // namespace
namespace before
{
PowerController::PowerController(PinManager& pinManager,
InterruptManager& interruptManager)
: mPinManager{pinManager}
{
interruptManager.triggerOnChange(kPin, [this](bool pinSet) {
if (pinSet)
{
mPulseReceived = true;
mConditionVariable.notify_one();
}
});
}
bool PowerController::turnOn()
{
mPinManager.setPin(kPin);
std::this_thread::sleep_for(kTimeBetweenPulses);
mPinManager.clearPin(kPin);
std::unique_lock<std::mutex> lk(mRunnerMutex);
std::cout << "Waiting for response" << std::endl;
mConditionVariable.wait_for(
lk, kTimeToWaitForPulse, [this]() { return mPulseReceived.load(); });
return mPulseReceived.load();
}
} // namespace before
namespace after
{
PowerController::PowerController(PinManager& pinManager,
InterruptManager& interruptManager,
AsynchronousTimer& asynchronousTimer,
TimeKeeper& timeKeeper)
: mPinManager{pinManager}
, mAsynchronousTimer{asynchronousTimer}
, mTimeKeeper{timeKeeper}
{
interruptManager.triggerOnChange(kPin, [this](bool pinSet) {
if (pinSet)
{
mPulseReceived = true;
mConditionVariable.notify_one();
}
});
}
bool PowerController::turnOn()
{
mPinManager.setPin(kPin);
mTimeKeeper.sleepFor(kTimeBetweenPulses);
mPinManager.clearPin(kPin);
mAsynchronousTimer.schedule(
[this]() {
mPulseTimedOut = true;
mConditionVariable.notify_one();
},
kTimeToWaitForPulse);
std::unique_lock<std::mutex> lk(mRunnerMutex);
std::cout << "Waiting for response" << std::endl;
mConditionVariable.wait(lk, [this]() {
return mPulseReceived.load() || mPulseTimedOut.load();
});
mAsynchronousTimer.abort();
mPulseTimedOut = false;
return mPulseReceived.load();
}
} // namespace after