Close METADAPT-A transaction channel
This commit is contained in:
parent
cbaff8b593
commit
8fe3ba8d4f
@ -109,6 +109,7 @@ func (this *a) sendMessageSafe(trans int64, method uint16, data []byte) error {
|
|||||||
func (this *a) receive() {
|
func (this *a) receive() {
|
||||||
defer func() {
|
defer func() {
|
||||||
this.underlying.Close()
|
this.underlying.Close()
|
||||||
|
close(this.transChan)
|
||||||
this.transLock.Lock()
|
this.transLock.Lock()
|
||||||
defer this.transLock.Unlock()
|
defer this.transLock.Unlock()
|
||||||
for _, trans := range this.transMap {
|
for _, trans := range this.transMap {
|
||||||
|
Loading…
Reference in New Issue
Block a user