Remove unused message pool

3 files changed, 2 insertions, 33 deletions

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 <ms@kilabit.info>. 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
 	}