signal: don't register write interest on signal pipe (#4898)

tokio-rs · Aug 11, 2022 · d48c437 · d48c437
1 parent 9d9488d
commit d48c437
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/tokio/src/signal/unix/driver.rs b/tokio/src/signal/unix/driver.rs
@@ -74,11 +74,8 @@ impl Driver {
         let original =
             ManuallyDrop::new(unsafe { std::os::unix::net::UnixStream::from_raw_fd(receiver_fd) });
         let receiver = UnixStream::from_std(original.try_clone()?);
-        let receiver = PollEvented::new_with_interest_and_handle(
-            receiver,
-            Interest::READABLE | Interest::WRITABLE,
-            park.handle(),
-        )?;
+        let receiver =
+            PollEvented::new_with_interest_and_handle(receiver, Interest::READABLE, park.handle())?;
 
         Ok(Self {
             park,

diff --git a/tokio/tests/rt_metrics.rs b/tokio/tests/rt_metrics.rs
@@ -400,7 +400,7 @@ fn io_driver_ready_count() {
     let stream = tokio::net::TcpStream::connect("google.com:80");
     let _stream = rt.block_on(async move { stream.await.unwrap() });
 
-    assert_eq!(metrics.io_driver_ready_count(), 2);
+    assert_eq!(metrics.io_driver_ready_count(), 1);
 }
 
 fn basic() -> Runtime {