Skip to content

Commit

Permalink
net: make deadline helpers join to netFD as its methods
Browse files Browse the repository at this point in the history
Just for readability reasons; to prevent overlooking deadline stuff
across over platforms.

R=golang-dev, dvyukov
CC=golang-dev
https://golang.org/cl/8656044
  • Loading branch information
cixtor committed Aug 13, 2013
1 parent 5a20b4a commit 39a7017
Show file tree
Hide file tree
Showing 8 changed files with 24 additions and 24 deletions.
6 changes: 3 additions & 3 deletions src/pkg/net/fd_plan9.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,15 +108,15 @@ func (fd *netFD) file(f *os.File, s string) (*os.File, error) {
return os.NewFile(uintptr(dfd), s), nil
}

func setDeadline(fd *netFD, t time.Time) error {
func (fd *netFD) setDeadline(t time.Time) error {
return syscall.EPLAN9
}

func setReadDeadline(fd *netFD, t time.Time) error {
func (fd *netFD) setReadDeadline(t time.Time) error {
return syscall.EPLAN9
}

func setWriteDeadline(fd *netFD, t time.Time) error {
func (fd *netFD) setWriteDeadline(t time.Time) error {
return syscall.EPLAN9
}

Expand Down
12 changes: 6 additions & 6 deletions src/pkg/net/fd_poll_runtime.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,16 +115,16 @@ func convertErr(res int) error {
panic("unreachable")
}

func setReadDeadline(fd *netFD, t time.Time) error {
return setDeadlineImpl(fd, t, 'r')
func (fd *netFD) setDeadline(t time.Time) error {
return setDeadlineImpl(fd, t, 'r'+'w')
}

func setWriteDeadline(fd *netFD, t time.Time) error {
return setDeadlineImpl(fd, t, 'w')
func (fd *netFD) setReadDeadline(t time.Time) error {
return setDeadlineImpl(fd, t, 'r')
}

func setDeadline(fd *netFD, t time.Time) error {
return setDeadlineImpl(fd, t, 'r'+'w')
func (fd *netFD) setWriteDeadline(t time.Time) error {
return setDeadlineImpl(fd, t, 'w')
}

func setDeadlineImpl(fd *netFD, t time.Time, mode int) error {
Expand Down
14 changes: 7 additions & 7 deletions src/pkg/net/fd_poll_unix.go
Original file line number Diff line number Diff line change
Expand Up @@ -353,18 +353,18 @@ func (pd *pollDesc) Init(fd *netFD) error {

// TODO(dfc) these unused error returns could be removed

func setReadDeadline(fd *netFD, t time.Time) error {
fd.pd.rdeadline.setTime(t)
func (fd *netFD) setDeadline(t time.Time) error {
fd.setReadDeadline(t)
fd.setWriteDeadline(t)
return nil
}

func setWriteDeadline(fd *netFD, t time.Time) error {
fd.pd.wdeadline.setTime(t)
func (fd *netFD) setReadDeadline(t time.Time) error {
fd.pd.rdeadline.setTime(t)
return nil
}

func setDeadline(fd *netFD, t time.Time) error {
setReadDeadline(fd, t)
setWriteDeadline(fd, t)
func (fd *netFD) setWriteDeadline(t time.Time) error {
fd.pd.wdeadline.setTime(t)
return nil
}
6 changes: 3 additions & 3 deletions src/pkg/net/net.go
Original file line number Diff line number Diff line change
Expand Up @@ -160,23 +160,23 @@ func (c *conn) SetDeadline(t time.Time) error {
if !c.ok() {
return syscall.EINVAL
}
return setDeadline(c.fd, t)
return c.fd.setDeadline(t)
}

// SetReadDeadline implements the Conn SetReadDeadline method.
func (c *conn) SetReadDeadline(t time.Time) error {
if !c.ok() {
return syscall.EINVAL
}
return setReadDeadline(c.fd, t)
return c.fd.setReadDeadline(t)
}

// SetWriteDeadline implements the Conn SetWriteDeadline method.
func (c *conn) SetWriteDeadline(t time.Time) error {
if !c.ok() {
return syscall.EINVAL
}
return setWriteDeadline(c.fd, t)
return c.fd.setWriteDeadline(t)
}

// SetReadBuffer sets the size of the operating system's
Expand Down
4 changes: 2 additions & 2 deletions src/pkg/net/sock_posix.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,14 +113,14 @@ func (fd *netFD) dial(laddr, raddr sockaddr, deadline time.Time, toAddr func(sys
return err
} else if rsa != nil {
if !deadline.IsZero() {
setWriteDeadline(fd, deadline)
fd.setWriteDeadline(deadline)
}
if err := fd.connect(lsa, rsa); err != nil {
return err
}
fd.isConnected = true
if !deadline.IsZero() {
setWriteDeadline(fd, noDeadline)
fd.setWriteDeadline(noDeadline)
}
}
}
Expand Down
2 changes: 1 addition & 1 deletion src/pkg/net/tcpsock_plan9.go
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ func (l *TCPListener) SetDeadline(t time.Time) error {
if l == nil || l.fd == nil || l.fd.ctl == nil {
return syscall.EINVAL
}
return setDeadline(l.fd, t)
return l.fd.setDeadline(t)
}

// File returns a copy of the underlying os.File, set to blocking
Expand Down
2 changes: 1 addition & 1 deletion src/pkg/net/tcpsock_posix.go
Original file line number Diff line number Diff line change
Expand Up @@ -272,7 +272,7 @@ func (l *TCPListener) SetDeadline(t time.Time) error {
if l == nil || l.fd == nil {
return syscall.EINVAL
}
return setDeadline(l.fd, t)
return l.fd.setDeadline(t)
}

// File returns a copy of the underlying os.File, set to blocking
Expand Down
2 changes: 1 addition & 1 deletion src/pkg/net/unixsock_posix.go
Original file line number Diff line number Diff line change
Expand Up @@ -347,7 +347,7 @@ func (l *UnixListener) SetDeadline(t time.Time) (err error) {
if l == nil || l.fd == nil {
return syscall.EINVAL
}
return setDeadline(l.fd, t)
return l.fd.setDeadline(t)
}

// File returns a copy of the underlying os.File, set to blocking
Expand Down

0 comments on commit 39a7017

Please sign in to comment.