RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-04 10:12:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

mds: set laggy in tick() if its been a while

Browse Source
This commit is contained in:
Sage Weil 2010-04-06 13:24:58 -07:00
parent 56de662246
commit 2f21010659
2 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/mds/MDS.cc
View File

@ -438,6 +438,7 @@ int MDS::init()
// schedule tick
reset_tick();
last_tick = g_clock.now();
mds_lock.Unlock();
return 0;
@ -464,8 +465,18 @@ void MDS::tick()
logclient.send_log();
utime_t now = g_clock.now();
utime_t delay = now;
delay -= last_tick;
if (delay > g_conf.mds_session_timeout / 2) {
dout(0) << " last tick was " << delay << " > " << g_conf.mds_tick_interval
<< " seconds ago, laggy_until " << laggy_until
<< ", setting laggy flag" << dendl;
laggy = true;
}
if (laggy)
return;
last_tick = now;
// make sure mds log flushes, trims periodically
mdlog->flush();
@ -478,7 +489,6 @@ void MDS::tick()
}
// log
utime_t now = g_clock.now();
mds_load_t load = balancer->get_load(now);
if (logger) {
@ -569,6 +579,7 @@ void MDS::handle_mds_beacon(MMDSBeacon *m)
dout(1) << " clearing laggy flag" << dendl;
laggy = false;
laggy_until = now;
last_tick = now; // so that tick() will start up again
queue_waiters(waiting_for_nolaggy);
}

1
src/mds/MDS.h
View File

@ -258,6 +258,7 @@ class MDS : public Dispatcher {
utime_t beacon_last_acked_stamp; // last time we sent a beacon that got acked
bool laggy;
utime_t laggy_until;
utime_t last_tick;
bool is_laggy() { return laggy; }
utime_t get_laggy_until() { return laggy_until; }