kqueue: close closepipe on error

fsnotify · Mar 5, 2016 · cb591dd · cb591dd
1 parent baf2550
commit cb591dd
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/kqueue.go b/kqueue.go
@@ -469,6 +469,8 @@ func kqueue() (kq int, closepipe [2]int, err error) {
 	syscall.SetKevent(&events[0], closepipe[0], syscall.EVFILT_READ, pflag)
 	if ok, err := syscall.Kevent(kq, events, nil, nil); ok == -1 {
 		syscall.Close(kq)
+		syscall.Close(closepipe[0])
+		syscall.Close(closepipe[1])
 		return kq, closepipe, err
 	}
 	return kq, closepipe, nil