diff options
Diffstat (limited to 'libgo/go/net/sock.go')
-rw-r--r-- | libgo/go/net/sock.go | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/libgo/go/net/sock.go b/libgo/go/net/sock.go index 2359014..d9df02c 100644 --- a/libgo/go/net/sock.go +++ b/libgo/go/net/sock.go @@ -24,7 +24,7 @@ func boolint(b bool) int { } // Generic socket creation. -func socket(net string, f, p, t int, la, ra syscall.Sockaddr, toAddr func(syscall.Sockaddr) Addr) (fd *netFD, err os.Error) { +func socket(net string, f, p, t int, la, ra syscall.Sockaddr, toAddr func(syscall.Sockaddr) Addr) (fd *netFD, err error) { // See ../syscall/exec.go for description of ForkLock. syscall.ForkLock.RLock() s, e := syscall.Socket(f, p, t) @@ -67,74 +67,74 @@ func socket(net string, f, p, t int, la, ra syscall.Sockaddr, toAddr func(syscal return fd, nil } -func setsockoptInt(fd *netFD, level, opt int, value int) os.Error { +func setsockoptInt(fd *netFD, level, opt int, value int) error { return os.NewSyscallError("setsockopt", syscall.SetsockoptInt(fd.sysfd, level, opt, value)) } -func setsockoptNsec(fd *netFD, level, opt int, nsec int64) os.Error { +func setsockoptNsec(fd *netFD, level, opt int, nsec int64) error { var tv = syscall.NsecToTimeval(nsec) return os.NewSyscallError("setsockopt", syscall.SetsockoptTimeval(fd.sysfd, level, opt, &tv)) } -func setReadBuffer(fd *netFD, bytes int) os.Error { +func setReadBuffer(fd *netFD, bytes int) error { fd.incref() defer fd.decref() return setsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_RCVBUF, bytes) } -func setWriteBuffer(fd *netFD, bytes int) os.Error { +func setWriteBuffer(fd *netFD, bytes int) error { fd.incref() defer fd.decref() return setsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_SNDBUF, bytes) } -func setReadTimeout(fd *netFD, nsec int64) os.Error { +func setReadTimeout(fd *netFD, nsec int64) error { fd.rdeadline_delta = nsec return nil } -func setWriteTimeout(fd *netFD, nsec int64) os.Error { +func setWriteTimeout(fd *netFD, nsec int64) error { fd.wdeadline_delta = nsec return nil } -func setTimeout(fd *netFD, nsec int64) os.Error { +func setTimeout(fd *netFD, nsec int64) error { if e := setReadTimeout(fd, nsec); e != nil { return e } return setWriteTimeout(fd, nsec) } -func setReuseAddr(fd *netFD, reuse bool) os.Error { +func setReuseAddr(fd *netFD, reuse bool) error { fd.incref() defer fd.decref() return setsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, boolint(reuse)) } -func bindToDevice(fd *netFD, dev string) os.Error { +func bindToDevice(fd *netFD, dev string) error { // TODO(rsc): call setsockopt with null-terminated string pointer return os.EINVAL } -func setDontRoute(fd *netFD, dontroute bool) os.Error { +func setDontRoute(fd *netFD, dontroute bool) error { fd.incref() defer fd.decref() return setsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_DONTROUTE, boolint(dontroute)) } -func setKeepAlive(fd *netFD, keepalive bool) os.Error { +func setKeepAlive(fd *netFD, keepalive bool) error { fd.incref() defer fd.decref() return setsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, boolint(keepalive)) } -func setNoDelay(fd *netFD, noDelay bool) os.Error { +func setNoDelay(fd *netFD, noDelay bool) error { fd.incref() defer fd.decref() return setsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_NODELAY, boolint(noDelay)) } -func setLinger(fd *netFD, sec int) os.Error { +func setLinger(fd *netFD, sec int) error { var l syscall.Linger if sec >= 0 { l.Onoff = 1 @@ -153,7 +153,7 @@ type UnknownSocketError struct { sa syscall.Sockaddr } -func (e *UnknownSocketError) String() string { +func (e *UnknownSocketError) Error() string { return "unknown socket address type " + reflect.TypeOf(e.sa).String() } @@ -163,7 +163,7 @@ type writerOnly struct { // Fallback implementation of io.ReaderFrom's ReadFrom, when sendfile isn't // applicable. -func genericReadFrom(w io.Writer, r io.Reader) (n int64, err os.Error) { +func genericReadFrom(w io.Writer, r io.Reader) (n int64, err error) { // Use wrapper to hide existing r.ReadFrom from io.Copy. return io.Copy(writerOnly{w}, r) } |