fix: close pubsub

yxq · 33cn · commit aca60b86d6e5 · 2021-08-03T17:43:50.000+08:00
diff --git a/system/p2p/dht/p2p.go b/system/p2p/dht/p2p.go
@@ -204,7 +204,7 @@ func (p *P2P) CloseP2P() {
 
 	protocol.ClearEventHandler()
 	if !p.isRestart() {
-		p.mgr.PubSub.Unsub(p.subChan)
+		p.mgr.PubSub.Shutdown()
 
 	}
 	p.host.Close()

Original file line number	Diff line number	Diff line change
`@@ -204,7 +204,7 @@ func (p *P2P) CloseP2P() {`
`204`	`204`
`205`	`205`	`protocol.ClearEventHandler()`
`206`	`206`	`if !p.isRestart() {`
`207`		`- p.mgr.PubSub.Unsub(p.subChan)`
	`207`	`+ p.mgr.PubSub.Shutdown()`
`208`	`208`
`209`	`209`	`}`
`210`	`210`	`p.host.Close()`