mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
parent
46ee06a85c
commit
b1aa962233
@ -21,6 +21,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net"
|
"net"
|
||||||
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -206,20 +207,62 @@ func checkCertSAN(ctx context.Context, cert *x509.Certificate, remoteAddr string
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if len(cert.DNSNames) > 0 {
|
if len(cert.DNSNames) > 0 {
|
||||||
for _, dns := range cert.DNSNames {
|
ok, err := isHostInDNS(ctx, h, cert.DNSNames)
|
||||||
|
if ok {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
errStr := ""
|
||||||
|
if err != nil {
|
||||||
|
errStr = " (" + err.Error() + ")"
|
||||||
|
}
|
||||||
|
return fmt.Errorf("tls: %q does not match any of DNSNames %q"+errStr, h, cert.DNSNames)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func isHostInDNS(ctx context.Context, host string, dnsNames []string) (ok bool, err error) {
|
||||||
|
// reverse lookup
|
||||||
|
wildcards, names := []string{}, []string{}
|
||||||
|
for _, dns := range dnsNames {
|
||||||
|
if strings.HasPrefix(dns, "*.") {
|
||||||
|
wildcards = append(wildcards, dns[1:])
|
||||||
|
} else {
|
||||||
|
names = append(names, dns)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
lnames, lerr := net.DefaultResolver.LookupAddr(ctx, host)
|
||||||
|
for _, name := range lnames {
|
||||||
|
// strip trailing '.' from PTR record
|
||||||
|
if name[len(name)-1] == '.' {
|
||||||
|
name = name[:len(name)-1]
|
||||||
|
}
|
||||||
|
for _, wc := range wildcards {
|
||||||
|
if strings.HasSuffix(name, wc) {
|
||||||
|
return true, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
for _, n := range names {
|
||||||
|
if n == name {
|
||||||
|
return true, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
err = lerr
|
||||||
|
|
||||||
|
// forward lookup
|
||||||
|
for _, dns := range names {
|
||||||
addrs, lerr := net.DefaultResolver.LookupHost(ctx, dns)
|
addrs, lerr := net.DefaultResolver.LookupHost(ctx, dns)
|
||||||
if lerr != nil {
|
if lerr != nil {
|
||||||
|
err = lerr
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
for _, addr := range addrs {
|
for _, addr := range addrs {
|
||||||
if addr == h {
|
if addr == host {
|
||||||
return nil
|
return true, nil
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return fmt.Errorf("tls: %q does not match any of DNSNames %q", h, cert.DNSNames)
|
return false, err
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *tlsListener) Close() error {
|
func (l *tlsListener) Close() error {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user