Quick fix thread unsafe dispatcher

shawn1m · Mar 6, 2019 · 78c0ace · 78c0ace
1 parent 058f993
commit 78c0ace
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/core/inbound/server.go b/core/inbound/server.go
@@ -123,8 +123,9 @@ func (s *Server) Run() {
 func (s *Server) ServeDNS(w dns.ResponseWriter, q *dns.Msg) {
 
 	inboundIP, _, _ := net.SplitHostPort(w.RemoteAddr().String())
-	s.dispatcher.InboundIP = inboundIP
-	s.dispatcher.QuestionMessage = q
+	currentDispatcher := s.dispatcher
+	currentDispatcher.InboundIP = inboundIP
+	currentDispatcher.QuestionMessage = q
 
 	log.Debug("Question from " + inboundIP + ": " + q.Question[0].String())
 
@@ -134,7 +135,7 @@ func (s *Server) ServeDNS(w dns.ResponseWriter, q *dns.Msg) {
 		}
 	}
 
-	responseMessage := s.dispatcher.Exchange()
+	responseMessage := currentDispatcher.Exchange()
 
 	if responseMessage == nil {
 		return