-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
23 changed files
with
962 additions
and
185 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,89 @@ | ||
| // | ||
| // Created by Levalup. | ||
| // L.eval: Let programmer get rid of only work jobs. | ||
| // | ||
|
|
||
| #include <iostream> | ||
|
|
||
| #include "uvcxx/pipe.h" | ||
| #include "uvcxx/buf.h" | ||
| #include "uvcxx/timer.h" | ||
| #include "uvcxx/utilities.h" | ||
|
|
||
| int main() { | ||
| // setting | ||
| std::string pipe_name = "a.pipe"; | ||
| auto server_time_ms = 1000; | ||
|
|
||
| (void) std::remove(pipe_name.c_str()); | ||
|
|
||
| uv::loop_t server_loop; | ||
| uv::loop_t client_loop; | ||
|
|
||
| // server | ||
| { | ||
| uv::pipe_t server(server_loop, false); | ||
| server.bind(pipe_name); | ||
|
|
||
| server.listen(128).call([=]() mutable { | ||
| auto conn = server.accept(false); | ||
|
|
||
| uv::buf_t server_buf; | ||
| conn.alloc().call([=](size_t size, uv_buf_t *buf) mutable { | ||
| server_buf.resize(size); | ||
| *buf = server_buf; | ||
| }); | ||
| conn.read_start().call([=](ssize_t nread, const uv_buf_t *buf) mutable { | ||
| std::cout << "server read: " << std::string(buf->base, nread) << std::endl; | ||
| }).except<uvcxx::E_EAGAIN>([]() { | ||
| }).except<uvcxx::E_EOF>([=]() mutable { | ||
| conn.close(nullptr); | ||
| }).except([=]() mutable { | ||
| conn.close(nullptr); | ||
| }); | ||
| }).except([=](const std::exception &e) { | ||
| std::cout << "[ERROR] listen named pipe " << pipe_name << " failed. " << e.what() << std::endl; | ||
| throw uvcxx::close_handle(); | ||
| }).finally([=]() { | ||
| (void) std::remove(pipe_name.c_str()); | ||
| }); | ||
|
|
||
| std::cout << "[INFO] stop server after " << server_time_ms << "ms" << std::endl; | ||
| uv::timer_t(server_loop).start(server_time_ms, 1).call([=]() mutable { | ||
| server.close(nullptr); | ||
| throw uvcxx::close_handle(); // close timer | ||
| }); | ||
| } | ||
|
|
||
| // client | ||
| for (int i = 0; i < 5; ++i) { | ||
| auto msg = uvcxx::catstr("hello~", i); | ||
|
|
||
| uv::pipe_t client(client_loop, false); | ||
| client.connect(pipe_name).then([=]() mutable { | ||
| client.write(msg).then([=]() { | ||
| std::cout << "client write: " << msg << std::endl; | ||
| }).finally([=]() mutable { | ||
| client.close(nullptr); | ||
| }); | ||
| }).except([=]() mutable { | ||
| std::cout << "[ERROR] can not connect to " << pipe_name << std::endl; | ||
| client.close(nullptr); | ||
| }); | ||
| } | ||
|
|
||
| auto server_run = std::async(std::launch::async, [&]() { | ||
| server_loop.run(); | ||
| std::cout << "[INFO] server exit" << std::endl; | ||
| }); | ||
|
|
||
| auto client_run = std::async(std::launch::async, [&]() { | ||
| client_loop.run(); | ||
| std::cout << "[INFO] client exit" << std::endl; | ||
| }); | ||
|
|
||
| server_run.wait(); | ||
| client_run.wait(); | ||
|
|
||
| return 0; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,115 @@ | ||
| // | ||
| // Created by Levalup. | ||
| // L.eval: Let programmer get rid of only work jobs. | ||
| // | ||
|
|
||
| #include <iostream> | ||
|
|
||
| #include "uvcxx/cxx/sockaddr.h" | ||
| #include "uvcxx/tcp.h" | ||
| #include "uvcxx/buf.h" | ||
| #include "uvcxx/timer.h" | ||
| #include "uvcxx/utilities.h" | ||
|
|
||
| uvcxx::any_address_t getsockname(const uv::tcp_t &tcp) { | ||
| uvcxx::any_address_t name; | ||
| auto len = name.len(); | ||
| (void) tcp.getsockname(name, &len); | ||
| return name; | ||
| } | ||
|
|
||
| uvcxx::any_address_t getpeername(const uv::tcp_t &tcp) { | ||
| uvcxx::any_address_t name; | ||
| auto len = name.len(); | ||
| (void) tcp.getpeername(name, &len); | ||
| return name; | ||
| } | ||
|
|
||
| int main() { | ||
| // setting | ||
| std::string localhost = "127.0.0.1"; | ||
| int port = 0; | ||
| auto server_time_ms = 1000; | ||
|
|
||
| uv::loop_t server_loop; | ||
| uv::loop_t client_loop; | ||
|
|
||
| // server | ||
| { | ||
| // make address support IPv4 and IPv6 | ||
| auto addr = uvcxx::make_address("0.0.0.0", port); | ||
| // if work IPv4 only, simplify code as following | ||
| // uvcxx::IPv4 addr("0.0.0.0", port); // or uvcxx::IPv4(uvcxx::address_t::ANY, port); | ||
|
|
||
| uv::tcp_t server(server_loop); | ||
| server.bind(addr, 0); | ||
|
|
||
| auto server_sock = getsockname(server); | ||
| port = server_sock.port(); | ||
|
|
||
| std::cout << "[INFO] server start listen: " << server_sock << std::endl; | ||
|
|
||
| server.listen(128).call([=]() mutable { | ||
| auto conn = server.accept(false); | ||
|
|
||
| std::cout << "[INFO] received [" << getsockname(conn) << " <- " << getpeername(conn) << "]" << std::endl; | ||
|
|
||
| uv::buf_t server_buf; | ||
| conn.alloc().call([=](size_t size, uv_buf_t *buf) mutable { | ||
| server_buf.resize(size); | ||
| *buf = server_buf; | ||
| }); | ||
| conn.read_start().call([=](ssize_t nread, const uv_buf_t *buf) mutable { | ||
| std::cout << "server read: " << std::string(buf->base, nread) << std::endl; | ||
| }).except<uvcxx::E_EAGAIN>([]() { | ||
| }).except<uvcxx::E_EOF>([=]() mutable { | ||
| conn.close(nullptr); | ||
| }).except([=]() mutable { | ||
| conn.close(nullptr); | ||
| }); | ||
| }).except([=](const std::exception &e) { | ||
| std::cout << "[ERROR] listen " << addr << " failed. " << e.what() << std::endl; | ||
| throw uvcxx::close_handle(); | ||
| }); | ||
|
|
||
| std::cout << "[INFO] stop server after " << server_time_ms << "ms" << std::endl; | ||
| uv::timer_t(server_loop).start(server_time_ms, 1).call([=]() mutable { | ||
| server.close(nullptr); | ||
| throw uvcxx::close_handle(); // close timer | ||
| }); | ||
| } | ||
|
|
||
| // client | ||
| for (int i = 0; i < 5; ++i) { | ||
| auto addr = uvcxx::make_address(localhost, port); | ||
|
|
||
| auto msg = uvcxx::catstr("hello~", i); | ||
|
|
||
| uv::tcp_t client(client_loop, false); | ||
| client.connect(addr).then([=]() mutable { | ||
| client.write(msg).then([=]() { | ||
| std::cout << "client write: " << msg << std::endl; | ||
| }).finally([=]() mutable { | ||
| client.close(nullptr); | ||
| }); | ||
| }).except([=]() mutable { | ||
| std::cout << "[ERROR] can not connect to " << addr << std::endl; | ||
| client.close(nullptr); | ||
| }); | ||
| } | ||
|
|
||
| auto server_run = std::async(std::launch::async, [&]() { | ||
| server_loop.run(); | ||
| std::cout << "[INFO] server exit" << std::endl; | ||
| }); | ||
|
|
||
| auto client_run = std::async(std::launch::async, [&]() { | ||
| client_loop.run(); | ||
| std::cout << "[INFO] client exit" << std::endl; | ||
| }); | ||
|
|
||
| server_run.wait(); | ||
| client_run.wait(); | ||
|
|
||
| return 0; | ||
| } |
Oops, something went wrong.