mirror of https://go.googlesource.com/go
103 lines
2.2 KiB
Go
103 lines
2.2 KiB
Go
// Copyright 2023 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.
|
|
|
|
//go:build wasip1
|
|
|
|
package net
|
|
|
|
import (
|
|
"os"
|
|
"syscall"
|
|
_ "unsafe" // for go:linkname
|
|
)
|
|
|
|
func fileListener(f *os.File) (Listener, error) {
|
|
filetype, err := fd_fdstat_get_type(f.PollFD().Sysfd)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
net, err := fileListenNet(filetype)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
pfd := f.PollFD().Copy()
|
|
fd := newPollFD(net, pfd)
|
|
if err := fd.init(); err != nil {
|
|
pfd.Close()
|
|
return nil, err
|
|
}
|
|
return newFileListener(fd), nil
|
|
}
|
|
|
|
func fileConn(f *os.File) (Conn, error) {
|
|
filetype, err := fd_fdstat_get_type(f.PollFD().Sysfd)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
net, err := fileConnNet(filetype)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
pfd := f.PollFD().Copy()
|
|
fd := newPollFD(net, pfd)
|
|
if err := fd.init(); err != nil {
|
|
pfd.Close()
|
|
return nil, err
|
|
}
|
|
return newFileConn(fd), nil
|
|
}
|
|
|
|
func filePacketConn(f *os.File) (PacketConn, error) {
|
|
return nil, syscall.ENOPROTOOPT
|
|
}
|
|
|
|
func fileListenNet(filetype syscall.Filetype) (string, error) {
|
|
switch filetype {
|
|
case syscall.FILETYPE_SOCKET_STREAM:
|
|
return "tcp", nil
|
|
case syscall.FILETYPE_SOCKET_DGRAM:
|
|
return "", syscall.EOPNOTSUPP
|
|
default:
|
|
return "", syscall.ENOTSOCK
|
|
}
|
|
}
|
|
|
|
func fileConnNet(filetype syscall.Filetype) (string, error) {
|
|
switch filetype {
|
|
case syscall.FILETYPE_SOCKET_STREAM:
|
|
return "tcp", nil
|
|
case syscall.FILETYPE_SOCKET_DGRAM:
|
|
return "udp", nil
|
|
default:
|
|
return "", syscall.ENOTSOCK
|
|
}
|
|
}
|
|
|
|
func newFileListener(fd *netFD) Listener {
|
|
switch fd.net {
|
|
case "tcp":
|
|
return &TCPListener{fd: fd}
|
|
default:
|
|
panic("unsupported network for file listener: " + fd.net)
|
|
}
|
|
}
|
|
|
|
func newFileConn(fd *netFD) Conn {
|
|
switch fd.net {
|
|
case "tcp":
|
|
return &TCPConn{conn{fd: fd}}
|
|
case "udp":
|
|
return &UDPConn{conn{fd: fd}}
|
|
default:
|
|
panic("unsupported network for file connection: " + fd.net)
|
|
}
|
|
}
|
|
|
|
// This helper is implemented in the syscall package. It means we don't have
|
|
// to redefine the fd_fdstat_get host import or the fdstat struct it
|
|
// populates.
|
|
//
|
|
//go:linkname fd_fdstat_get_type syscall.fd_fdstat_get_type
|
|
func fd_fdstat_get_type(fd int) (uint8, error)
|