From c0424e7a55250705579ee64c269892677fa86adf Mon Sep 17 00:00:00 2001
From: "Claudius \"keldu\" Holeksa" <mail@keldu.de>
Date: Fri, 15 Mar 2024 14:41:47 +0100
Subject: async,io: Fixed immediate issues in async and built a basic io
 echo_server

---
 modules/async/c++/async.tmpl.hpp | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

(limited to 'modules/async/c++/async.tmpl.hpp')

diff --git a/modules/async/c++/async.tmpl.hpp b/modules/async/c++/async.tmpl.hpp
index 98573b5..ec8d3fc 100644
--- a/modules/async/c++/async.tmpl.hpp
+++ b/modules/async/c++/async.tmpl.hpp
@@ -285,7 +285,7 @@ template <typename T> size_t immediate_conveyor_node<T>::space() const {
 }
 
 template <typename T> size_t immediate_conveyor_node<T>::queued() const {
-	return retrieved_ > 1 ? 0 : 1;
+	return retrieved_ > 0 ? 0 : 1;
 }
 
 template <typename T> void immediate_conveyor_node<T>::child_has_fired() {
@@ -301,15 +301,10 @@ template <typename T> void immediate_conveyor_node<T>::parent_has_fired() {
 		arm_next();
 	}
 }
-}
-#include <iostream>
-namespace saw {
+
 template <typename T> void immediate_conveyor_node<T>::fire() {
-	std::cout<<"Immediate fire"<<std::endl;
 	if (parent_) {
-		std::cout<<"Immediate parent:  "<<queued()<<" "<<parent_->space()<<std::endl;
 		parent_->child_has_fired();
-		std::cout<<"Immediate parent2: "<<queued()<<" "<<parent_->space()<<std::endl;
 		if (queued() > 0 && parent_->space() > 0) {
 			arm_last();
 		}
-- 
cgit v1.2.3