aboutsummaryrefslogtreecommitdiff
path: root/weed/storage
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2025-06-02 23:56:58 -0700
committerChris Lu <chris.lu@gmail.com>2025-06-02 23:56:58 -0700
commitb25561d0d7c45a17f0b6bd73b6335dfa2b50b3f7 (patch)
treeb5135c511efe0268563ce55555ad18186606f446 /weed/storage
parent72047317498700d349afa15b370d3ba8e88fa417 (diff)
downloadseaweedfs-b25561d0d7c45a17f0b6bd73b6335dfa2b50b3f7.tar.xz
seaweedfs-b25561d0d7c45a17f0b6bd73b6335dfa2b50b3f7.zip
3.89
Diffstat (limited to 'weed/storage')
-rw-r--r--weed/storage/needle_map/compact_map.go16
1 files changed, 10 insertions, 6 deletions
diff --git a/weed/storage/needle_map/compact_map.go b/weed/storage/needle_map/compact_map.go
index a1288cadb..f0b174029 100644
--- a/weed/storage/needle_map/compact_map.go
+++ b/weed/storage/needle_map/compact_map.go
@@ -91,15 +91,19 @@ func (cs *CompactSection) Set(key NeedleId, offset Offset, size Size) (oldOffset
oldOffset.OffsetHigher, oldOffset.OffsetLower, oldSize = oldValue.OffsetHigher, oldValue.OffsetLower, oldValue.Size
}
cs.setOverflowEntry(skey, offset, size)
+<<<<<<< Updated upstream
return
+=======
+ } else {
+ // if we maxed out our values bucket, pin its capacity to minimize memory usage
+ if len(cs.values) == MaxSectionBucketSize {
+ bucket := make([]SectionalNeedleValue, len(cs.values))
+ copy(bucket, cs.values)
+ cs.values = bucket
+ }
+>>>>>>> Stashed changes
}
- // if we maxed out our values bucket, pin its capacity to minimize memory usage
- if len(cs.values) == MaxSectionBucketSize {
- bucket := make([]SectionalNeedleValue, len(cs.values))
- copy(bucket, cs.values)
- cs.values = bucket
- }
return
}