RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-21 01:47:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

simplify mds overload judgement logic

Browse Source 
Signed-off-by: Jianyu Li <joannyli@tencent.com>
This commit is contained in:
Jianyu Li 2017-12-12 15:20:44 +08:00
parent 9a276c2733
commit e5ca899260
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/mds/MDBalancer.cc
View File

@ -664,11 +664,13 @@ void MDBalancer::prep_rebalance(int beat)
dout(15) << " mds." << it->second << " is importer" << dendl;
importers.insert(pair<double,mds_rank_t>(it->first,it->second));
importer_set.insert(it->second);
} else if ((it->first > target_load * (1.0 + g_conf->mds_bal_min_rebalance)) &&
(it->second == whoami || !mds_last_epoch_under_info[it->second] || beat_epoch - mds_last_epoch_under_info[it->second] >= 2)){
dout(15) << " mds." << it->second << " is exporter" << dendl;
exporters.insert(pair<double,mds_rank_t>(it->first,it->second));
exporter_set.insert(it->second);
} else if (it->first > target_load * (1.0 + g_conf->mds_bal_min_rebalance)) {
int mds_last_epoch_under = (it->second == whoami) ? 0 : mds_last_epoch_under_info[it->second];
if (!mds_last_epoch_under || beat_epoch - mds_last_epoch_under >= 2) {
dout(15) << " mds." << it->second << " is exporter" << dendl;
exporters.insert(pair<double,mds_rank_t>(it->first,it->second));
exporter_set.insert(it->second);
}
}
}