From d73ad08e87b9c7cc37f42cf280bc50c8e447b667 Mon Sep 17 00:00:00 2001
From: q66 <daniel@octaforge.org>
Date: Thu, 23 Mar 2017 10:41:13 +0100
Subject: [PATCH] make channels outside of scheduler

---
 ostd/channel.hh     |  2 +-
 ostd/concurrency.hh | 20 ++++++++++----------
 2 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/ostd/channel.hh b/ostd/channel.hh
index 1e1108b..e196b88 100644
--- a/ostd/channel.hh
+++ b/ostd/channel.hh
@@ -73,7 +73,7 @@ private:
         }
 
         template<typename F>
-        impl(F &func): p_lock(), p_cond(func) {}
+        impl(F &func): p_lock(), p_cond(func()) {}
 
         template<typename U>
         void put(U &&val) {
diff --git a/ostd/concurrency.hh b/ostd/concurrency.hh
index 5319eba..02ebb33 100644
--- a/ostd/concurrency.hh
+++ b/ostd/concurrency.hh
@@ -15,6 +15,7 @@
 #include "ostd/platform.hh"
 #include "ostd/coroutine.hh"
 #include "ostd/channel.hh"
+#include "ostd/generic_condvar.hh"
 
 namespace ostd {
 
@@ -46,9 +47,8 @@ struct thread_scheduler {
         std::this_thread::yield();
     }
 
-    template<typename T>
-    channel<T> make_channel() {
-        return channel<T>{};
+    generic_condvar make_condition() {
+        return generic_condvar{};
     }
 
 private:
@@ -221,9 +221,8 @@ public:
         ctx->yield();
     }
 
-    template<typename T>
-    channel<T> make_channel() {
-        return channel<T>{[this]() {
+    generic_condvar make_condition() {
+        return generic_condvar{[this]() {
             return coro_cond{*this};
         }};
     }
@@ -399,9 +398,8 @@ public:
         task::current()->yield();
     }
 
-    template<typename T>
-    channel<T> make_channel() {
-        return channel<T>{[this]() {
+    generic_condvar make_condition() {
+        return generic_condvar{[this]() {
             return task_cond{*this};
         }};
     }
@@ -543,7 +541,9 @@ inline void yield(S &sched) {
 
 template<typename T, typename S>
 inline channel<T> make_channel(S &sched) {
-    return sched.template make_channel<T>();
+    return channel<T>{[&sched]() {
+        return sched.make_condition();
+    }};
 }
 
 } /* namespace ostd */