aboutsummaryrefslogtreecommitdiff
path: root/cacheworker.go
diff options
context:
space:
mode:
authorShulhan <ms@kilabit.info>2018-11-30 08:53:31 +0700
committerShulhan <ms@kilabit.info>2018-11-30 08:53:31 +0700
commitda0218f4625b59a93fbeec68e6d2a8d7abf2bd39 (patch)
tree039a78458b45f2506ad63e2a5fccbcd2bc1e8ae1 /cacheworker.go
parentedc41b72b95c3f38ec5c5a0424693a7051175715 (diff)
downloadrescached-da0218f4625b59a93fbeec68e6d2a8d7abf2bd39.tar.xz
Remove unused message pool
Diffstat (limited to 'cacheworker.go')
-rw-r--r--cacheworker.go8
1 files changed, 2 insertions, 6 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)