From 353448e5caf3ae0e864e980a3042aac7156ae8db Mon Sep 17 00:00:00 2001
From: ucwong <ucwong@126.com>
Date: Fri, 17 May 2024 23:50:13 +0800
Subject: [PATCH] optimized clean & leech

---
 backend/handler.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/backend/handler.go b/backend/handler.go
index eb1ba4f9..0d820323 100644
--- a/backend/handler.go
+++ b/backend/handler.go
@@ -1257,14 +1257,16 @@ func (tm *TorrentManager) activeLoop() {
 				}
 			}*/
 
-			var clean = make([]*caffe.Torrent, 0, tm.torrents.Len())
+			//var clean = make([]*caffe.Torrent, 0, tm.torrents.Len())
 			tm.torrents.Range(func(ih string, t *caffe.Torrent) bool {
 				if t.Running() {
 					if t.Torrent.BytesMissing() == 0 {
-						clean = append(clean, t)
+						//clean = append(clean, t)
+						workers.Go(func() error { return tm.finish(t) })
 					} else {
 						if t.Torrent.BytesCompleted() < t.BytesRequested() {
 							workers.Go(func() error { return t.Leech() })
+							//t.Leech()
 						}
 					}
 				}
@@ -1281,13 +1283,13 @@ func (tm *TorrentManager) activeLoop() {
 				log.Warn("Leech error", "err", err)
 			}
 
-			for _, i := range clean {
+			/*for _, i := range clean {
 				workers.Go(func() error { return tm.finish(i) })
 			}
 
 			if err := workers.Wait(); err != nil {
 				log.Warn("Finished error", "err", err)
-			}
+			}*/
 
 			counter++