diff options
author | Yuqian Yang <crupest@crupest.life> | 2025-09-03 12:30:46 +0800 |
---|---|---|
committer | Yuqian Yang <crupest@crupest.life> | 2025-09-03 12:30:46 +0800 |
commit | 5e59a8e38c9f8992e6ffd9dbbde11e1f873780e1 (patch) | |
tree | da6a32441317706dee212db2ec9e319cc95563c8 /include/cru/base/platform/unix/Timer.h | |
parent | f6c36037edc3f1293f96e84691136c657ca488dc (diff) | |
download | cru-5e59a8e38c9f8992e6ffd9dbbde11e1f873780e1.tar.gz cru-5e59a8e38c9f8992e6ffd9dbbde11e1f873780e1.tar.bz2 cru-5e59a8e38c9f8992e6ffd9dbbde11e1f873780e1.zip |
Add unix timer file. Not tested.
Diffstat (limited to 'include/cru/base/platform/unix/Timer.h')
-rw-r--r-- | include/cru/base/platform/unix/Timer.h | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/include/cru/base/platform/unix/Timer.h b/include/cru/base/platform/unix/Timer.h new file mode 100644 index 00000000..e2cbff7d --- /dev/null +++ b/include/cru/base/platform/unix/Timer.h @@ -0,0 +1,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 |