From da0218f4625b59a93fbeec68e6d2a8d7abf2bd39 Mon Sep 17 00:00:00 2001 From: Shulhan Date: Fri, 30 Nov 2018 08:53:31 +0700 Subject: Remove unused message pool --- cacheworker.go | 8 ++------ messagepool.go | 24 ------------------------ rescached.go | 3 --- 3 files changed, 2 insertions(+), 33 deletions(-) delete mode 100644 messagepool.go diff --git a/cacheworker.go b/cacheworker.go index c1553d5..d6c5376 100644 --- a/cacheworker.go +++ b/cacheworker.go @@ -48,10 +48,7 @@ func (cw *cacheWorker) start() { for { select { case msg := <-cw.addQueue: - added := cw.add(msg, false) - if !added { - freeMessage(msg) - } + _ = cw.add(msg, false) case res := <-cw.updateQueue: cw.update(res) @@ -114,8 +111,7 @@ func (cw *cacheWorker) add(msg *dns.Message, isLocal bool) bool { return true } - oldMsg := lres.update(res, msg) - freeMessage(oldMsg) + _ = lres.update(res, msg) if !isLocal { cw.cachesList.fix(res) diff --git a/messagepool.go b/messagepool.go deleted file mode 100644 index 194d721..0000000 --- a/messagepool.go +++ /dev/null @@ -1,24 +0,0 @@ -// Copyright 2018, Shulhan . All rights reserved. -// Use of this source code is governed by a BSD-style -// license that can be found in the LICENSE file. - -package rescached - -import ( - "sync" - - "github.com/shuLhan/share/lib/dns" -) - -var _messagePool = sync.Pool{ - New: func() interface{} { - return dns.NewMessage() - }, -} - -// -// freeMessage put the message back to the pool. -// -func freeMessage(msg *dns.Message) { - _messagePool.Put(msg) -} diff --git a/rescached.go b/rescached.go index 7201759..81eff3a 100644 --- a/rescached.go +++ b/rescached.go @@ -431,9 +431,6 @@ func (srv *Server) processForwardResponse(req *dns.Request, res *dns.Message) { } } if !ok { - if res != nil { - freeMessage(res) - } srv.freeRequests(req) return } -- cgit v1.3-6-g1900