Fix broken pipe waker

Darksonn · Darksonn · commit 7c593389e768 · 2025-08-28T10:40:55.000+02:00
diff --git a/src/sys/unix/selector/kqueue.rs b/src/sys/unix/selector/kqueue.rs
@@ -129,7 +129,6 @@ impl Selector {
         })
     }
 
-    cfg_io_source! {
     pub fn register(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> {
         let flags = libc::EV_CLEAR | libc::EV_RECEIPT | libc::EV_ADD;
         // At most we need two changes, but maybe we only need 1.
@@ -169,6 +168,7 @@ impl Selector {
         kevent_register(self.kq.as_raw_fd(), changes, &[libc::EPIPE as i64])
     }
 
+    cfg_io_source! {
     pub fn reregister(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> {
         let flags = libc::EV_CLEAR | libc::EV_RECEIPT;
         let write_flags = if interests.is_writable() {

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,6 @@ impl Selector {`
`129`	`129`	`})`
`130`	`130`	`}`
`131`	`131`
`132`		`- cfg_io_source! {`
`133`	`132`	`pub fn register(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> {`
`134`	`133`	`let flags = libc::EV_CLEAR \| libc::EV_RECEIPT \| libc::EV_ADD;`
`135`	`134`	`// At most we need two changes, but maybe we only need 1.`
`@@ -169,6 +168,7 @@ impl Selector {`
`169`	`168`	`kevent_register(self.kq.as_raw_fd(), changes, &[libc::EPIPE as i64])`
`170`	`169`	`}`
`171`	`170`
	`171`	`+ cfg_io_source! {`
`172`	`172`	`pub fn reregister(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> {`
`173`	`173`	`let flags = libc::EV_CLEAR \| libc::EV_RECEIPT;`
`174`	`174`	`let write_flags = if interests.is_writable() {`