diff options
author | Russ Cox <rsc@golang.org> | 2009-06-01 22:14:39 -0700 |
---|---|---|
committer | Russ Cox <rsc@golang.org> | 2009-06-01 22:14:39 -0700 |
commit | 9849d463b66c597d5e2429274e677030c4465484 (patch) | |
tree | 874da14a9428e632f5d373e713631be06c233e65 /src/lib/net/fd_linux.go | |
parent | 8f6dc671ffef2fc05c938ba6dee40a0354e83bbd (diff) | |
download | golang-9849d463b66c597d5e2429274e677030c4465484.tar.gz |
update Go tree to use new syscall package.
R=r
DELTA=713 (109 added, 386 deleted, 218 changed)
OCL=29707
CL=29722
Diffstat (limited to 'src/lib/net/fd_linux.go')
-rw-r--r-- | src/lib/net/fd_linux.go | 39 |
1 files changed, 19 insertions, 20 deletions
diff --git a/src/lib/net/fd_linux.go b/src/lib/net/fd_linux.go index 78a1670e1..bd822589e 100644 --- a/src/lib/net/fd_linux.go +++ b/src/lib/net/fd_linux.go @@ -18,27 +18,27 @@ const ( ) type pollster struct { - epfd int64; + epfd int; // Events we're already waiting for - events map[int64] uint32; + events map[int] uint32; } func newpollster() (p *pollster, err os.Error) { p = new(pollster); - var e int64; + var e int; // The arg to epoll_create is a hint to the kernel // about the number of FDs we will care about. // We don't know. - if p.epfd, e = syscall.Epoll_create(16); e != 0 { + if p.epfd, e = syscall.EpollCreate(16); e != 0 { return nil, os.ErrnoToError(e) } - p.events = make(map[int64] uint32); + p.events = make(map[int] uint32); return p, nil } -func (p *pollster) AddFD(fd int64, mode int, repeat bool) os.Error { +func (p *pollster) AddFD(fd int, mode int, repeat bool) os.Error { var ev syscall.EpollEvent; var already bool; ev.Fd = int32(fd); @@ -52,20 +52,20 @@ func (p *pollster) AddFD(fd int64, mode int, repeat bool) os.Error { ev.Events |= writeFlags; } - var op int64; + var op int; if already { op = syscall.EPOLL_CTL_MOD; } else { op = syscall.EPOLL_CTL_ADD; } - if e := syscall.Epoll_ctl(p.epfd, op, fd, &ev); e != 0 { + if e := syscall.EpollCtl(p.epfd, op, fd, &ev); e != 0 { return os.ErrnoToError(e) } p.events[fd] = ev.Events; return nil } -func (p *pollster) StopWaiting(fd int64, bits uint) { +func (p *pollster) StopWaiting(fd int, bits uint) { events, already := p.events[fd]; if !already { print("Epoll unexpected fd=", fd, "\n"); @@ -86,19 +86,19 @@ func (p *pollster) StopWaiting(fd int64, bits uint) { var ev syscall.EpollEvent; ev.Fd = int32(fd); ev.Events = events; - if e := syscall.Epoll_ctl(p.epfd, syscall.EPOLL_CTL_MOD, fd, &ev); e != 0 { + if e := syscall.EpollCtl(p.epfd, syscall.EPOLL_CTL_MOD, fd, &ev); e != 0 { print("Epoll modify fd=", fd, ": ", os.ErrnoToError(e).String(), "\n"); } p.events[fd] = events; } else { - if e := syscall.Epoll_ctl(p.epfd, syscall.EPOLL_CTL_DEL, fd, nil); e != 0 { + if e := syscall.EpollCtl(p.epfd, syscall.EPOLL_CTL_DEL, fd, nil); e != 0 { print("Epoll delete fd=", fd, ": ", os.ErrnoToError(e).String(), "\n"); } p.events[fd] = 0, false; } } -func (p *pollster) DelFD(fd int64, mode int) { +func (p *pollster) DelFD(fd int, mode int) { if mode == 'r' { p.StopWaiting(fd, readFlags); } else { @@ -106,17 +106,17 @@ func (p *pollster) DelFD(fd int64, mode int) { } } -func (p *pollster) WaitFD(nsec int64) (fd int64, mode int, err os.Error) { +func (p *pollster) WaitFD(nsec int64) (fd int, mode int, err os.Error) { // Get an event. var evarray [1]syscall.EpollEvent; ev := &evarray[0]; - var msec int64 = -1; + var msec int = -1; if nsec > 0 { - msec = (nsec + 1e6 - 1)/1e6; + msec = int((nsec + 1e6 - 1)/1e6); } - n, e := syscall.Epoll_wait(p.epfd, &evarray, msec); + n, e := syscall.EpollWait(p.epfd, &evarray, msec); for e == syscall.EAGAIN || e == syscall.EINTR { - n, e = syscall.Epoll_wait(p.epfd, &evarray, msec); + n, e = syscall.EpollWait(p.epfd, &evarray, msec); } if e != 0 { return -1, 0, os.ErrnoToError(e); @@ -124,7 +124,7 @@ func (p *pollster) WaitFD(nsec int64) (fd int64, mode int, err os.Error) { if n == 0 { return -1, 0, nil; } - fd = int64(ev.Fd); + fd = int(ev.Fd); if ev.Events & writeFlags != 0 { p.StopWaiting(fd, writeFlags); @@ -146,6 +146,5 @@ func (p *pollster) WaitFD(nsec int64) (fd int64, mode int, err os.Error) { } func (p *pollster) Close() os.Error { - r, e := syscall.Close(p.epfd); - return os.ErrnoToError(e); + return os.ErrnoToError(syscall.Close(p.epfd)); } |