mirror of
https://github.com/cwinfo/yggdrasil-go.git
synced 2024-11-26 07:11:40 +00:00
it helps to actually run the notifyQueued stuff...
This commit is contained in:
parent
052de98f12
commit
b132560f65
@ -281,6 +281,8 @@ func (p *peer) _sendPackets(packets [][]byte) {
|
|||||||
if p.idle {
|
if p.idle {
|
||||||
p.idle = false
|
p.idle = false
|
||||||
p._handleIdle()
|
p._handleIdle()
|
||||||
|
} else {
|
||||||
|
p.intf.notifyQueued(p.seq)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -296,6 +298,7 @@ func (p *peer) _handleIdle() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if len(packets) > 0 {
|
if len(packets) > 0 {
|
||||||
|
p.seq++
|
||||||
p.bytesSent += uint64(size)
|
p.bytesSent += uint64(size)
|
||||||
p.intf.out(packets)
|
p.intf.out(packets)
|
||||||
} else {
|
} else {
|
||||||
|
Loading…
Reference in New Issue
Block a user