dht: Stop processing packet if server closes after unmarshalling

diff --git a/dht/server.go b/dht/server.go
index 630fc421f6f883e78c805f42862f26de610cab41..37a5cc6bc34b0480e2bdeb65a0bfb534489008d3 100644 (file)
--- 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)