From b834b1e362221b339f6d435c2c4036f0943975e1 Mon Sep 17 00:00:00 2001 From: Murtaza Aliakbar Date: Sat, 24 Aug 2024 04:21:03 +0530 Subject: [PATCH] udpmux: post drain() clear all routes --- intra/udpmux.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/intra/udpmux.go b/intra/udpmux.go index a110775a..e97d0c29 100644 --- a/intra/udpmux.go +++ b/intra/udpmux.go @@ -158,11 +158,12 @@ func (x *muxer) stop() error { func (x *muxer) drain() { x.rmu.Lock() defer x.rmu.Unlock() + + defer clear(x.routes) log.I("udp: mux: %s drain: closing %d demuxed conns", x.cid, len(x.routes)) for _, c := range x.routes { clos(c) // will unroute as well } - } // readers has to tasks: