RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-31 07:22:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

ReplicatedPG: only pull in one backfill peer at a time

Browse Source 
Signed-off-by: Samuel Just <samuel.just@dreamhost.com>
This commit is contained in:
Samuel Just 2011-12-22 17:17:40 -08:00
parent 8b8aab8473
commit 517ddf8435
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/osd/PG.cc
View File

@ -993,6 +993,7 @@ void PG::calc_acting(int& newest_update_osd_id, vector<int>& want) const
<< " with " << primary->second << dendl;
want.push_back(primary->first);
unsigned usable = 1;
unsigned backfill = 0;
// select replicas that have log contiguity with primary
for (vector<int>::const_iterator i = up.begin();
@ -1002,8 +1003,13 @@ void PG::calc_acting(int& newest_update_osd_id, vector<int>& want) const
continue;
const Info &cur_info = all_info.find(*i)->second;
if (cur_info.is_incomplete() || cur_info.last_update < primary->second.log_tail) {
dout(10) << " osd." << *i << " (up) accepted (backfill) " << cur_info << dendl;
want.push_back(*i);
if (backfill < 1) {
dout(10) << " osd." << *i << " (up) accepted (backfill) " << cur_info << dendl;
want.push_back(*i);
backfill++;
} else {
dout(10) << " osd." << *i << " (up) rejected" << cur_info << dendl;
}
} else {
want.push_back(*i);
usable++;