From 75d4dd5de92d74bb2d43aecbdfdefae0ba23088b Mon Sep 17 00:00:00 2001 From: Shulhan Date: Fri, 6 Dec 2019 22:02:41 +0700 Subject: dns: remove unused isRunning on runTCPForwarder --- lib/dns/server.go | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) (limited to 'lib') diff --git a/lib/dns/server.go b/lib/dns/server.go index e37d74fe..ea510217 100644 --- a/lib/dns/server.go +++ b/lib/dns/server.go @@ -977,10 +977,7 @@ func (srv *Server) runTLSForwarder(nameserver string, primaryq, fallbackq chan * } func (srv *Server) runTCPForwarder(remoteAddr string, primaryq, fallbackq chan *request, tag string) { - var ( - isRunning = true - stopper = srv.newStopper() - ) + stopper := srv.newStopper() log.Printf("dns: starting forwarder %s for %s\n", tag, remoteAddr) @@ -988,12 +985,11 @@ func (srv *Server) runTCPForwarder(remoteAddr string, primaryq, fallbackq chan * srv.incForwarder() } - for isRunning { + for { select { case req, ok := <-primaryq: if !ok { log.Println("dns: primary queue has been closed") - isRunning = false goto out } if debug.Value >= 1 { @@ -1022,7 +1018,6 @@ func (srv *Server) runTCPForwarder(remoteAddr string, primaryq, fallbackq chan * srv.processResponse(req, res) case <-stopper: - isRunning = false goto out } } -- cgit v1.3-6-g1900