fix: upgraded tags must be popped from all log sets
This commit is contained in:
parent
1b5d28386a
commit
979597a2ca
|
@ -881,7 +881,7 @@ struct TagPartitionedLogSystem : ILogSystem, ReferenceCounted<TagPartitionedLogS
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
for(auto& t : tLogs) {
|
for(auto& t : tLogs) {
|
||||||
if(t->locality == tagLocalitySpecial || t->locality == tag.locality || (tag.locality < 0 && ((popLocality == tagLocalityInvalid) == t->isLocal))) {
|
if(t->locality == tagLocalitySpecial || t->locality == tag.locality || tag.locality == tagLocalityUpgraded || (tag.locality < 0 && ((popLocality == tagLocalityInvalid) == t->isLocal))) {
|
||||||
for(auto& log : t->logServers) {
|
for(auto& log : t->logServers) {
|
||||||
Version prev = outstandingPops[std::make_pair(log->get().id(),tag)].first;
|
Version prev = outstandingPops[std::make_pair(log->get().id(),tag)].first;
|
||||||
if (prev < upTo)
|
if (prev < upTo)
|
||||||
|
|
Loading…
Reference in New Issue