scrub_infop->pending_scrub_error = true;
if (scrub_infop->header &&
scrub_infop->header->repair)
- cache->repair_dirfrag_stats(this, NULL);
+ cache->repair_dirfrag_stats(this);
}
return rval;
}
if (in->scrub_infop &&
in->scrub_infop->header &&
in->scrub_infop->header->repair)
- in->mdcache->repair_inode_stats(in, NULL);
+ in->mdcache->repair_inode_stats(in);
goto next;
}
if (frags_errors > 0)
}
};
-void MDCache::repair_dirfrag_stats(CDir *dir, Context *fin)
+void MDCache::repair_dirfrag_stats(CDir *dir)
{
- if (!fin)
- fin = new C_MDSInternalNoop;
MDRequestRef mdr = request_start_internal(CEPH_MDS_OP_REPAIR_FRAGSTATS);
mdr->pin(dir);
mdr->internal_op_private = dir;
- mdr->internal_op_finish = fin;
+ mdr->internal_op_finish = new C_MDSInternalNoop;
repair_dirfrag_stats_work(mdr);
}
mds->mdlog->submit_entry(le, new C_MDC_RepairDirfragStats(mds, mdr));
}
-void MDCache::repair_inode_stats(CInode *diri, Context *fin)
+void MDCache::repair_inode_stats(CInode *diri)
{
- if (!fin)
- fin = new C_MDSInternalNoop;
MDRequestRef mdr = request_start_internal(CEPH_MDS_OP_REPAIR_INODESTATS);
mdr->pin(diri);
mdr->internal_op_private = diri;
- mdr->internal_op_finish = fin;
+ mdr->internal_op_finish = new C_MDSInternalNoop;
repair_inode_stats_work(mdr);
}
void enqueue_scrub(const string& path, const std::string &tag,
bool force, bool recursive, bool repair,
Formatter *f, Context *fin);
- void repair_inode_stats(CInode *diri, Context *fin);
- void repair_dirfrag_stats(CDir *dir, Context *fin);
+ void repair_inode_stats(CInode *diri);
+ void repair_dirfrag_stats(CDir *dir);
};
class C_MDS_RetryRequest : public MDSInternalContext {