Merge pull request #236 from CortexFoundation/dev

torrent/monitor | running status signal switch assert
CortexFoundation · Nov 18, 2019 · 99306ce · 99306ce
2 parents 8309c15 + b50844f
commit 99306ce
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/torrentfs/monitor.go b/torrentfs/monitor.go
@@ -531,6 +531,9 @@ func (m *Monitor) parseBlockTorrentInfo(b *Block, flowCtrl bool) error {
 
 func (m *Monitor) Stop() {
 	log.Info("Torrent listener closing")
+	if atomic.LoadInt32(&(m.terminated)) == 1 {
+		return
+	}
 	atomic.StoreInt32(&(m.terminated), 1)
 	close(m.exitCh)
 	//m.wg.Wait()