diff options
| author | Shulhan <m.shulhan@gmail.com> | 2019-12-06 22:02:41 +0700 |
|---|---|---|
| committer | Shulhan <m.shulhan@gmail.com> | 2019-12-07 00:58:06 +0700 |
| commit | 75d4dd5de92d74bb2d43aecbdfdefae0ba23088b (patch) | |
| tree | d783d34711b54ff2f5f362895312622c3deafd72 /lib/dns/server.go | |
| parent | 378c8e36a3011136792f2da637d85a99968504ae (diff) | |
| download | pakakeh.go-75d4dd5de92d74bb2d43aecbdfdefae0ba23088b.tar.xz | |
dns: remove unused isRunning on runTCPForwarder
Diffstat (limited to 'lib/dns/server.go')
| -rw-r--r-- | lib/dns/server.go | 9 |
1 files changed, 2 insertions, 7 deletions
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 } } |