mirrors/yggdrasil-go
2
0
Fork 0
mirror of https://github.com/yggdrasil-network/yggdrasil-go synced 2024-11-10 07:20:39 +03:00
Code Issues Packages Projects Releases Wiki Activity

attempting to debug/fix a possible goroutine leak

Browse Source
This commit is contained in:
Arceliar 2020-11-25 02:44:13 -06:00
parent ea58a0f181
commit df1239b054
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/yggdrasil/link.go
View File

@ -460,9 +460,6 @@ func (intf *link) notifyStalled() {
// reset the close timer // reset the close timer
func (intf *link) notifyReading() { func (intf *link) notifyReading() {
intf.Act(&intf.reader, func() { intf.Act(&intf.reader, func() {
if intf.closeTimer != nil {
intf.closeTimer.Stop()
}
intf.closeTimer = time.AfterFunc(closeTime, func() { intf.msgIO.close() }) intf.closeTimer = time.AfterFunc(closeTime, func() { intf.msgIO.close() })
}) })
} }
@ -470,6 +467,7 @@ func (intf *link) notifyReading() {
// wake up the link if it was stalled, and (if size > 0) prepare to send keep-alive traffic // wake up the link if it was stalled, and (if size > 0) prepare to send keep-alive traffic
func (intf *link) notifyRead(size int) { func (intf *link) notifyRead(size int) {
intf.Act(&intf.reader, func() { intf.Act(&intf.reader, func() {
intf.closeTimer.Stop()
if intf.stallTimer != nil { if intf.stallTimer != nil {
intf.stallTimer.Stop() intf.stallTimer.Stop()
intf.stallTimer = nil intf.stallTimer = nil