aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-09-14 00:06:54 -0700
committerchrislu <chris.lu@gmail.com>2022-09-14 00:06:54 -0700
commit58d18b68d8ca463cef2a817f69f62e7b2fbd61f0 (patch)
treef559101647fbf78ca21addac0ec7400ccbd18e8f
parentf8ef25099c63a5b0603f781e5d514e0c07bbf325 (diff)
downloadseaweedfs-58d18b68d8ca463cef2a817f69f62e7b2fbd61f0.tar.xz
seaweedfs-58d18b68d8ca463cef2a817f69f62e7b2fbd61f0.zip
rename variable
-rw-r--r--weed/server/volume_server_handlers_read.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/server/volume_server_handlers_read.go b/weed/server/volume_server_handlers_read.go
index ced473852..90f553116 100644
--- a/weed/server/volume_server_handlers_read.go
+++ b/weed/server/volume_server_handlers_read.go
@@ -120,11 +120,11 @@ func (vs *VolumeServer) GetOrHeadHandler(w http.ResponseWriter, r *http.Request)
}
var count int
- var needleSize types.Size
+ var memoryCost types.Size
readOption.AttemptMetaOnly, readOption.MustMetaOnly = shouldAttemptStreamWrite(hasVolume, ext, r)
onReadSizeFn := func(size types.Size) {
- needleSize = size
- atomic.AddInt64(&vs.inFlightDownloadDataSize, int64(needleSize))
+ memoryCost = size
+ atomic.AddInt64(&vs.inFlightDownloadDataSize, int64(memoryCost))
}
if hasVolume {
count, err = vs.store.ReadVolumeNeedle(volumeId, n, readOption, onReadSizeFn)
@@ -132,7 +132,7 @@ func (vs *VolumeServer) GetOrHeadHandler(w http.ResponseWriter, r *http.Request)
count, err = vs.store.ReadEcShardNeedle(volumeId, n, onReadSizeFn)
}
defer func() {
- atomic.AddInt64(&vs.inFlightDownloadDataSize, -int64(needleSize))
+ atomic.AddInt64(&vs.inFlightDownloadDataSize, -int64(memoryCost))
vs.inFlightDownloadDataLimitCond.Signal()
}()