Fix: the keys argument to changeSizes was passed as a reference, but when used after the first wait(), it may no longer be valid.

This commit is contained in:
A.J. Beamon 2019-10-09 14:07:48 -07:00
parent 932b852822
commit 909855bcec
1 changed files with 1 additions and 1 deletions

View File

@ -258,7 +258,7 @@ ACTOR Future<int64_t> getFirstSize( Reference<AsyncVar<Optional<StorageMetrics>>
}
}
ACTOR Future<Void> changeSizes( DataDistributionTracker* self, KeyRangeRef keys, int64_t oldShardsEndingSize ) {
ACTOR Future<Void> changeSizes( DataDistributionTracker* self, KeyRange keys, int64_t oldShardsEndingSize ) {
state vector<Future<int64_t>> sizes;
state vector<Future<int64_t>> systemSizes;
for (auto it : self->shards.intersectingRanges(keys) ) {