summaryrefslogtreecommitdiff
path: root/modules/async
diff options
context:
space:
mode:
authorClaudius 'keldu' Holeksa <mail@keldu.de>2024-09-01 13:24:09 +0200
committerClaudius 'keldu' Holeksa <mail@keldu.de>2024-09-01 13:24:09 +0200
commit55f9635f8818614d1c0e5f2dbfc6eb3de18a7107 (patch)
treeb716810726e9511fc07699e7072092eced2ecd7c /modules/async
parent636abd840ef43ff5bca30f963d6d1cf28f016cf7 (diff)
Playing around with dependencies.
I need to think about the potential async codec behaviours
Diffstat (limited to 'modules/async')
-rw-r--r--modules/async/.nix/derivation.nix3
-rw-r--r--modules/async/c++/async.cpp16
-rw-r--r--modules/async/c++/async.hpp13
3 files changed, 16 insertions, 16 deletions
diff --git a/modules/async/.nix/derivation.nix b/modules/async/.nix/derivation.nix
index 3992ea1..96bf173 100644
--- a/modules/async/.nix/derivation.nix
+++ b/modules/async/.nix/derivation.nix
@@ -21,7 +21,8 @@ in stdenv.mkDerivation {
];
buildInputs = [
- forstio.core
+ forstio.core
+ forstio.codec
];
doCheck = true;
diff --git a/modules/async/c++/async.cpp b/modules/async/c++/async.cpp
index 742d43c..ea30cda 100644
--- a/modules/async/c++/async.cpp
+++ b/modules/async/c++/async.cpp
@@ -259,17 +259,17 @@ bool event_loop::turn() {
return true;
}
-bool event_loop::wait(const std::chrono::steady_clock::duration &duration) {
+bool event_loop::wait_for(uint64_t duration) {
if (event_port_) {
- event_port_->wait(duration);
+ event_port_->wait_for(duration);
}
return turn_loop();
}
-bool event_loop::wait(const std::chrono::steady_clock::time_point &time_point) {
+bool event_loop::wait_until(uint64_t time_point) {
if (event_port_) {
- event_port_->wait(time_point);
+ event_port_->wait_until(time_point);
}
return turn_loop();
@@ -306,12 +306,12 @@ wait_scope::~wait_scope() { loop_.leave_scope(); }
void wait_scope::wait() { loop_.wait(); }
-void wait_scope::wait(const std::chrono::steady_clock::duration &duration) {
- loop_.wait(duration);
+void wait_scope::wait_for(uint64_t duration) {
+ loop_.wait_for(duration);
}
-void wait_scope::wait(const std::chrono::steady_clock::time_point &time_point) {
- loop_.wait(time_point);
+void wait_scope::wait_until(uint64_t time_point) {
+ loop_.wait_until(time_point);
}
void wait_scope::poll() { loop_.poll(); }
diff --git a/modules/async/c++/async.hpp b/modules/async/c++/async.hpp
index bb56952..06fa4e3 100644
--- a/modules/async/c++/async.hpp
+++ b/modules/async/c++/async.hpp
@@ -3,7 +3,6 @@
#include <forstio/common.hpp>
#include <forstio/error.hpp>
-#include <chrono>
#include <functional>
#include <limits>
#include <list>
@@ -361,8 +360,8 @@ public:
virtual void poll() = 0;
virtual void wait() = 0;
- virtual void wait(const std::chrono::steady_clock::duration &) = 0;
- virtual void wait(const std::chrono::steady_clock::time_point &) = 0;
+ virtual void wait_for(uint64_t millisec) = 0;
+ virtual void wait_until(uint64_t millisec) = 0;
virtual void wake() = 0;
};
@@ -451,8 +450,8 @@ public:
event_loop &operator=(event_loop &&) = default;
bool wait();
- bool wait(const std::chrono::steady_clock::duration &);
- bool wait(const std::chrono::steady_clock::time_point &);
+ bool wait_for(uint64_t millisec);
+ bool wait_until(uint64_t millisec);
bool poll();
event_port *get_event_port();
@@ -473,8 +472,8 @@ public:
~wait_scope();
void wait();
- void wait(const std::chrono::steady_clock::duration &);
- void wait(const std::chrono::steady_clock::time_point &);
+ void wait_for(uint64_t millisec);
+ void wait_until(uint64_t millisec);
void poll();
};