2011-06-12 18:22:31 -06:00
|
|
|
// Copyright 2009 The Go Authors. All rights reserved.
|
|
|
|
// Use of this source code is governed by a BSD-style
|
|
|
|
// license that can be found in the LICENSE file.
|
|
|
|
|
all: merge NaCl branch (part 1)
See golang.org/s/go13nacl for design overview.
This CL is the mostly mechanical changes from rsc's Go 1.2 based NaCl branch, specifically 39cb35750369 to 500771b477cf from https://code.google.com/r/rsc-go13nacl. This CL does not include working NaCl support, there are probably two or three more large merges to come.
CL 15750044 is not included as it involves more invasive changes to the linker which will need to be merged separately.
The exact change lists included are
15050047: syscall: support for Native Client
15360044: syscall: unzip implementation for Native Client
15370044: syscall: Native Client SRPC implementation
15400047: cmd/dist, cmd/go, go/build, test: support for Native Client
15410048: runtime: support for Native Client
15410049: syscall: file descriptor table for Native Client
15410050: syscall: in-memory file system for Native Client
15440048: all: update +build lines for Native Client port
15540045: cmd/6g, cmd/8g, cmd/gc: support for Native Client
15570045: os: support for Native Client
15680044: crypto/..., hash/crc32, reflect, sync/atomic: support for amd64p32
15690044: net: support for Native Client
15690048: runtime: support for fake time like on Go Playground
15690051: build: disable various tests on Native Client
LGTM=rsc
R=rsc
CC=golang-codereviews
https://golang.org/cl/68150047
2014-02-25 07:47:42 -07:00
|
|
|
// +build darwin dragonfly freebsd linux nacl netbsd openbsd solaris
|
build: add build comments to core packages
The go/build package already recognizes
system-specific file names like
mycode_darwin.go
mycode_darwin_386.go
mycode_386.s
However, it is also common to write files that
apply to multiple architectures, so a recent CL added
to go/build the ability to process comments
listing a set of conditions for building. For example:
// +build darwin freebsd openbsd/386
says that this file should be compiled only on
OS X, FreeBSD, or 32-bit x86 OpenBSD systems.
These conventions are not yet documented
(hence this long CL description).
This CL adds build comments to the multi-system
files in the core library, a step toward making it
possible to use go/build to build them.
With this change go/build can handle crypto/rand,
exec, net, path/filepath, os/user, and time.
os and syscall need additional adjustments.
R=golang-dev, r, gri, r, gustavo
CC=golang-dev
https://golang.org/cl/5011046
2011-09-15 14:48:57 -06:00
|
|
|
|
2011-06-12 18:22:31 -06:00
|
|
|
// DNS client: see RFC 1035.
|
|
|
|
// Has to be linked into package net for Dial.
|
|
|
|
|
|
|
|
// TODO(rsc):
|
|
|
|
// Check periodically whether /etc/resolv.conf has changed.
|
|
|
|
// Could potentially handle many outstanding lookups faster.
|
|
|
|
// Could have a small cache.
|
|
|
|
// Random UDP source port (net.Dial should do that for us).
|
|
|
|
// Random request IDs.
|
|
|
|
|
|
|
|
package net
|
|
|
|
|
|
|
|
import (
|
2013-08-13 10:44:12 -06:00
|
|
|
"io"
|
2011-11-08 16:41:54 -07:00
|
|
|
"math/rand"
|
2011-06-12 18:22:31 -06:00
|
|
|
"sync"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
|
|
|
// Send a request on the connection and hope for a reply.
|
|
|
|
// Up to cfg.attempts attempts.
|
2011-11-01 20:05:34 -06:00
|
|
|
func exchange(cfg *dnsConfig, c Conn, name string, qtype uint16) (*dnsMsg, error) {
|
2013-08-14 14:08:08 -06:00
|
|
|
_, useTCP := c.(*TCPConn)
|
2011-06-12 18:22:31 -06:00
|
|
|
if len(name) >= 256 {
|
2011-11-01 20:05:34 -06:00
|
|
|
return nil, &DNSError{Err: "name too long", Name: name}
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
|
|
|
out := new(dnsMsg)
|
2011-11-30 10:01:46 -07:00
|
|
|
out.id = uint16(rand.Int()) ^ uint16(time.Now().UnixNano())
|
2011-06-12 18:22:31 -06:00
|
|
|
out.question = []dnsQuestion{
|
|
|
|
{name, qtype, dnsClassINET},
|
|
|
|
}
|
|
|
|
out.recursion_desired = true
|
|
|
|
msg, ok := out.Pack()
|
|
|
|
if !ok {
|
2011-11-01 20:05:34 -06:00
|
|
|
return nil, &DNSError{Err: "internal error - cannot pack message", Name: name}
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
2013-08-13 10:44:12 -06:00
|
|
|
if useTCP {
|
|
|
|
mlen := uint16(len(msg))
|
|
|
|
msg = append([]byte{byte(mlen >> 8), byte(mlen)}, msg...)
|
|
|
|
}
|
2011-06-12 18:22:31 -06:00
|
|
|
for attempt := 0; attempt < cfg.attempts; attempt++ {
|
|
|
|
n, err := c.Write(msg)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2012-01-18 17:24:06 -07:00
|
|
|
if cfg.timeout == 0 {
|
2013-07-22 19:13:58 -06:00
|
|
|
c.SetReadDeadline(noDeadline)
|
2012-01-18 17:24:06 -07:00
|
|
|
} else {
|
|
|
|
c.SetReadDeadline(time.Now().Add(time.Duration(cfg.timeout) * time.Second))
|
|
|
|
}
|
2013-08-13 10:44:12 -06:00
|
|
|
buf := make([]byte, 2000)
|
|
|
|
if useTCP {
|
|
|
|
n, err = io.ReadFull(c, buf[:2])
|
|
|
|
if err != nil {
|
|
|
|
if e, ok := err.(Error); ok && e.Timeout() {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
2013-08-14 14:08:08 -06:00
|
|
|
mlen := int(buf[0])<<8 | int(buf[1])
|
|
|
|
if mlen > len(buf) {
|
|
|
|
buf = make([]byte, mlen)
|
|
|
|
}
|
|
|
|
n, err = io.ReadFull(c, buf[:mlen])
|
2013-08-13 10:44:12 -06:00
|
|
|
} else {
|
|
|
|
n, err = c.Read(buf)
|
|
|
|
}
|
2011-06-12 18:22:31 -06:00
|
|
|
if err != nil {
|
|
|
|
if e, ok := err.(Error); ok && e.Timeout() {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
return nil, err
|
|
|
|
}
|
2013-08-14 14:08:08 -06:00
|
|
|
buf = buf[:n]
|
2011-06-12 18:22:31 -06:00
|
|
|
in := new(dnsMsg)
|
|
|
|
if !in.Unpack(buf) || in.id != out.id {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
return in, nil
|
|
|
|
}
|
|
|
|
var server string
|
|
|
|
if a := c.RemoteAddr(); a != nil {
|
|
|
|
server = a.String()
|
|
|
|
}
|
2011-11-01 20:05:34 -06:00
|
|
|
return nil, &DNSError{Err: "no answer from server", Name: name, Server: server, IsTimeout: true}
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
|
|
|
|
|
|
|
// Do a lookup for a single name, which must be rooted
|
|
|
|
// (otherwise answer will not find the answers).
|
2011-11-01 20:05:34 -06:00
|
|
|
func tryOneName(cfg *dnsConfig, name string, qtype uint16) (cname string, addrs []dnsRR, err error) {
|
2011-06-12 18:22:31 -06:00
|
|
|
if len(cfg.servers) == 0 {
|
2011-11-01 20:05:34 -06:00
|
|
|
return "", nil, &DNSError{Err: "no DNS servers", Name: name}
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
|
|
|
for i := 0; i < len(cfg.servers); i++ {
|
|
|
|
// Calling Dial here is scary -- we have to be sure
|
|
|
|
// not to dial a name that will require a DNS lookup,
|
|
|
|
// or Dial will call back here to translate it.
|
|
|
|
// The DNS config parser has already checked that
|
|
|
|
// all the cfg.servers[i] are IP addresses, which
|
|
|
|
// Dial will use without a DNS lookup.
|
|
|
|
server := cfg.servers[i] + ":53"
|
|
|
|
c, cerr := Dial("udp", server)
|
|
|
|
if cerr != nil {
|
|
|
|
err = cerr
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
msg, merr := exchange(cfg, c, name, qtype)
|
|
|
|
c.Close()
|
|
|
|
if merr != nil {
|
|
|
|
err = merr
|
|
|
|
continue
|
|
|
|
}
|
2013-08-13 10:44:12 -06:00
|
|
|
if msg.truncated { // see RFC 5966
|
|
|
|
c, cerr = Dial("tcp", server)
|
|
|
|
if cerr != nil {
|
|
|
|
err = cerr
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
msg, merr = exchange(cfg, c, name, qtype)
|
|
|
|
c.Close()
|
|
|
|
if merr != nil {
|
|
|
|
err = merr
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
2011-06-12 18:22:31 -06:00
|
|
|
cname, addrs, err = answer(name, server, msg, qtype)
|
2011-11-01 20:05:34 -06:00
|
|
|
if err == nil || err.(*DNSError).Err == noSuchHost {
|
2011-06-12 18:22:31 -06:00
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
func convertRR_A(records []dnsRR) []IP {
|
|
|
|
addrs := make([]IP, len(records))
|
|
|
|
for i, rr := range records {
|
|
|
|
a := rr.(*dnsRR_A).A
|
|
|
|
addrs[i] = IPv4(byte(a>>24), byte(a>>16), byte(a>>8), byte(a))
|
|
|
|
}
|
|
|
|
return addrs
|
|
|
|
}
|
|
|
|
|
|
|
|
func convertRR_AAAA(records []dnsRR) []IP {
|
|
|
|
addrs := make([]IP, len(records))
|
|
|
|
for i, rr := range records {
|
2011-08-24 11:59:33 -06:00
|
|
|
a := make(IP, IPv6len)
|
2011-06-12 18:22:31 -06:00
|
|
|
copy(a, rr.(*dnsRR_AAAA).AAAA[:])
|
|
|
|
addrs[i] = a
|
|
|
|
}
|
|
|
|
return addrs
|
|
|
|
}
|
|
|
|
|
|
|
|
var cfg *dnsConfig
|
2011-11-01 20:05:34 -06:00
|
|
|
var dnserr error
|
2011-06-12 18:22:31 -06:00
|
|
|
|
2013-12-18 09:26:36 -07:00
|
|
|
// Assume dns config file is /etc/resolv.conf here
|
|
|
|
func loadConfig() { cfg, dnserr = dnsReadConfig("/etc/resolv.conf") }
|
2011-06-12 18:22:31 -06:00
|
|
|
|
|
|
|
var onceLoadConfig sync.Once
|
|
|
|
|
2011-11-01 20:05:34 -06:00
|
|
|
func lookup(name string, qtype uint16) (cname string, addrs []dnsRR, err error) {
|
2011-06-12 18:22:31 -06:00
|
|
|
if !isDomainName(name) {
|
2011-11-01 20:05:34 -06:00
|
|
|
return name, nil, &DNSError{Err: "invalid domain name", Name: name}
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
|
|
|
onceLoadConfig.Do(loadConfig)
|
|
|
|
if dnserr != nil || cfg == nil {
|
|
|
|
err = dnserr
|
|
|
|
return
|
|
|
|
}
|
|
|
|
// If name is rooted (trailing dot) or has enough dots,
|
|
|
|
// try it by itself first.
|
|
|
|
rooted := len(name) > 0 && name[len(name)-1] == '.'
|
|
|
|
if rooted || count(name, '.') >= cfg.ndots {
|
|
|
|
rname := name
|
|
|
|
if !rooted {
|
|
|
|
rname += "."
|
|
|
|
}
|
|
|
|
// Can try as ordinary name.
|
|
|
|
cname, addrs, err = tryOneName(cfg, rname, qtype)
|
|
|
|
if err == nil {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if rooted {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
// Otherwise, try suffixes.
|
|
|
|
for i := 0; i < len(cfg.search); i++ {
|
|
|
|
rname := name + "." + cfg.search[i]
|
|
|
|
if rname[len(rname)-1] != '.' {
|
|
|
|
rname += "."
|
|
|
|
}
|
|
|
|
cname, addrs, err = tryOneName(cfg, rname, qtype)
|
|
|
|
if err == nil {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Last ditch effort: try unsuffixed.
|
|
|
|
rname := name
|
|
|
|
if !rooted {
|
|
|
|
rname += "."
|
|
|
|
}
|
|
|
|
cname, addrs, err = tryOneName(cfg, rname, qtype)
|
|
|
|
if err == nil {
|
|
|
|
return
|
|
|
|
}
|
2013-10-02 20:09:54 -06:00
|
|
|
if e, ok := err.(*DNSError); ok {
|
|
|
|
// Show original name passed to lookup, not suffixed one.
|
|
|
|
// In general we might have tried many suffixes; showing
|
|
|
|
// just one is misleading. See also golang.org/issue/6324.
|
|
|
|
e.Name = name
|
|
|
|
}
|
2011-06-12 18:22:31 -06:00
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
// goLookupHost is the native Go implementation of LookupHost.
|
|
|
|
// Used only if cgoLookupHost refuses to handle the request
|
|
|
|
// (that is, only if cgoLookupHost is the stub in cgo_stub.go).
|
|
|
|
// Normally we let cgo use the C library resolver instead of
|
|
|
|
// depending on our lookup code, so that Go and C get the same
|
|
|
|
// answers.
|
2011-11-01 20:05:34 -06:00
|
|
|
func goLookupHost(name string) (addrs []string, err error) {
|
2011-06-12 18:22:31 -06:00
|
|
|
// Use entries from /etc/hosts if they match.
|
|
|
|
addrs = lookupStaticHost(name)
|
|
|
|
if len(addrs) > 0 {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
onceLoadConfig.Do(loadConfig)
|
|
|
|
if dnserr != nil || cfg == nil {
|
|
|
|
err = dnserr
|
|
|
|
return
|
|
|
|
}
|
|
|
|
ips, err := goLookupIP(name)
|
|
|
|
if err != nil {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
addrs = make([]string, 0, len(ips))
|
|
|
|
for _, ip := range ips {
|
|
|
|
addrs = append(addrs, ip.String())
|
|
|
|
}
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
// goLookupIP is the native Go implementation of LookupIP.
|
|
|
|
// Used only if cgoLookupIP refuses to handle the request
|
|
|
|
// (that is, only if cgoLookupIP is the stub in cgo_stub.go).
|
|
|
|
// Normally we let cgo use the C library resolver instead of
|
|
|
|
// depending on our lookup code, so that Go and C get the same
|
|
|
|
// answers.
|
2011-11-01 20:05:34 -06:00
|
|
|
func goLookupIP(name string) (addrs []IP, err error) {
|
2011-09-19 09:50:31 -06:00
|
|
|
// Use entries from /etc/hosts if possible.
|
|
|
|
haddrs := lookupStaticHost(name)
|
|
|
|
if len(haddrs) > 0 {
|
|
|
|
for _, haddr := range haddrs {
|
|
|
|
if ip := ParseIP(haddr); ip != nil {
|
|
|
|
addrs = append(addrs, ip)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if len(addrs) > 0 {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
2011-06-12 18:22:31 -06:00
|
|
|
onceLoadConfig.Do(loadConfig)
|
|
|
|
if dnserr != nil || cfg == nil {
|
|
|
|
err = dnserr
|
|
|
|
return
|
|
|
|
}
|
|
|
|
var records []dnsRR
|
|
|
|
var cname string
|
2012-06-25 15:32:39 -06:00
|
|
|
var err4, err6 error
|
|
|
|
cname, records, err4 = lookup(name, dnsTypeA)
|
2011-06-12 18:22:31 -06:00
|
|
|
addrs = convertRR_A(records)
|
|
|
|
if cname != "" {
|
|
|
|
name = cname
|
|
|
|
}
|
2012-06-25 15:32:39 -06:00
|
|
|
_, records, err6 = lookup(name, dnsTypeAAAA)
|
|
|
|
if err4 != nil && err6 == nil {
|
|
|
|
// Ignore A error because AAAA lookup succeeded.
|
|
|
|
err4 = nil
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
2012-06-25 15:32:39 -06:00
|
|
|
if err6 != nil && len(addrs) > 0 {
|
|
|
|
// Ignore AAAA error because A lookup succeeded.
|
|
|
|
err6 = nil
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
2012-06-25 15:32:39 -06:00
|
|
|
if err4 != nil {
|
|
|
|
return nil, err4
|
|
|
|
}
|
|
|
|
if err6 != nil {
|
|
|
|
return nil, err6
|
|
|
|
}
|
|
|
|
|
2011-06-12 18:22:31 -06:00
|
|
|
addrs = append(addrs, convertRR_AAAA(records)...)
|
2012-06-25 15:32:39 -06:00
|
|
|
return addrs, nil
|
2011-06-12 18:22:31 -06:00
|
|
|
}
|
|
|
|
|
|
|
|
// goLookupCNAME is the native Go implementation of LookupCNAME.
|
|
|
|
// Used only if cgoLookupCNAME refuses to handle the request
|
|
|
|
// (that is, only if cgoLookupCNAME is the stub in cgo_stub.go).
|
|
|
|
// Normally we let cgo use the C library resolver instead of
|
|
|
|
// depending on our lookup code, so that Go and C get the same
|
|
|
|
// answers.
|
2011-11-01 20:05:34 -06:00
|
|
|
func goLookupCNAME(name string) (cname string, err error) {
|
2011-06-12 18:22:31 -06:00
|
|
|
onceLoadConfig.Do(loadConfig)
|
|
|
|
if dnserr != nil || cfg == nil {
|
|
|
|
err = dnserr
|
|
|
|
return
|
|
|
|
}
|
|
|
|
_, rr, err := lookup(name, dnsTypeCNAME)
|
|
|
|
if err != nil {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
cname = rr[0].(*dnsRR_CNAME).Cname
|
|
|
|
return
|
|
|
|
}
|