hardening channel drain

This commit is contained in:
pascal
2026-05-21 17:40:45 +02:00
parent d3ae81e601
commit 12361e5479

View File

@@ -3285,7 +3285,10 @@ const peerUpdateTimeout = 5 * time.Second
func drainPeerUpdates(ch <-chan *network_map.UpdateMessage) {
for {
select {
case <-ch:
case _, ok := <-ch:
if !ok {
return
}
case <-time.After(200 * time.Millisecond):
return
}