blob: 49f25185215d7de0b0ea264b07c29c4be65ce7c4 (
plain)
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
|
#pragma once
#if !defined(__unix) && !defined(__APPLE__)
#error "This file can only be included on unix."
#endif
#include "../../Base.h"
#include "../../Exception.h"
#include "UnixFile.h"
#include <chrono>
#include <thread>
namespace cru::platform::unix {
class UnixTimerFile : public Object2 {
public:
template <class Rep, class Period>
explicit UnixTimerFile(std::chrono::duration<Rep, Period> time) {
auto fds = OpenUniDirectionalPipe();
this->read_fd_ = std::move(fds.read);
this->write_fd_ = std::move(fds.write);
this->thread_ = std::thread([this, time] {
std::this_thread::sleep_for(time);
constexpr auto buffer = "";
auto written = ::write(this->write_fd_, buffer, 1);
if (written != 1) {
throw Exception(
"Failed to write to pipe in UnixTimerFile thread at timeout.");
}
});
this->thread_.detach();
}
int GetReadFd() const;
private:
UnixFileDescriptor write_fd_;
UnixFileDescriptor read_fd_;
std::thread thread_;
};
} // namespace cru::platform::unix
|
