| // Copyright 2016 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. |
| |
| package net |
| |
| import ( |
| "context" |
| "io" |
| "os" |
| "syscall" |
| "syscall/zx/mxnet" |
| ) |
| |
| func (a *TCPAddr) encode() ([]byte, error) { // TODO remove |
| b := make([]byte, mxnet.SockaddrLen) |
| _, err := mxnet.EncodeSockaddr(b, mxnet.Addr(a.IP), uint16(a.Port), uint32(zoneCache.index(a.Zone))) |
| return b, err |
| } |
| |
| func (a *TCPAddr) family() int { |
| if a == nil || len(a.IP) <= IPv4len { |
| return syscall.AF_INET |
| } |
| if a.IP.To4() != nil { |
| return syscall.AF_INET |
| } |
| return syscall.AF_INET6 |
| } |
| |
| func (a *TCPAddr) sockaddr(family int) (addr mxnet.Addr, port uint16, zone uint32, err error) { |
| if a == nil { |
| return "", 0, 0, nil |
| } |
| return ipToSockaddr(family, a.IP, a.Port, a.Zone) |
| } |
| |
| func (c *TCPConn) readFrom(r io.Reader) (int64, error) { |
| return genericReadFrom(c, r) |
| } |
| |
| func (sd *sysDialer) dialTCP(ctx context.Context, laddr, raddr *TCPAddr) (*TCPConn, error) { |
| if testHookDialTCP != nil { |
| return testHookDialTCP(ctx, sd.network, laddr, raddr) |
| } |
| return sd.doDialTCP(ctx, laddr, raddr) |
| } |
| |
| func (sd *sysDialer) doDialTCP(ctx context.Context, laddr, raddr *TCPAddr) (*TCPConn, error) { |
| switch sd.network { |
| case "tcp", "tcp4", "tcp6": |
| default: |
| return nil, UnknownNetworkError(sd.network) |
| } |
| if raddr == nil { |
| return nil, errMissingAddress |
| } |
| fd, err := dialFuchsia(ctx, sd.network, laddr, raddr) |
| if err != nil { |
| return nil, err |
| } |
| return newTCPConn(fd), nil |
| } |
| |
| func (ln *TCPListener) ok() bool { return ln != nil && ln.fd != nil } |
| |
| func (ln *TCPListener) accept() (*TCPConn, error) { |
| fd, err := ln.fd.accept() |
| if err != nil { |
| return nil, err |
| } |
| return newTCPConn(fd), nil |
| } |
| |
| func (ln *TCPListener) close() error { return ln.fd.Close() } |
| |
| func (ln *TCPListener) file() (*os.File, error) { return ln.fd.dup() } |
| |
| func (sl *sysListener) listenTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) { |
| fd, err := dialFuchsia(ctx, sl.network, laddr, nil) |
| if err != nil { |
| return nil, err |
| } |
| return &TCPListener{fd}, nil |
| } |