+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+
#include "MonClient.h"
#include <random>
found->reset();
auto ret = seastar::do_with(
std::move(pending_conns),
- [this](auto &pending_conns) {
+ [](auto &pending_conns) {
return seastar::parallel_for_each(
pending_conns,
- [this] (auto &conn) {
+ [] (auto &conn) {
if (!conn) {
return seastar::now();
} else {
return seastar::now();
} else {
p_blocked = seastar::abort_source();
- return seastar::sleep_abortable(10s, *p_blocked).then([this] {
+ return seastar::sleep_abortable(10s, *p_blocked).then([] {
throw std::runtime_error(
"Timeout (10s) in socket_blocker::wait_blocked()");
}).handle_exception_type([] (const seastar::sleep_aborted& e) {
}
ceph_assert(!p_unblocked);
p_unblocked = seastar::abort_source();
- return seastar::sleep_abortable(10s, *p_unblocked).then([this] {
+ return seastar::sleep_abortable(10s, *p_unblocked).then([] {
ceph_abort("Timeout (10s) in socket_blocker::block()");
}).handle_exception_type([] (const seastar::sleep_aborted& e) {
// wait done!
if (bytes == 0) {
return seastar::make_ready_future<seastar::temporary_buffer<char>>();
}
- return in.read_exactly(bytes).then([this](auto buf) {
+ return in.read_exactly(bytes).then([](auto buf) {
if (buf.empty()) {
throw std::system_error(make_error_code(error::read_eof));
}