udpmux: post drain() clear all routes

celzero · Aug 23, 2024 · b834b1e · b834b1e · ignoramous · Aug 23, 2024
1 parent a0ad8a0
commit b834b1e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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: