// 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. // The net package provides a portable interface to Unix // networks sockets, including TCP/IP, UDP, domain name // resolution, and Unix domain sockets. package net // TODO(rsc): // support for raw IP sockets // support for raw ethernet sockets import "os" // Addr represents a network end point address. type Addr interface { Network() string // name of the network String() string // string form of address } // Conn is a generic stream-oriented network connection. type Conn interface { // Read reads data from the connection. // Read can be made to time out and return err == os.EAGAIN // after a fixed time limit; see SetTimeout and SetReadTimeout. Read(b []byte) (n int, err os.Error) // Write writes data to the connection. // Write can be made to time out and return err == os.EAGAIN // after a fixed time limit; see SetTimeout and SetReadTimeout. Write(b []byte) (n int, err os.Error) // Close closes the connection. Close() os.Error // LocalAddr returns the local network address. LocalAddr() Addr // RemoteAddr returns the remote network address. RemoteAddr() Addr // SetTimeout sets the read and write deadlines associated // with the connection. SetTimeout(nsec int64) os.Error // SetReadTimeout sets the time (in nanoseconds) that // Read will wait for data before returning os.EAGAIN. // Setting nsec == 0 (the default) disables the deadline. SetReadTimeout(nsec int64) os.Error // SetWriteTimeout sets the time (in nanoseconds) that // Write will wait to send its data before returning os.EAGAIN. // Setting nsec == 0 (the default) disables the deadline. // Even if write times out, it may return n > 0, indicating that // some of the data was successfully written. SetWriteTimeout(nsec int64) os.Error } // PacketConn is a generic packet-oriented network connection. type PacketConn interface { // ReadFrom reads a packet from the connection, // copying the payload into b. It returns the number of // bytes copied into b and the return address that // was on the packet. // ReadFrom can be made to time out and return err == os.EAGAIN // after a fixed time limit; see SetTimeout and SetReadTimeout. ReadFrom(b []byte) (n int, addr Addr, err os.Error) // WriteTo writes a packet with payload b to addr. // WriteTo can be made to time out and return err == os.EAGAIN // after a fixed time limit; see SetTimeout and SetWriteTimeout. // On packet-oriented connections, write timeouts are rare. WriteTo(b []byte, addr Addr) (n int, err os.Error) // Close closes the connection. Close() os.Error // LocalAddr returns the local network address. LocalAddr() Addr // SetTimeout sets the read and write deadlines associated // with the connection. SetTimeout(nsec int64) os.Error // SetReadTimeout sets the time (in nanoseconds) that // Read will wait for data before returning os.EAGAIN. // Setting nsec == 0 (the default) disables the deadline. SetReadTimeout(nsec int64) os.Error // SetWriteTimeout sets the time (in nanoseconds) that // Write will wait to send its data before returning os.EAGAIN. // Setting nsec == 0 (the default) disables the deadline. // Even if write times out, it may return n > 0, indicating that // some of the data was successfully written. SetWriteTimeout(nsec int64) os.Error } // A Listener is a generic network listener for stream-oriented protocols. // Accept waits for the next connection and Close closes the connection. type Listener interface { Accept() (c Conn, err os.Error) Close() os.Error Addr() Addr // Listener's network address } // Dial connects to the remote address raddr on the network net. // If the string laddr is not empty, it is used as the local address // for the connection. // // Known networks are "tcp", "tcp4" (IPv4-only), "tcp6" (IPv6-only), // "udp", "udp4" (IPv4-only), and "udp6" (IPv6-only). // // For IP networks, addresses have the form host:port. If host is // a literal IPv6 address, it must be enclosed in square brackets. // // Examples: // Dial("tcp", "", "12.34.56.78:80") // Dial("tcp", "", "google.com:80") // Dial("tcp", "", "[de:ad:be:ef::ca:fe]:80") // Dial("tcp", "127.0.0.1:123", "127.0.0.1:88") // func Dial(net, laddr, raddr string) (c Conn, err os.Error) { switch net { case "tcp", "tcp4", "tcp6": var la, ra *TCPAddr if laddr != "" { if la, err = ResolveTCPAddr(laddr); err != nil { goto Error } } if raddr != "" { if ra, err = ResolveTCPAddr(raddr); err != nil { goto Error } } return DialTCP(net, la, ra) case "udp", "udp4", "upd6": var la, ra *UDPAddr if laddr != "" { if la, err = ResolveUDPAddr(laddr); err != nil { goto Error } } if raddr != "" { if ra, err = ResolveUDPAddr(raddr); err != nil { goto Error } } return DialUDP(net, la, ra) case "unix", "unixgram": var la, ra *UnixAddr if raddr != "" { if ra, err = ResolveUnixAddr(net, raddr); err != nil { goto Error } } if laddr != "" { if la, err = ResolveUnixAddr(net, laddr); err != nil { goto Error } } return DialUnix(net, la, ra) } err = UnknownNetworkError(net) Error: return nil, &OpError{"dial", net + " " + raddr, nil, err} } // Listen announces on the local network address laddr. // The network string net must be a stream-oriented // network: "tcp", "tcp4", "tcp6", or "unix". func Listen(net, laddr string) (l Listener, err os.Error) { switch net { case "tcp", "tcp4", "tcp6": var la *TCPAddr if laddr != "" { if la, err = ResolveTCPAddr(laddr); err != nil { return nil, err } } l, err := ListenTCP(net, la) if err != nil { return nil, err } return l, nil case "unix": var la *UnixAddr if laddr != "" { if la, err = ResolveUnixAddr(net, laddr); err != nil { return nil, err } } l, err := ListenUnix(net, la) if err != nil { return nil, err } return l, nil } return nil, UnknownNetworkError(net) } // ListenPacket announces on the local network address laddr. // The network string net must be a packet-oriented network: // "udp", "udp4", "udp6", or "unixgram". func ListenPacket(net, laddr string) (c PacketConn, err os.Error) { switch net { case "udp", "udp4", "udp6": var la *UDPAddr if laddr != "" { if la, err = ResolveUDPAddr(laddr); err != nil { return nil, err } } c, err := ListenUDP(net, la) if err != nil { return nil, err } return c, nil case "unixgram": var la *UnixAddr if laddr != "" { if la, err = ResolveUnixAddr(net, laddr); err != nil { return nil, err } } c, err := DialUnix(net, la, nil) if err != nil { return nil, err } return c, nil } return nil, UnknownNetworkError(net) } var errMissingAddress = os.ErrorString("missing address") type OpError struct { Op string Net string Addr Addr Error os.Error } func (e *OpError) String() string { s := e.Op if e.Net != "" { s += " " + e.Net } if e.Addr != nil { s += " " + e.Addr.String() } s += ": " + e.Error.String() return s } type AddrError struct { Error string Addr string } func (e *AddrError) String() string { s := e.Error if e.Addr != "" { s += " " + e.Addr } return s } type UnknownNetworkError string func (e UnknownNetworkError) String() string { return "unknown network " + string(e) }