_send_ready_to_merge();
}
-void OSDService::set_ready_to_merge_target(PG *pg, epoch_t last_epoch_clean)
+void OSDService::set_ready_to_merge_target(PG *pg,
+ epoch_t last_epoch_started,
+ epoch_t last_epoch_clean)
{
- Mutex::Locker l(merge_lock);
+ std::lock_guard l(merge_lock);
dout(10) << __func__ << " " << pg->pg_id << dendl;
- ready_to_merge_target.insert(make_pair(pg->pg_id.pgid, last_epoch_clean));
+ ready_to_merge_target.insert(make_pair(pg->pg_id.pgid,
+ make_pair(last_epoch_started,
+ last_epoch_clean)));
assert(not_ready_to_merge_target.count(pg->pg_id.pgid) == 0);
_send_ready_to_merge();
}