boost/redis
2
0
Fork 0
mirror of https://github.com/boostorg/redis.git synced 2026-02-10 23:52:20 +00:00
Code Issues Projects Releases Wiki Activity

Adds sync version of resp::read.

Browse Source
This commit is contained in:
Marcelo Zimbres
2020-12-12 15:57:46 +01:00
parent 107e56145d
commit d1f4e69122
3 changed files with 77 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
examples/example.cpp
View File

@@ -71,26 +71,35 @@ net::awaitable<void> example2()
}
}
net::awaitable<void> example3()
void example4()
{
tcp_socket socket {co_await this_coro::executor};
io_context ioc {1};
auto ex = ioc.get_executor();
tcp::resolver resv(ex);
auto const r = resv.resolve("127.0.0.1", "6379");
sentinel_op2<tcp_socket>::config cfg
{ {"127.0.0.1", "26379"}
, {"mymaster"}
, {"master"}
};
tcp::socket socket {ex};
net::connect(socket, r);
instance inst;
co_await async_get_instance2(socket, cfg, inst);
resp::pipeline p;
p.ping();
net::write(socket, buffer(p.payload));
resp::buffer buffer;
resp::response res;
boost::system::error_code ec;
resp::read(socket, buffer, res, ec);
resp::print(res.res);
ioc.run();
}
int main()
{
example4();
io_context ioc {1};
co_spawn(ioc, example1(), detached);
co_spawn(ioc, example2(), detached);
co_spawn(ioc, example3(), detached);
ioc.run();
}