mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2026-04-29 11:31:28 -05:00
Code Issues Packages Projects Releases 159 Wiki Activity

go/store/datas/pull: fix bug in visited set update

Browse Source
This commit is contained in:
Andy Arthur
2023-02-01 17:36:27 -08:00
parent 0bd07d8252
commit 002641e5ab
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
go/store/datas/pull/puller.go
+4 -4
View File
@@ -445,10 +445,6 @@ func (p *Puller) Pull(ctx context.Context) error {
}
func batchNovelHashes(absent hash.HashSet, visited hash.HashSet, maxBatchSize int64) []hash.HashSet {
for h := range absent {
visited.Insert(h)
}
numAbsent := int64(len(absent))
if numAbsent < maxBatchSize {
smaller := absent
@@ -463,6 +459,9 @@ func batchNovelHashes(absent hash.HashSet, visited hash.HashSet, maxBatchSize in
absent.Remove(k)
}
}
for h := range absent {
visited.Insert(h)
}
return []hash.HashSet{absent}
} else {
var numBatches = (numAbsent / maxBatchSize) + 1
@@ -475,6 +474,7 @@ func batchNovelHashes(absent hash.HashSet, visited hash.HashSet, maxBatchSize in
var totalAbsent int64
for k := range absent {
if !visited.Has(k) {
visited.Insert(k)
currentNewBatch.Insert(k)
totalAbsent++