Signed-off-by: Sage Weil <sage@redhat.com>
clog->debug() << "purged_snaps scrub starts";
osd_lock.unlock();
s.run();
- osd_lock.lock();
- if (is_stopping()) {
- return;
- }
if (s.stray.size()) {
clog->debug() << "purged_snaps scrub find " << s.stray.size() << " strays";
} else {
pg->queue_snap_retrim(snap);
pg->unlock();
}
+ osd_lock.Lock();
+ if (is_stopping()) {
+ return;
+ }
dout(10) << __func__ << " done queueing pgs, updating superblock" << dendl;
ObjectStore::Transaction t;
superblock.last_purged_snaps_scrub = ceph_clock_now();