From 2ca76cfea8a21617c475efa542e8657346580967 Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Tue, 17 May 2016 16:07:03 +1000 Subject: [PATCH] dht: Stop processing packet if server closes after unmarshalling --- dht/server.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dht/server.go b/dht/server.go index 630fc421..37a5cc6b 100644 --- a/dht/server.go +++ b/dht/server.go @@ -180,6 +180,9 @@ func (s *Server) processPacket(b []byte, addr Addr) { } s.mu.Lock() defer s.mu.Unlock() + if s.closed.IsSet() { + return + } if d.Y == "q" { readQuery.Add(1) s.handleQuery(addr, d) -- 2.48.1