summaryrefslogtreecommitdiff
path: root/src/pkg/net/fd_linux.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/pkg/net/fd_linux.go')
-rw-r--r--src/pkg/net/fd_linux.go20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/pkg/net/fd_linux.go b/src/pkg/net/fd_linux.go
index 7c0fc042f..47ae4f1c3 100644
--- a/src/pkg/net/fd_linux.go
+++ b/src/pkg/net/fd_linux.go
@@ -12,15 +12,15 @@ import (
)
const (
- readFlags = syscall.EPOLLIN | syscall.EPOLLRDHUP;
- writeFlags = syscall.EPOLLOUT
+ readFlags = syscall.EPOLLIN | syscall.EPOLLRDHUP;
+ writeFlags = syscall.EPOLLOUT;
)
type pollster struct {
- epfd int;
+ epfd int;
// Events we're already waiting for
- events map[int] uint32;
+ events map[int]uint32;
}
func newpollster() (p *pollster, err os.Error) {
@@ -31,10 +31,10 @@ func newpollster() (p *pollster, err os.Error) {
// about the number of FDs we will care about.
// We don't know.
if p.epfd, e = syscall.EpollCreate(16); e != 0 {
- return nil, os.NewSyscallError("epoll_create", e)
+ return nil, os.NewSyscallError("epoll_create", e);
}
- p.events = make(map[int] uint32);
- return p, nil
+ p.events = make(map[int]uint32);
+ return p, nil;
}
func (p *pollster) AddFD(fd int, mode int, repeat bool) os.Error {
@@ -58,10 +58,10 @@ func (p *pollster) AddFD(fd int, mode int, repeat bool) os.Error {
op = syscall.EPOLL_CTL_ADD;
}
if e := syscall.EpollCtl(p.epfd, op, fd, &ev); e != 0 {
- return os.NewSyscallError("epoll_ctl", e)
+ return os.NewSyscallError("epoll_ctl", e);
}
p.events[fd] = ev.Events;
- return nil
+ return nil;
}
func (p *pollster) StopWaiting(fd int, bits uint) {
@@ -111,7 +111,7 @@ func (p *pollster) WaitFD(nsec int64) (fd int, mode int, err os.Error) {
ev := &evarray[0];
var msec int = -1;
if nsec > 0 {
- msec = int((nsec + 1e6 - 1)/1e6);
+ msec = int((nsec+1e6-1)/1e6);
}
n, e := syscall.EpollWait(p.epfd, &evarray, msec);
for e == syscall.EAGAIN || e == syscall.EINTR {