watchfd, err = syscall.Open(name, openMode, 0700)
if watchfd == -1 {
- return os.NewSyscallError("Open", err)
+ return err
}
isDir = fi.IsDir()
case <-w.done:
err := syscall.Close(w.kq)
if err != nil {
- w.Errors <- os.NewSyscallError("close", err)
+ w.Errors <- err
}
close(w.Events)
close(w.Errors)
kevents, err := read(w.kq, eventBuffer, &keventWaitTime)
// EINTR is okay, the syscall was interrupted before timeout expired.
if err != nil && err != syscall.EINTR {
- w.Errors <- os.NewSyscallError("Kevent", err)
+ w.Errors <- err
continue
}
func kqueue() (kq int, err error) {
kq, err = syscall.Kqueue()
if kq == -1 {
- return kq, os.NewSyscallError("Kqueue", err)
+ return kq, err
}
return kq, nil
}
// register the events
success, err := syscall.Kevent(kq, changes, nil, nil)
if success == -1 {
- return os.NewSyscallError("Kevent", err)
+ return err
}
return nil
}