benjamyn/any-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

streampool: close dial queue

Browse Source
This commit is contained in:
Sergey Cherepanov 2023-01-30 18:40:25 +03:00 committed by Mikhail Iudin
parent cf15052b76
commit 854d832c81
No known key found for this signature in database
GPG Key ID: FAAAA8BAABDFF1C0
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
net/streampool/streampool.go
View File

@ -332,6 +332,9 @@ func (s *streamPool) removeStream(streamId uint32) {
} }
func (s *streamPool) Close() (err error) { func (s *streamPool) Close() (err error) {
if e := s.dial.Close(); e != nil {
log.Warn("dial queue close error", zap.Error(e))
}
return s.exec.Close() return s.exec.Close()
} }