From 97ec4b9edfa88302878b523baf09674503d19fab Mon Sep 17 00:00:00 2001
From: "Claudius \"keldu\" Holeksa" <mail@keldu.de>
Date: Wed, 22 May 2024 17:22:18 +0200
Subject: Progress in fixing remote-sycl and ammended minor parts in
 echo_client

---
 modules/io/examples/echo_client.cpp | 21 +++++++++++++++------
 1 file changed, 15 insertions(+), 6 deletions(-)

(limited to 'modules/io')

diff --git a/modules/io/examples/echo_client.cpp b/modules/io/examples/echo_client.cpp
index 4b95158..e827ce0 100644
--- a/modules/io/examples/echo_client.cpp
+++ b/modules/io/examples/echo_client.cpp
@@ -5,6 +5,8 @@
 
 #include "echo.hpp"
 
+std::string message_content = "Hey there! Sending this message";
+
 int main(){
 	/**
 	 * Create EventLoop
@@ -38,26 +40,33 @@ int main(){
 		net_addr = std::move(addr);
 		network.connect(*net_addr).then([&](auto rmt_srv){
 			async_rmt = saw::heap<saw::async_io_stream>(std::move(rmt_srv));
-			async_rmt->write("foo", 3);
+			async_rmt->write(&message_content[0], message_content.size());
 
-			async_rmt->read(&read_data[0], 3, read_data.size()-1);
+			async_rmt->read(&read_data[0], message_content.size(), read_data.size()-1);
 
 			async_rmt->read_done().then([&](size_t b){
 	
-					std::cout<<"Received bytes:\n"<<std::endl;
+					std::cout<<"Received bytes:\n";
 					for(uint64_t i = 0; i < b; ++i){
 						std::cout<<static_cast<char>(read_data[i]);
 					}
-					std::cout<<std::endl;
+					std::cout<<'\n'<<std::endl;
 
 					keep_running = false;
 			}).detach();
 
 			async_rmt->on_read_disconnected().then([&](){
 				keep_running = false;
+				std::cout<<"Disconnected"<<std::endl;
 			}).detach();
-		}).detach();
-	}).detach();
+		}).detach([](auto err){
+			std::cerr<<"Couldn't connect to address"<<std::endl;
+			return err;
+		});
+	}).detach([](auto err){
+		std::cerr<<"Couldn't resolve address"<<std::endl;
+		return err;
+	});
 
 	wait_scope.poll();
 	while(keep_running){
-- 
cgit v1.2.3