diff options
| author | chrislu <chris.lu@gmail.com> | 2022-08-20 23:35:31 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-08-20 23:35:31 -0700 |
| commit | c7892bc7c4a5df48cc1db946243573b3ded3d711 (patch) | |
| tree | 1ee9312aa5db56d0d431c7e9236ce18df9996ba1 | |
| parent | f7e0a65e752f08566c829ce67c4aa8ed1d6dd4f6 (diff) | |
| download | seaweedfs-c7892bc7c4a5df48cc1db946243573b3ded3d711.tar.xz seaweedfs-c7892bc7c4a5df48cc1db946243573b3ded3d711.zip | |
volume: file counter should be all files
address https://github.com/seaweedfs/seaweedfs/pull/3388#issuecomment-1220466228
| -rw-r--r-- | weed/storage/needle_map_metric.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/weed/storage/needle_map_metric.go b/weed/storage/needle_map_metric.go index 0ce616131..abf6b4b8b 100644 --- a/weed/storage/needle_map_metric.go +++ b/weed/storage/needle_map_metric.go @@ -105,9 +105,8 @@ func newNeedleMapMetricFromIndexFile(r *os.File) (mm *mapMetric, err error) { mm.FileByteCounter += uint64(size) } - if !bf.TestAndAdd(buf) { - mm.FileCounter++ - } else { + mm.FileCounter++ + if bf.TestAndAdd(buf) { // deleted file mm.DeletionCounter++ if size.IsValid() { |