File tree Expand file tree Collapse file tree 1 file changed +4
-9
lines changed
Expand file tree Collapse file tree 1 file changed +4
-9
lines changed Original file line number Diff line number Diff line change @@ -694,17 +694,12 @@ Future<RangeResult> ConflictingKeysImpl::getRange(ReadYourWritesTransaction* ryw
694694 GetRangeLimits limitsHint) const {
695695 RangeResult result;
696696 if (ryw->getTransactionState ()->conflictingKeys ) {
697- auto krMapPtr = ryw->getTransactionState ()->conflictingKeys .get ();
698- auto beginIter = krMapPtr->rangeContaining (kr.begin );
699- auto endIter = krMapPtr->rangeContaining (kr.end );
700-
701- if (!kr.contains (beginIter->begin ()) && beginIter != endIter)
702- ++beginIter;
703- for (auto it = beginIter; it != endIter; ++it) {
697+ auto ranges = ryw->getTransactionState ()->conflictingKeys ->containedRanges (kr);
698+ for (auto it = ranges.begin (); it != ranges.end (); ++it) {
704699 result.push_back_deep (result.arena (), KeyValueRef (it->begin (), it->value ()));
705700 }
706- if (kr.contains (endIter ->begin ()))
707- result.push_back_deep (result.arena (), KeyValueRef (endIter ->begin (), endIter ->value ()));
701+ if (kr.contains (ranges. end () ->begin ()))
702+ result.push_back_deep (result.arena (), KeyValueRef (ranges. end () ->begin (), ranges. end () ->value ()));
708703 }
709704 return result;
710705}
You can’t perform that action at this time.
0 commit comments