Update channel.go (#92)

joy-shuang · web-flow · commit 69347fe88ffc · 2020-12-07T12:01:55.000+08:00
when reconnect close，close once only.
diff --git a/conn/channel.go b/conn/channel.go
@@ -943,6 +943,7 @@ func (hc *channelSession) processMessages() {
 				}
 				hc.c = con
 				hc.closed = make(chan interface{})
+				hc.closeOnce = sync.Once{}
 				hc.nodeInfo.Protocol = 1
 				go hc.processMessages()
 				if err = hc.handshakeChannel(); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -943,6 +943,7 @@ func (hc *channelSession) processMessages() {`
`943`	`943`	`}`
`944`	`944`	`hc.c = con`
`945`	`945`	`hc.closed = make(chan interface{})`
	`946`	`+ hc.closeOnce = sync.Once{}`
`946`	`947`	`hc.nodeInfo.Protocol = 1`
`947`	`948`	`go hc.processMessages()`
`948`	`949`	`if err = hc.handshakeChannel(); err != nil {`