RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-19 09:57:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

osd: check pending or active scrub before sched_scrub

Browse Source 
Signed-off-by: Xinze Chi <xmdxcxz@gmail.com>
This commit is contained in:
Xinze Chi 2015-05-29 11:29:38 +08:00
parent 7b4ee4060a
commit deb8ea44ce
2 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/osd/OSD.cc
View File

@ -896,6 +896,21 @@ void OSDService::share_map_peer(int peer, Connection *con, OSDMapRef map)
}
}
bool OSDService::can_inc_scrubs_pending()
{
bool can_inc = false;
Mutex::Locker l(sched_scrub_lock);
if (scrubs_pending + scrubs_active < cct->_conf->osd_max_scrubs) {
dout(20) << __func__ << scrubs_pending << " -> " << (scrubs_pending+1)
<< " (max " << cct->_conf->osd_max_scrubs << ", active " << scrubs_active << ")" << dendl;
can_inc = true;
} else {
dout(20) << __func__ << scrubs_pending << " + " << scrubs_active << " active >= max " << cct->_conf->osd_max_scrubs << dendl;
}
return can_inc;
}
bool OSDService::inc_scrubs_pending()
{
@ -5923,6 +5938,11 @@ bool OSD::scrub_load_below_threshold()
void OSD::sched_scrub()
{
// if not permitted, fail fast
if (!service.can_inc_scrubs_pending()) {
return;
}
utime_t now = ceph_clock_now(cct);
bool time_permit = scrub_time_permit(now);
bool load_is_low = scrub_load_below_threshold();

1
src/osd/OSD.h
View File

@ -564,6 +564,7 @@ public:
return true;
}
bool can_inc_scrubs_pending();
bool inc_scrubs_pending();
void inc_scrubs_active(bool reserved);
void dec_scrubs_pending();