From 875ce0328d1d919d639797972e4cf60c6715503f Mon Sep 17 00:00:00 2001 From: "Claudius \"keldu\" Holeksa" Date: Tue, 21 May 2024 12:13:10 +0200 Subject: Fixing up echo builders and names --- modules/io/examples/echo.hpp | 14 ++- modules/io/examples/echo_client.cpp | 4 +- modules/io/examples/echo_server.cpp | 15 ++- modules/io_codec/examples/SConscript | 4 +- modules/io_codec/examples/echo_client.cpp | 70 ----------- modules/io_codec/examples/echo_server.cpp | 165 ------------------------- modules/io_codec/examples/peer_echo_client.cpp | 28 +++++ modules/io_codec/examples/peer_echo_server.cpp | 2 + 8 files changed, 54 insertions(+), 248 deletions(-) delete mode 100644 modules/io_codec/examples/echo_client.cpp delete mode 100644 modules/io_codec/examples/echo_server.cpp create mode 100644 modules/io_codec/examples/peer_echo_client.cpp diff --git a/modules/io/examples/echo.hpp b/modules/io/examples/echo.hpp index 4eb8084..84416b9 100644 --- a/modules/io/examples/echo.hpp +++ b/modules/io/examples/echo.hpp @@ -1,9 +1,15 @@ #pragma once +#include +#include + +namespace saw { struct message { - std::array data; - uint64_t already_read = 0; - uint64_t already_written = 0; + std::array data; + uint64_t already_read = 0; + uint64_t already_written = 0; }; -constexpr std::string_view message_content = "Hello! This is an echo msg."; +constexpr std::string echo_address = "::1"; +constexpr uint16_t echo_port = 4322; +} diff --git a/modules/io/examples/echo_client.cpp b/modules/io/examples/echo_client.cpp index 53ebe54..4b95158 100644 --- a/modules/io/examples/echo_client.cpp +++ b/modules/io/examples/echo_client.cpp @@ -34,7 +34,7 @@ int main(){ std::array read_data; uint64_t read_bytes = 0; auto& network = aio.io->get_network(); - network.resolve_address("127.0.0.1", 4322).then([&](auto addr){ + network.resolve_address(saw::echo_address, saw::echo_port).then([&](auto addr){ net_addr = std::move(addr); network.connect(*net_addr).then([&](auto rmt_srv){ async_rmt = saw::heap(std::move(rmt_srv)); @@ -43,6 +43,8 @@ int main(){ async_rmt->read(&read_data[0], 3, read_data.size()-1); async_rmt->read_done().then([&](size_t b){ + + std::cout<<"Received bytes:\n"<(read_data[i]); } diff --git a/modules/io/examples/echo_server.cpp b/modules/io/examples/echo_server.cpp index 50863db..aa052a0 100644 --- a/modules/io/examples/echo_server.cpp +++ b/modules/io/examples/echo_server.cpp @@ -4,7 +4,7 @@ #include "echo.hpp" -saw::error_or handle_echo_write(saw::io_stream& rmt_clt, message& state, uint64_t tbw){ +saw::error_or handle_echo_write(saw::io_stream& rmt_clt, saw::message& state, uint64_t tbw){ auto eov = rmt_clt.write(&state.data[state.already_written], tbw); if(eov.is_error()){ return std::move(eov.get_error()); @@ -19,7 +19,7 @@ saw::error_or handle_echo_write(saw::io_stream& rmt_clt, message& state, u return saw::void_t{}; } -void handle_echo_message(saw::io_stream& rmt_clt, bool& keep_running, message& state){ +void handle_echo_message(saw::io_stream& rmt_clt, bool& keep_running, saw::message& state){ rmt_clt.read_ready().then([&](){ for(;;){ uint64_t tbr = state.data.size() < state.already_read ? 0: state.data.size() - state.already_read; @@ -37,7 +37,10 @@ void handle_echo_message(saw::io_stream& rmt_clt, bool& keep_running, message& s break; } } - auto read_bytes = eov.get_value(); + auto& read_bytes = eov.get_value(); + + std::cout<<"Read "< srv = nullptr; saw::own remote_client = nullptr; - message msg_state; + saw::message msg_state; std::cout<<"Starting to resolve address"< -#include - -#include "echo.hpp" - -int main(){ - /** - * Create EventLoop - * Setup EventPort to the outside world - * And setup the io comms to the outside. - */ - auto eo_aio = saw::setup_async_io(); - if(eo_aio.is_error()){ - auto& err = eo_aio.get_error(); - std::cerr< net_addr = nullptr; - saw::own async_rmt = nullptr; - - std::array read_data; - uint64_t read_bytes = 0; - auto& network = aio.io->get_network(); - network.resolve_address(saw::echo_address, saw::echo_port).then([&](auto addr){ - net_addr = std::move(addr); - network.connect(*net_addr).then([&](auto rmt_srv){ - async_rmt = saw::heap(std::move(rmt_srv)); - async_rmt->write("foo", 3); - - async_rmt->read(&read_data[0], 3, read_data.size()-1); - - async_rmt->read_done().then([&](size_t b){ - - std::cout<<"Received bytes:\n"<(read_data[i]); - } - std::cout<on_read_disconnected().then([&](){ - keep_running = false; - }).detach(); - }).detach(); - }).detach(); - - wait_scope.poll(); - while(keep_running){ - wait_scope.wait(); - } - - std::cout<<"Shutting down echo client"< - -#include "echo.hpp" - -saw::error_or handle_echo_write(saw::io_stream& rmt_clt, message& state, uint64_t tbw){ - auto eov = rmt_clt.write(&state.data[state.already_written], tbw); - if(eov.is_error()){ - return std::move(eov.get_error()); - } - - auto val = eov.get_value(); - state.already_written += val; - if(state.already_written > state.already_read){ - exit(-1); - } - - return saw::void_t{}; -} - -void handle_echo_message(saw::io_stream& rmt_clt, bool& keep_running, message& state){ - rmt_clt.read_ready().then([&](){ - for(;;){ - uint64_t tbr = state.data.size() < state.already_read ? 0: state.data.size() - state.already_read; - if(tbr == 0){ - exit(-1); - } - auto eov = rmt_clt.read(&state.data[state.already_read], tbr); - - if(eov.is_error()){ - auto& err = eov.get_error(); - if(err.is_critical()){ - std::cerr< state.data.size()){ - state.already_read = state.data.size(); - } - if(trigger_write){ - auto eov = handle_echo_write(rmt_clt, state, state.already_read - state.already_written); - if(eov.is_error()){ - auto& err = eov.get_error(); - if(err.is_critical()){ - std::cerr<<"After triggered write: "<get_network(); - saw::own addr = nullptr; - saw::own srv = nullptr; - saw::own remote_client = nullptr; - - // message msg_state; - - std::cout<<"Starting to resolve address"<accept().then([&](auto client) -> saw::error_or{ - - if(!remote_client){ - std::cout<<"Accepted client"<(); - }).detach(); - }else{ - keep_running = false; - } - }).detach([&](auto err) { - std::cout<<"Failed to resolve address: "< + +int main(){ + auto eo_aio = saw::setup_async_io(); + if(eo_aio.is_error()){ + auto& err = eo_aio.get_error(); + std::cerr<get_network(); + + return 0; +} diff --git a/modules/io_codec/examples/peer_echo_server.cpp b/modules/io_codec/examples/peer_echo_server.cpp index 586202a..ec8cf8d 100644 --- a/modules/io_codec/examples/peer_echo_server.cpp +++ b/modules/io_codec/examples/peer_echo_server.cpp @@ -2,6 +2,8 @@ #include "../c++/io_peer.hpp" +#include + int main(){ auto eo_aio = saw::setup_async_io(); if(eo_aio.is_error()){ -- cgit v1.2.3