diff options
Diffstat (limited to 'modules/io/examples/echo_server.cpp')
| -rw-r--r-- | modules/io/examples/echo_server.cpp | 15 |
1 files changed, 9 insertions, 6 deletions
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<void> handle_echo_write(saw::io_stream& rmt_clt, message& state, uint64_t tbw){ +saw::error_or<void> 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<void> 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 "<<read_bytes<<" bytes"<<std::endl; + if(read_bytes == 0u){ exit(-1); } @@ -53,7 +56,7 @@ void handle_echo_message(saw::io_stream& rmt_clt, bool& keep_running, message& s if(eov.is_error()){ auto& err = eov.get_error(); if(err.is_critical()){ - std::cerr<<err.get_category()<<std::endl; + std::cerr<<"After triggered write: "<<err.get_category()<<std::endl; exit(err.get_id()); }else { break; @@ -114,13 +117,13 @@ int main(){ saw::own<saw::server> srv = nullptr; saw::own<saw::io_stream> remote_client = nullptr; - message msg_state; + saw::message msg_state; std::cout<<"Starting to resolve address"<<std::endl; /** * Try to resolve address. If resolved */ - network.resolve_address("127.0.0.1", 4322).then([&](auto net_addr){ + network.resolve_address(saw::echo_address, saw::echo_port).then([&](auto net_addr){ std::cout<<"Resolved address"<<std::endl; addr = std::move(net_addr); srv = network.listen(*addr); |