aboutsummaryrefslogtreecommitdiff
path: root/lib/dns/server.go
diff options
context:
space:
mode:
authorShulhan <m.shulhan@gmail.com>2019-12-04 23:20:10 +0700
committerShulhan <m.shulhan@gmail.com>2019-12-04 23:59:13 +0700
commiteaf16a54fcb430885578c03e4e246af14966f033 (patch)
treee2c37cb8087aae79c20d7bde670df40e31299ad6 /lib/dns/server.go
parentce5fbf87e42d24ea95cd558150961623b9403c6e (diff)
downloadpakakeh.go-eaf16a54fcb430885578c03e4e246af14966f033.tar.xz
dns: remove the use of pointer on Message fields
Diffstat (limited to 'lib/dns/server.go')
-rw-r--r--lib/dns/server.go32
1 files changed, 18 insertions, 14 deletions
diff --git a/lib/dns/server.go b/lib/dns/server.go
index 000dea1f..e37d74fe 100644
--- a/lib/dns/server.go
+++ b/lib/dns/server.go
@@ -160,12 +160,12 @@ func isResponseValid(req *request, res *Message) bool {
}
if req.message.Question.Type != res.Question.Type {
log.Printf("dns: unmatched response type, got %s want %s\n",
- req.message.Question, res.Question)
+ req.message.Question.String(), res.Question.String())
return false
}
if req.message.Question.Class != res.Question.Class {
log.Printf("dns: unmatched response class, got %s want %s\n",
- req.message.Question, res.Question)
+ req.message.Question.String(), res.Question.String())
return false
}
@@ -688,7 +688,7 @@ func (srv *Server) processRequest() {
fmt.Printf("dns: < %s %d:%s\n",
connTypeNames[req.kind],
req.message.Header.ID,
- req.message.Question)
+ req.message.Question.String())
}
ans, an := srv.caches.get(string(req.message.Question.Name),
@@ -703,7 +703,7 @@ func (srv *Server) processRequest() {
fmt.Printf("dns: * %s %d:%s\n",
connTypeNames[req.kind],
req.message.Header.ID,
- req.message.Question)
+ req.message.Question.String())
}
req.error(RCodeErrServer)
}
@@ -716,7 +716,7 @@ func (srv *Server) processRequest() {
fmt.Printf("dns: ~ %s %d:%s\n",
connTypeNames[req.kind],
req.message.Header.ID,
- req.message.Question)
+ req.message.Question.String())
}
srv.primaryq <- req
} else {
@@ -724,7 +724,7 @@ func (srv *Server) processRequest() {
fmt.Printf("dns: * %s %d:%s\n",
connTypeNames[req.kind],
req.message.Header.ID,
- req.message.Question)
+ req.message.Question.String())
}
req.error(RCodeErrServer)
}
@@ -738,7 +738,7 @@ func (srv *Server) processRequest() {
if debug.Value >= 1 {
fmt.Printf("dns: > %s %d:%s\n",
connTypeNames[req.kind],
- res.Header.ID, res.Question)
+ res.Header.ID, res.Question.String())
}
_, err := req.writer.Write(res.Packet)
@@ -763,7 +763,7 @@ func (srv *Server) processResponse(req *request, res *Message) {
if res.Header.RCode != 0 {
log.Printf("dns: ! %s %s %d:%s\n",
connTypeNames[req.kind], rcodeNames[res.Header.RCode],
- res.Header.ID, res.Question)
+ res.Header.ID, res.Question.String())
return
}
@@ -774,11 +774,11 @@ func (srv *Server) processResponse(req *request, res *Message) {
if inserted {
fmt.Printf("dns: + %s %d:%s\n",
connTypeNames[req.kind],
- res.Header.ID, res.Question)
+ res.Header.ID, res.Question.String())
} else {
fmt.Printf("dns: # %s %d:%s\n",
connTypeNames[req.kind],
- res.Header.ID, res.Question)
+ res.Header.ID, res.Question.String())
}
}
}
@@ -872,7 +872,8 @@ func (srv *Server) runDohForwarder(nameserver string, primaryq, fallbackq chan *
if debug.Value >= 1 {
fmt.Printf("dns: ^ %s %s %d:%s\n",
tag, nameserver,
- req.message.Header.ID, req.message.Question)
+ req.message.Header.ID,
+ req.message.Question.String())
}
res, err = forwarder.Query(req.message)
@@ -943,7 +944,8 @@ func (srv *Server) runTLSForwarder(nameserver string, primaryq, fallbackq chan *
if debug.Value >= 1 {
fmt.Printf("dns: ^ %s %s %d:%s\n",
tag, nameserver,
- req.message.Header.ID, req.message.Question)
+ req.message.Header.ID,
+ req.message.Question.String())
}
res, err = forwarder.Query(req.message)
@@ -997,7 +999,8 @@ func (srv *Server) runTCPForwarder(remoteAddr string, primaryq, fallbackq chan *
if debug.Value >= 1 {
fmt.Printf("dns: ^ %s %s %d:%s\n",
tag, remoteAddr,
- req.message.Header.ID, req.message.Question)
+ req.message.Header.ID,
+ req.message.Question.String())
}
cl, err := NewTCPClient(remoteAddr)
@@ -1077,7 +1080,8 @@ func (srv *Server) runUDPForwarder(remoteAddr string, primaryq, fallbackq chan *
if debug.Value >= 1 {
fmt.Printf("dns: ^ %s %s %d:%s\n",
tag, remoteAddr,
- req.message.Header.ID, req.message.Question)
+ req.message.Header.ID,
+ req.message.Question.String())
}
res, err = forwarder.Query(req.message)