extern/rclone
1
0
Fork 0
mirror of https://github.com/rclone/rclone.git synced 2025-01-09 15:58:28 +01:00
Code Issues Packages Projects Releases Wiki Activity

vfs: writeback - stop the timer explicitly on transfers exceeded

Browse Source
This commit is contained in:
Nick Craig-Wood 2020-06-20 12:25:33 +01:00
parent 8506066926
commit b9ff495483
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
vfs/vfscache/writeback.go
View File

@ -187,19 +187,24 @@ func (wb *writeBack) _peekItem() (wbItem *writeBackItem) {
return wb.items[0] return wb.items[0]
} }
// stop the timer which runs the expiries
func (wb *writeBack) _stopTimer() {
if wb.expiry.IsZero() {
return
}
wb.expiry = time.Time{}
fs.Debugf(nil, "resetTimer STOP")
if wb.timer != nil {
wb.timer.Stop()
wb.timer = nil
}
}
// reset the timer which runs the expiries // reset the timer which runs the expiries
func (wb *writeBack) _resetTimer() { func (wb *writeBack) _resetTimer() {
wbItem := wb._peekItem() wbItem := wb._peekItem()
if wbItem == nil { if wbItem == nil {
if wb.expiry.IsZero() { wb._stopTimer()
return
}
wb.expiry = time.Time{}
fs.Debugf(nil, "resetTimer STOP")
if wb.timer != nil {
wb.timer.Stop()
wb.timer = nil
}
} else { } else {
if wb.expiry.Equal(wbItem.expiry) { if wb.expiry.Equal(wbItem.expiry) {
return return
@ -377,6 +382,8 @@ func (wb *writeBack) processItems(ctx context.Context) {
if resetTimer { if resetTimer {
wb._resetTimer() wb._resetTimer()
} else {
wb._stopTimer()
} }
} }