extern/rclone
1
0
Fork 0
mirror of https://github.com/rclone/rclone.git synced 2024-12-23 07:29:35 +01:00
Code Issues Packages Projects Releases Wiki Activity

accounting: fix unknown length file transfers count 3 transfers each #6213

Browse Source 
This was caused by nested calls to NewTransfer/Done.

This fixes the problem by only incrementing transfers if the remote is
present in the transferMap which means we only increment it once.
This commit is contained in:
buda 2022-06-27 20:56:03 +04:00 committed by GitHub
parent fdd2f8e6d2
commit 517e7d9271
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fs/accounting/stats.go
View File

@ -714,10 +714,10 @@ func (s *StatsInfo) NewTransferRemoteSize(remote string, size int64) *Transfer {
// DoneTransferring removes a transfer from the stats // DoneTransferring removes a transfer from the stats
// //
// if ok is true then it increments the transfers count // if ok is true and it was in the transfermap (to avoid incrementing in case of nested calls, #6213) then it increments the transfers count
func (s *StatsInfo) DoneTransferring(remote string, ok bool) { func (s *StatsInfo) DoneTransferring(remote string, ok bool) {
s.transferring.del(remote) existed := s.transferring.del(remote)
if ok { if ok && existed {
s.mu.Lock() s.mu.Lock()
s.transfers++ s.transfers++
s.mu.Unlock() s.mu.Unlock()

5
fs/accounting/transfermap.go
View File

@ -34,10 +34,13 @@ func (tm *transferMap) add(tr *Transfer) {
} }
// del removes a transfer from the map by name // del removes a transfer from the map by name
func (tm *transferMap) del(remote string) { func (tm *transferMap) del(remote string) bool {
tm.mu.Lock() tm.mu.Lock()
_, exists := tm.items[remote]
delete(tm.items, remote) delete(tm.items, remote)
tm.mu.Unlock() tm.mu.Unlock()
return exists
} }
// merge adds items from another map // merge adds items from another map