uint64_t got = m_throttle.get(c);
if (got < c) {
// Not enough tokens, add a blocker for it.
- Context *ctx = new FunctionContext([this, handler, item](int r) {
+ Context *ctx = new FunctionContext([handler, item](int r) {
(handler->*MF)(r, item);
});
m_blockers.emplace_back(c - got, ctx);
f->open_object_section("mds_load");
{
- auto dump_mds_load = [this, f, now](mds_load_t& load) {
+ auto dump_mds_load = [f, now](mds_load_t& load) {
f->dump_float("request_rate", load.req_rate);
f->dump_float("cache_hit_rate", load.cache_hit_rate);
f->dump_float("queue_length", load.queue_len);
}
}
- auto dump_func = [this, fd, f, depth, &dump_root](CInode *in) {
+ auto dump_func = [fd, f, depth, &dump_root](CInode *in) {
int r;
if (!dump_root.empty()) {
string ipath;
objecter->enable_blacklist_events();
std::set<entity_addr_t> blacklist;
epoch_t epoch = 0;
- objecter->with_osdmap([this, &blacklist, &epoch](const OSDMap& o) {
+ objecter->with_osdmap([&blacklist, &epoch](const OSDMap& o) {
o.get_blacklist(&blacklist);
epoch = o.get_epoch();
});
Context *on_blacklist_done = new FunctionContext([this, session_id, fn](int r) {
objecter->wait_for_latest_osdmap(
new C_OnFinisher(
- new FunctionContext([this, session_id, fn](int r) {
+ new FunctionContext([this, fn](int r) {
Mutex::Locker l(mds_lock);
auto epoch = objecter->with_osdmap([](const OSDMap &o){
return o.get_epoch();
monc->start_mon_command(cmd, {}, nullptr, nullptr, on_blacklist_done);
};
- auto blocking_blacklist = [this, cmd, &err_ss, background_blacklist](){
+ auto blocking_blacklist = [this, cmd, background_blacklist](){
C_SaferCond inline_ctx;
background_blacklist([&inline_ctx](){inline_ctx.complete(0);});
mds_lock.Unlock();
auto m = new MServiceMap(service_map);
sub->session->con->send_message(m);
if (sub->onetime) {
- mon->with_session_map([this, sub](MonSessionMap& session_map) {
+ mon->with_session_map([sub](MonSessionMap& session_map) {
session_map.remove_sub(sub);
});
} else {
if (sub->next <= epoch) {
mon->send_latest_monmap(sub->session->con.get());
if (sub->onetime) {
- mon->with_session_map([this, sub](MonSessionMap& session_map) {
+ mon->with_session_map([sub](MonSessionMap& session_map) {
session_map.remove_sub(sub);
});
} else {
ConnectionRef());
});
ctx->register_on_finish(
- [ctx, this]() {
+ [ctx]() {
delete ctx;
});
void expect_copyup(MockCopyupRequest& mock_copyup_request, int r) {
EXPECT_CALL(mock_copyup_request, send())
- .WillOnce(Invoke([&mock_copyup_request, r]() {
- }));
+ .WillOnce(Invoke([]() {}));
}
void expect_copyup(MockCopyupRequest& mock_copyup_request,
int owner_id = -1;
mutex lock;
- const auto pingpong = [&,this](int m_id, rbd_image_t &m_image) {
+ const auto pingpong = [&](int m_id, rbd_image_t &m_image) {
for (int i = 0; i < 10; i++) {
{
lock_guard<mutex> locker(lock);
C_SaferCond notify_sync_ctx;
EXPECT_CALL(mock_instance_watcher,
notify_sync_request(mock_local_image_ctx.id, _))
- .WillOnce(Invoke([this, &on_sync_start, ¬ify_sync_ctx](
+ .WillOnce(Invoke([&on_sync_start, ¬ify_sync_ctx](
const std::string &, Context *ctx) {
on_sync_start = ctx;
notify_sync_ctx.complete(0);
}));
EXPECT_CALL(mock_instance_watcher,
cancel_sync_request(mock_local_image_ctx.id))
- .WillOnce(Invoke([this, &on_sync_start](const std::string &) {
+ .WillOnce(Invoke([&on_sync_start](const std::string &) {
EXPECT_NE(nullptr, on_sync_start);
on_sync_start->complete(-ECANCELED);
return true;