From f2f5321eb57d10410ebb6eb1a29022c4764d9c19 Mon Sep 17 00:00:00 2001 From: Mark Holt Date: Wed, 7 Aug 2024 21:28:52 +0100 Subject: [PATCH] add close printer --- torrent.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/torrent.go b/torrent.go index acfc6648ee..ed5bdb4c51 100644 --- a/torrent.go +++ b/torrent.go @@ -1070,6 +1070,9 @@ func (t *Torrent) close(wg *sync.WaitGroup) (err error) { err = errors.New("already closed") return } + + fmt.Println("CLS", t.name(true)) + for _, f := range t.onClose { f() } @@ -1098,7 +1101,7 @@ func (t *Torrent) close(wg *sync.WaitGroup) (err error) { if t.storage != nil { closed := make(chan struct{}) defer func() { closed <- struct{}{} }() - + fmt.Println("ST CLS", t.name(true)) wg.Add(1) go func() { defer wg.Done() @@ -1107,9 +1110,9 @@ func (t *Torrent) close(wg *sync.WaitGroup) (err error) { defer t.storageLock.Unlock() if f := t.storage.Close; f != nil { fmt.Println("CLS", t.name(true)) - err1 := f() - if err1 != nil { - t.logger.WithDefaultLevel(log.Warning).Printf("error closing storage: %v", err1) + if err := f(); err != nil { + fmt.Println("ERR", t.name(true)) + t.logger.WithDefaultLevel(log.Warning).Printf("error closing storage: %v", err) } } }()