#include <boost/range/begin.hpp>
#include <boost/range/end.hpp>
#include <spawn/spawn.hpp>
+#include <boost/asio/io_context.hpp>
#include <boost/asio/use_future.hpp>
#define dout_subsys ceph_subsys_rados
TEST_F(AsioRados, AsyncReadCallback)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
auto success_cb = [&] (boost::system::error_code ec, bufferlist bl) {
EXPECT_FALSE(ec);
TEST_F(AsioRados, AsyncReadFuture)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
std::future<bufferlist> f1 = librados::async_read(service, io, "exist", 256,
0, boost::asio::use_future);
TEST_F(AsioRados, AsyncReadYield)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
auto success_cr = [&] (spawn::yield_context yield) {
boost::system::error_code ec;
TEST_F(AsioRados, AsyncWriteCallback)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
bufferlist bl;
bl.append("hello");
TEST_F(AsioRados, AsyncWriteFuture)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
bufferlist bl;
bl.append("hello");
TEST_F(AsioRados, AsyncWriteYield)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
bufferlist bl;
bl.append("hello");
TEST_F(AsioRados, AsyncReadOperationCallback)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
{
librados::ObjectReadOperation op;
op.read(0, 0, nullptr, nullptr);
TEST_F(AsioRados, AsyncReadOperationFuture)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
std::future<bufferlist> f1;
{
librados::ObjectReadOperation op;
TEST_F(AsioRados, AsyncReadOperationYield)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
auto success_cr = [&] (spawn::yield_context yield) {
librados::ObjectReadOperation op;
TEST_F(AsioRados, AsyncWriteOperationCallback)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
bufferlist bl;
bl.append("hello");
TEST_F(AsioRados, AsyncWriteOperationFuture)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
bufferlist bl;
bl.append("hello");
TEST_F(AsioRados, AsyncWriteOperationYield)
{
- boost::asio::io_service service;
+ boost::asio::io_context service;
bufferlist bl;
bl.append("hello");