blob: b09a51a800a4243311b91b2e1f93aba9f0405dd3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
#include "echo.hpp"
#include "../c++/io_peer.hpp"
#include <iostream>
#include <forstio/codec/transport.hpp>
int main(){
using namespace saw;
auto eo_aio = saw::setup_async_io();
if(eo_aio.is_error()){
auto& err = eo_aio.get_error();
std::cerr<<err.get_message()<<std::endl;
return err.get_id();
}
auto& aio = eo_aio.get_value();
/**
* Make the event loop the current event loop on this thread
*/
saw::wait_scope wait_scope{aio.event_loop};
bool keep_running = true;
aio.event_port.on_signal(saw::Signal::Terminate).then([&keep_running](){
keep_running = false;
}).detach();
auto& network = aio.io->get_network();
auto eo_addr = network.resolve_address(saw::echo_address, saw::echo_port).take();
if(eo_addr.is_error()){
return -1;
}
auto& addr = eo_addr.get_value();
network.connect(*addr).then([](saw::own<saw::io_stream> client){
auto echo_stream = saw::heap<saw::async_io_stream>(std::move(client));
auto echo_peer_stream_p = saw::new_streaming_io_peer<sch::Echo, sch::Echo, transport::FixedLength<8u>, encode::KelSimple, ring_buffer>(std::move(echo_stream));
echo_peer_stream_p.first->on_read_disconnected().attach(std::move(echo_peer_stream_p.first)).detach();
}).detach();
return 0;
}
|
