if s.pr, s.pw, err = os.Pipe(); err != nil {
return nil, err
}
- if err = _SetNonblock(s.pr.fd); err != nil {
+ if err = _SetNonblock(s.pr.Fd); err != nil {
Error:
s.pr.Close();
s.pw.Close();
return nil, err
}
- if err = _SetNonblock(s.pw.fd); err != nil {
+ if err = _SetNonblock(s.pw.Fd); err != nil {
goto Error
}
if s.poll, err = NewPollster(); err != nil {
goto Error
}
- if err = s.poll.AddFD(s.pr.fd, 'r', true); err != nil {
+ if err = s.poll.AddFD(s.pr.Fd, 'r', true); err != nil {
s.poll.Close();
goto Error
}
print("_PollServer WaitFD: ", err.String(), "\n");
return
}
- if fd == s.pr.fd {
+ if fd == s.pr.Fd {
// Drain our wakeup pipe.
for nn, e := s.pr.Read(scratch); nn > 0; {
nn, e = s.pr.Read(scratch)
// FDs are wrappers for file descriptors
type FD struct {
- fd int64
+ Fd int64
}
func NewFD(fd int64) *FD {
if fd == nil {
return EINVAL
}
- r, e := syscall.Close(fd.fd);
- fd.fd = -1; // so it can't be closed again
+ r, e := syscall.Close(fd.Fd);
+ fd.Fd = -1; // so it can't be closed again
return ErrnoToError(e)
}
}
var r, e int64;
if len(b) > 0 { // because we access b[0]
- r, e = syscall.Read(fd.fd, &b[0], int64(len(b)));
+ r, e = syscall.Read(fd.Fd, &b[0], int64(len(b)));
if r < 0 {
r = 0
}
}
var r, e int64;
if len(b) > 0 { // because we access b[0]
- r, e = syscall.Write(fd.fd, &b[0], int64(len(b)));
+ r, e = syscall.Write(fd.Fd, &b[0], int64(len(b)));
if r < 0 {
r = 0
}
if !syscall.StringToBytes(b, s) {
return 0, EINVAL
}
- r, e := syscall.Write(fd.fd, &b[0], int64(len(s)));
+ r, e := syscall.Write(fd.Fd, &b[0], int64(len(s)));
if r < 0 {
r = 0
}