1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
// SPDX-License-Identifier: GPL-3.0-or-later
package dnsquery
import (
"math/rand"
"net"
"strconv"
"sync"
"time"
"github.com/miekg/dns"
)
func (d *DNSQuery) collect() (map[string]int64, error) {
if d.dnsClient == nil {
d.dnsClient = d.newDNSClient(d.Network, d.Timeout.Duration())
}
mx := make(map[string]int64)
domain := randomDomain(d.Domains)
d.Debugf("current domain : %s", domain)
var wg sync.WaitGroup
var mux sync.RWMutex
for _, srv := range d.Servers {
for rtypeName, rtype := range d.recordTypes {
wg.Add(1)
go func(srv, rtypeName string, rtype uint16, wg *sync.WaitGroup) {
defer wg.Done()
msg := new(dns.Msg)
msg.SetQuestion(dns.Fqdn(domain), rtype)
address := net.JoinHostPort(srv, strconv.Itoa(d.Port))
resp, rtt, err := d.dnsClient.Exchange(msg, address)
mux.Lock()
defer mux.Unlock()
px := "server_" + srv + "_record_" + rtypeName + "_"
mx[px+"query_status_success"] = 0
mx[px+"query_status_network_error"] = 0
mx[px+"query_status_dns_error"] = 0
if err != nil {
d.Debugf("error on querying %s after %s query for %s : %s", srv, rtypeName, domain, err)
mx[px+"query_status_network_error"] = 1
return
}
if resp != nil && resp.Rcode != dns.RcodeSuccess {
d.Debugf("invalid answer from %s after %s query for %s (rcode %d)", srv, rtypeName, domain, resp.Rcode)
mx[px+"query_status_dns_error"] = 1
} else {
mx[px+"query_status_success"] = 1
}
mx["server_"+srv+"_record_"+rtypeName+"_query_time"] = rtt.Nanoseconds()
}(srv, rtypeName, rtype, &wg)
}
}
wg.Wait()
return mx, nil
}
func randomDomain(domains []string) string {
src := rand.NewSource(time.Now().UnixNano())
r := rand.New(src)
return domains[r.Intn(len(domains))]
}
|
