| // 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. |
| |
| package net |
| |
| import ( |
| "os" |
| "syscall" |
| "time" |
| ) |
| |
| // UnixConn is an implementation of the Conn interface for connections |
| // to Unix domain sockets. |
| type UnixConn struct { |
| conn |
| } |
| |
| // ReadFromUnix reads a packet from c, copying the payload into b. It |
| // returns the number of bytes copied into b and the source address of |
| // the packet. |
| // |
| // ReadFromUnix can be made to time out and return an error with |
| // Timeout() == true after a fixed time limit; see SetDeadline and |
| // SetReadDeadline. |
| func (c *UnixConn) ReadFromUnix(b []byte) (int, *UnixAddr, error) { |
| return 0, nil, &OpError{Op: "read", Net: c.fd.dir, Source: c.fd.laddr, Addr: c.fd.raddr, Err: syscall.EPLAN9} |
| } |
| |
| // ReadFrom implements the PacketConn ReadFrom method. |
| func (c *UnixConn) ReadFrom(b []byte) (int, Addr, error) { |
| return 0, nil, &OpError{Op: "read", Net: c.fd.dir, Source: c.fd.laddr, Addr: c.fd.raddr, Err: syscall.EPLAN9} |
| } |
| |
| // ReadMsgUnix reads a packet from c, copying the payload into b and |
| // the associated out-of-band data into oob. It returns the number of |
| // bytes copied into b, the number of bytes copied into oob, the flags |
| // that were set on the packet, and the source address of the packet. |
| func (c *UnixConn) ReadMsgUnix(b, oob []byte) (n, oobn, flags int, addr *UnixAddr, err error) { |
| return 0, 0, 0, nil, &OpError{Op: "read", Net: c.fd.dir, Source: c.fd.laddr, Addr: c.fd.raddr, Err: syscall.EPLAN9} |
| } |
| |
| // WriteToUnix writes a packet to addr via c, copying the payload from b. |
| // |
| // WriteToUnix can be made to time out and return an error with |
| // Timeout() == true after a fixed time limit; see SetDeadline and |
| // SetWriteDeadline. On packet-oriented connections, write timeouts |
| // are rare. |
| func (c *UnixConn) WriteToUnix(b []byte, addr *UnixAddr) (int, error) { |
| return 0, &OpError{Op: "write", Net: c.fd.dir, Source: c.fd.laddr, Addr: addr.opAddr(), Err: syscall.EPLAN9} |
| } |
| |
| // WriteTo implements the PacketConn WriteTo method. |
| func (c *UnixConn) WriteTo(b []byte, addr Addr) (int, error) { |
| return 0, &OpError{Op: "write", Net: c.fd.dir, Source: c.fd.laddr, Addr: addr, Err: syscall.EPLAN9} |
| } |
| |
| // WriteMsgUnix writes a packet to addr via c, copying the payload |
| // from b and the associated out-of-band data from oob. It returns |
| // the number of payload and out-of-band bytes written. |
| func (c *UnixConn) WriteMsgUnix(b, oob []byte, addr *UnixAddr) (n, oobn int, err error) { |
| return 0, 0, &OpError{Op: "write", Net: c.fd.dir, Source: c.fd.laddr, Addr: addr.opAddr(), Err: syscall.EPLAN9} |
| } |
| |
| // CloseRead shuts down the reading side of the Unix domain connection. |
| // Most callers should just use Close. |
| func (c *UnixConn) CloseRead() error { |
| return &OpError{Op: "close", Net: c.fd.dir, Source: c.fd.laddr, Addr: c.fd.raddr, Err: syscall.EPLAN9} |
| } |
| |
| // CloseWrite shuts down the writing side of the Unix domain connection. |
| // Most callers should just use Close. |
| func (c *UnixConn) CloseWrite() error { |
| return &OpError{Op: "close", Net: c.fd.dir, Source: c.fd.laddr, Addr: c.fd.raddr, Err: syscall.EPLAN9} |
| } |
| |
| // DialUnix connects to the remote address raddr on the network net, |
| // which must be "unix", "unixgram" or "unixpacket". If laddr is not |
| // nil, it is used as the local address for the connection. |
| func DialUnix(net string, laddr, raddr *UnixAddr) (*UnixConn, error) { |
| return dialUnix(net, laddr, raddr, noDeadline) |
| } |
| |
| func dialUnix(net string, laddr, raddr *UnixAddr, deadline time.Time) (*UnixConn, error) { |
| return nil, &OpError{Op: "dial", Net: net, Source: laddr.opAddr(), Addr: raddr.opAddr(), Err: syscall.EPLAN9} |
| } |
| |
| // UnixListener is a Unix domain socket listener. Clients should |
| // typically use variables of type Listener instead of assuming Unix |
| // domain sockets. |
| type UnixListener struct { |
| fd *netFD |
| } |
| |
| // ListenUnix announces on the Unix domain socket laddr and returns a |
| // Unix listener. The network net must be "unix" or "unixpacket". |
| func ListenUnix(net string, laddr *UnixAddr) (*UnixListener, error) { |
| return nil, &OpError{Op: "listen", Net: net, Source: nil, Addr: laddr.opAddr(), Err: syscall.EPLAN9} |
| } |
| |
| // AcceptUnix accepts the next incoming call and returns the new |
| // connection. |
| func (l *UnixListener) AcceptUnix() (*UnixConn, error) { |
| return nil, &OpError{Op: "accept", Net: l.fd.dir, Source: nil, Addr: l.fd.laddr, Err: syscall.EPLAN9} |
| } |
| |
| // Accept implements the Accept method in the Listener interface; it |
| // waits for the next call and returns a generic Conn. |
| func (l *UnixListener) Accept() (Conn, error) { |
| return nil, &OpError{Op: "accept", Net: l.fd.dir, Source: nil, Addr: l.fd.laddr, Err: syscall.EPLAN9} |
| } |
| |
| // Close stops listening on the Unix address. Already accepted |
| // connections are not closed. |
| func (l *UnixListener) Close() error { |
| return &OpError{Op: "close", Net: l.fd.dir, Source: nil, Addr: l.fd.laddr, Err: syscall.EPLAN9} |
| } |
| |
| // Addr returns the listener's network address. |
| // The Addr returned is shared by all invocations of Addr, so |
| // do not modify it. |
| func (l *UnixListener) Addr() Addr { return nil } |
| |
| // SetDeadline sets the deadline associated with the listener. |
| // A zero time value disables the deadline. |
| func (l *UnixListener) SetDeadline(t time.Time) error { |
| return &OpError{Op: "set", Net: l.fd.dir, Source: nil, Addr: l.fd.laddr, Err: syscall.EPLAN9} |
| } |
| |
| // File returns a copy of the underlying os.File, set to blocking |
| // mode. It is the caller's responsibility to close f when finished. |
| // Closing l does not affect f, and closing f does not affect l. |
| // |
| // The returned os.File's file descriptor is different from the |
| // connection's. Attempting to change properties of the original |
| // using this duplicate may or may not have the desired effect. |
| func (l *UnixListener) File() (*os.File, error) { |
| return nil, &OpError{Op: "file", Net: l.fd.dir, Source: nil, Addr: l.fd.laddr, Err: syscall.EPLAN9} |
| } |
| |
| // ListenUnixgram listens for incoming Unix datagram packets addressed |
| // to the local address laddr. The network net must be "unixgram". |
| // The returned connection's ReadFrom and WriteTo methods can be used |
| // to receive and send packets with per-packet addressing. |
| func ListenUnixgram(net string, laddr *UnixAddr) (*UnixConn, error) { |
| return nil, &OpError{Op: "listen", Net: net, Source: nil, Addr: laddr.opAddr(), Err: syscall.EPLAN9} |
| } |