Fix for UDP

Author: chriso

dial_wasip1.go

@@ -32,7 +32,10 @@ func DialContext(ctx context.Context, network, address string) (Conn, error) {
 }
 
 func dialAddr(addr net.Addr) (Conn, error) {
-	fd, err := syscall.Socket(family(addr), socketType(addr), 0)
+	proto := family(addr)
+	sotype := socketType(addr)
+
+	fd, err := syscall.Socket(proto, sotype, 0)
 	if err != nil {
 		return nil, err
 	}
@@ -42,6 +45,13 @@ func dialAddr(addr net.Addr) (Conn, error) {
 		return nil, fmt.Errorf("SetNonblock: %w", err)
 	}
 
+	if sotype == syscall.SOCK_DGRAM && proto != syscall.AF_UNIX {
+		if err := syscall.SetsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_BROADCAST, 1); err != nil {
+			syscall.Close(fd)
+			return nil, err
+		}
+	}
+
 	var inProgress bool
 	switch err := syscall.Connect(fd, socketAddress(addr)); err {
 	case nil:
@@ -102,7 +112,7 @@ func family(addr net.Addr) int {
 	var ip net.IP
 	switch a := addr.(type) {
 	case *net.UnixAddr:
-		panic("not implemented")
+		return syscall.AF_UNIX
 	case *net.TCPAddr:
 		ip = a.IP
 	case *net.UDPAddr:
@@ -136,7 +146,7 @@ func socketAddress(addr net.Addr) syscall.Sockaddr {
 	var port int
 	switch a := addr.(type) {
 	case *net.UnixAddr:
-		panic("not implemented")
+		return &syscall.SockaddrUnix{Name: a.Name}
 	case *net.TCPAddr:
 		ip, port = a.IP, a.Port
 	case *net.UDPAddr:

lookup_wasip1.go

@@ -7,7 +7,8 @@ import (
 
 func lookupAddr(context, network, address string) (net.Addr, error) {
 	switch network {
-	case "tcp", "tcp4", "tcp6", "udp", "udp4", "udp6":
+	case "tcp", "tcp4", "tcp6":
+	case "udp", "udp4", "udp6":
 	case "unix", "unixgram":
 		return &net.UnixAddr{Name: address, Net: network}, nil
 	default:
@@ -50,5 +51,19 @@ func lookupAddr(context, network, address string) (net.Addr, error) {
 			}
 		}
 	}
-	return nil, fmt.Errorf("no route to host: %v", host)
+	if network == "udp" || network == "udp4" {
+		for _, ip := range ips {
+			if len(ip) == net.IPv4len {
+				return &net.UDPAddr{IP: ip, Port: port}, nil
+			}
+		}
+	}
+	if network == "udp" || network == "udp6" {
+		for _, ip := range ips {
+			if len(ip) == net.IPv6len {
+				return &net.UDPAddr{IP: ip, Port: port}, nil
+			}
+		}
+	}
+	return nil, fmt.Errorf("cannot listen on %q", host)
 }

syscall/net_wasip1.go

@@ -13,6 +13,7 @@ const (
 	_ = iota
 	AF_INET
 	AF_INET6
+	AF_UNIX
 )
 
 const (
@@ -29,6 +30,8 @@ const (
 	SO_REUSEADDR = iota
 	_
 	SO_ERROR
+	_
+	SO_BROADCAST
 )
 
 type Sockaddr interface {