Index: src/pkg/net/sock.go |
=================================================================== |
--- a/src/pkg/net/sock.go |
+++ b/src/pkg/net/sock.go |
@@ -24,7 +24,7 @@ |
} |
// 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 @@ |
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 @@ |
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 @@ |
// 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) |
} |