gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(objectnode): fix s3qos resource release

Browse Source 
Signed-off-by: tangdeyi <tangdeyi@oppo.com>
This commit is contained in:
tangdeyi 2023-09-06 15:38:46 +08:00 committed by tangdeyi
parent 21e22d368d
commit 7507bbdc35
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
objectnode/ratelimit.go
View File

@ -199,7 +199,6 @@ func (r *UserRateMgr) QPSLimitAllowed(uid string) (bool, time.Duration) {
}
log.LogDebugf("QPSLimit: defaultQPSLimit[%d] usrQPSLimit[%d] uid[%s]", defaultQPSLimit, usrQPSLimit, uid)
qpsLimit := r.QPSLimit.Acquire(uid, qpsQuota)
defer r.QPSLimit.Release(uid)
return !qpsLimit.Limit(), 0
}
@ -234,7 +233,6 @@ func (r *UserRateMgr) GetResponseWriter(uid string, w io.Writer) io.Writer {
log.LogDebugf("WriterFlowCtrl: defaultBandWidthLimit[%d] usrBandWidthLimit[%d] uid[%s]", defaultBandWidthLimit, usrBandWidthLimit, uid)
rate, _ := convertUint64ToInt(bandWidthQuota)
flowCtrl := r.BandWidthLimit.Acquire(uid, rate)
defer r.BandWidthLimit.Release(uid)
w = flowctrl.NewRateWriterWithCtrl(w, flowCtrl)
return w
@ -253,7 +251,6 @@ func (r *UserRateMgr) GetReader(uid string, reader io.Reader) io.Reader {
log.LogDebugf("ReaderFlowCtrl: defaultBandWidthLimit[%d] usrBandWidthLimit[%d] uid[%s]", defaultBandWidthLimit, usrBandWidthLimit, uid)
rate, _ := convertUint64ToInt(bandWidthQuota)
flowCtrl := r.BandWidthLimit.Acquire(uid, rate)
defer r.BandWidthLimit.Release(uid)
reader = flowctrl.NewRateReaderWithCtrl(reader, flowCtrl)
return reader