mirror of
https://github.com/ceph/ceph
synced 2025-02-23 11:07:35 +00:00
crimson: do not capture unused variables
to silence warnings like src/crimson/net/Socket.cc:93:41: warning: lambda capture 'this' is not used [-Wunused-lambda-capture] return in.read_exactly(bytes).then([this](auto buf) { ^~~~ Signed-off-by: Kefu Chai <kchai@redhat.com>
This commit is contained in:
parent
acd4de57c4
commit
ba0fc1fef3
@ -1,3 +1,5 @@
|
||||
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
|
||||
|
||||
#include "MonClient.h"
|
||||
|
||||
#include <random>
|
||||
@ -988,10 +990,10 @@ seastar::future<> Client::reopen_session(int rank)
|
||||
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 {
|
||||
|
@ -62,7 +62,7 @@ class socket_blocker {
|
||||
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) {
|
||||
@ -78,7 +78,7 @@ class socket_blocker {
|
||||
}
|
||||
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!
|
||||
|
@ -90,7 +90,7 @@ Socket::read_exactly(size_t bytes) {
|
||||
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));
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user