diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-08-30 02:03:08 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-08-30 02:03:08 -0700 |
| commit | f811fd0903a8e91f63d38a3a95ee6863a010db4e (patch) | |
| tree | eae446a9e809acda5364ae92d563beb5e94a10a4 | |
| parent | 44d0ac95f6a068203edc4568660a720c6f5cdf8b (diff) | |
| download | seaweedfs-f811fd0903a8e91f63d38a3a95ee6863a010db4e.tar.xz seaweedfs-f811fd0903a8e91f63d38a3a95ee6863a010db4e.zip | |
fix build
| -rw-r--r-- | weed/storage/needle_map_metric.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/weed/storage/needle_map_metric.go b/weed/storage/needle_map_metric.go index 7cf48dd72..0bdfdcedc 100644 --- a/weed/storage/needle_map_metric.go +++ b/weed/storage/needle_map_metric.go @@ -93,10 +93,10 @@ func (mm *mapMetric) MaybeSetMaxFileKey(key NeedleId) { func newNeedleMapMetricFromIndexFile(r *os.File) (mm *mapMetric, err error) { mm = &mapMetric{} - var bf *boom.StableBloomFilter + var bf *boom.BloomFilter buf := make([]byte, NeedleIdSize) err = reverseWalkIndexFile(r, func(entryCount int64) { - bf = boom.NewDefaultStableBloomFilter(uint(entryCount), 0.001) + bf = boom.NewBloomFilter(uint(entryCount), 0.001) }, func(key NeedleId, offset Offset, size Size) error { mm.MaybeSetMaxFileKey(key) @@ -105,9 +105,8 @@ func newNeedleMapMetricFromIndexFile(r *os.File) (mm *mapMetric, err error) { mm.FileByteCounter += uint64(size) } - if !bf.Test(buf) { + if !bf.TestAndAdd(buf) { mm.FileCounter++ - bf.Add(buf) } else { // deleted file mm.DeletionCounter++ |