} else {
return socket->flush();
}
- }).then([this] {
+ }).then([] {
return stop_t::yes;
});
}
abort_protocol();
}
if (socket) {
- (void) with_gate(pending_dispatch, [this, sock = std::move(socket)] () mutable {
+ (void) with_gate(pending_dispatch, [sock = std::move(socket)] () mutable {
return sock->close().then([sock = std::move(sock)] {});
});
}
if (unlikely(state != state_t::CONNECTING)) {
logger().debug("{} triggered {} during Socket::connect()",
conn, get_state_name(state));
- return sock->close().then([this, sock = std::move(sock)] {
+ return sock->close().then([sock = std::move(sock)] {
abort_protocol();
});
}
{
auto wait = WaitFrame::Encode();
logger().debug("{} WRITE WaitFrame", conn);
- return write_frame(wait).then([this] {
+ return write_frame(wait).then([] {
return next_step_t::wait;
});
}
auto ident_missing_features = IdentMissingFeaturesFrame::Encode(feat_missing);
logger().warn("{} WRITE IdentMissingFeaturesFrame: features={} (peer missing)",
conn, feat_missing);
- return write_frame(ident_missing_features).then([this] {
+ return write_frame(ident_missing_features).then([] {
return next_step_t::wait;
});
}
}
if (socket) {
- (void) with_gate(pending_dispatch, [this, sock = std::move(socket)] () mutable {
+ (void) with_gate(pending_dispatch, [sock = std::move(socket)] () mutable {
return sock->close().then([sock = std::move(sock)] {});
});
}
CEPH_ENTITY_TYPE_OSD),
back_msgr.connect(osdmap->get_hb_back_addrs(peer).front(),
CEPH_ENTITY_TYPE_OSD))
- .then([this, &info=peer_info->second] (auto xcon_front, auto xcon_back) {
+ .then([&info=peer_info->second] (auto xcon_front, auto xcon_back) {
// sharded-messenger compatible mode
info.con_front = xcon_front->release();
info.con_back = xcon_back->release();
return seastar::make_ready_future<osd_id_t>(-1);
}
}, osds_t{},
- [this](osds_t&& extras, osd_id_t extra) {
+ [](osds_t&& extras, osd_id_t extra) {
if (extra >= 0) {
extras.push_back(extra);
}
"args": [{}]
}})", whoami, weight, loc);
return monc->run_command({cmd}, {}).then(
- [this](int32_t code, string message, bufferlist) {
+ [](int32_t code, string message, bufferlist) {
if (code) {
logger().warn("fail to add to crush: {} ({})", message, code);
throw std::runtime_error("fail to add to crush");
{
auto o = std::make_unique<OSDMap>();
if (e > 0) {
- return load_map_bl(e).then([e, o=std::move(o), this](bufferlist bl) mutable {
+ return load_map_bl(e).then([o=std::move(o)](bufferlist bl) mutable {
o->decode(bl);
return seastar::make_ready_future<unique_ptr<OSDMap>>(std::move(o));
});
}
}
return make_pg(startmap, pgid).then(
- [this, startmap=std::move(startmap)](auto pg) mutable {
+ [startmap=std::move(startmap)](auto pg) mutable {
return seastar::make_ready_future<Ref<PG>, cached_map_t>(
std::move(pg),
std::move(startmap));
return store->get_attrs(
coll,
ghobject_t{oid, ghobject_t::NO_GEN, shard}).safe_then(
- [oid, this](auto &&attrs) -> load_metadata_ertr::future<loaded_object_md_t::ref>{
+ [oid](auto &&attrs) -> load_metadata_ertr::future<loaded_object_md_t::ref>{
loaded_object_md_t::ref ret(new loaded_object_md_t());
if (auto oiiter = attrs.find(OI_ATTR); oiiter != attrs.end()) {
bufferlist bl;
return load_metadata_ertr::make_ready_future<loaded_object_md_t::ref>(
std::move(ret));
- }, crimson::ct_error::enoent::handle([oid, this] {
+ }, crimson::ct_error::enoent::handle([oid] {
logger().debug(
"load_metadata: object {} doesn't exist, returning empty metadata",
oid);
gstart,
ghobject_t::get_max(),
limit)
- .then([this](std::vector<ghobject_t> gobjects, ghobject_t next) {
+ .then([](std::vector<ghobject_t> gobjects, ghobject_t next) {
std::vector<hobject_t> objects;
boost::copy(gobjects |
boost::adaptors::filtered([](const ghobject_t& o) {
string{info_key},
string{biginfo_key},
string{fastinfo_key}});
- }).then([this](auto&& values) {
+ }).then([](auto&& values) {
{
// sanity check
auto infover = find_value<__u8>(values, infover_key);