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

mon/MonClient: make _sub_got behave if we "got" old stuff

Browse Source 
Signed-off-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2015-11-13 13:03:16 -05:00
parent ca75e37a30
commit 57121dbe2c
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/mon/MonClient.h
View File

@ -231,15 +231,19 @@ private:
}
void _sub_got(string what, version_t got) {
if (sub_new.count(what)) {
if (sub_new[what].flags & CEPH_SUBSCRIBE_ONETIME)
sub_new.erase(what);
else
sub_new[what].start = got + 1;
if (sub_new[what].start <= got) {
if (sub_new[what].flags & CEPH_SUBSCRIBE_ONETIME)
sub_new.erase(what);
else
sub_new[what].start = got + 1;
}
} else if (sub_sent.count(what)) {
if (sub_sent[what].flags & CEPH_SUBSCRIBE_ONETIME)
sub_sent.erase(what);
else
sub_sent[what].start = got + 1;
if (sub_sent[what].start <= got) {
if (sub_sent[what].flags & CEPH_SUBSCRIBE_ONETIME)
sub_sent.erase(what);
else
sub_sent[what].start = got + 1;
}
}
}
void _sub_unwant(string what) {