From e331d94a26bbeeaa99d64c4374b19461af4d2171 Mon Sep 17 00:00:00 2001
From: Jeremy Wall <jeremy@marzhillstudios.com>
Date: Mon, 1 Feb 2021 17:06:23 -0500
Subject: [PATCH] Expose errors when setting timeouts

---
 src/socket.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/socket.rs b/src/socket.rs
index 28986a0..9101fa8 100644
--- a/src/socket.rs
+++ b/src/socket.rs
@@ -93,7 +93,7 @@ impl IcmpSocket for IcmpSocket4 {
     }
 
     fn rcv_from(&mut self) -> std::io::Result<(Self::PacketType, SockAddr)> {
-        self.inner.set_read_timeout(None);
+        self.inner.set_read_timeout(None)?;
         let (read_count, addr) = self.inner.recv_from(&mut self.buf)?;
         Ok((self.buf[0..read_count].try_into()?, addr))
     }
@@ -102,7 +102,7 @@ impl IcmpSocket for IcmpSocket4 {
         &mut self,
         timeout: Duration,
     ) -> std::io::Result<(Self::PacketType, SockAddr)> {
-        self.inner.set_read_timeout(Some(timeout));
+        self.inner.set_read_timeout(Some(timeout))?;
         let (read_count, addr) = self.inner.recv_from(&mut self.buf)?;
         Ok((self.buf[0..read_count].try_into()?, addr))
     }
@@ -167,7 +167,7 @@ impl IcmpSocket for IcmpSocket6 {
     }
 
     fn rcv_from(&mut self) -> std::io::Result<(Self::PacketType, SockAddr)> {
-        self.inner.set_read_timeout(None);
+        self.inner.set_read_timeout(None)?;
         let (read_count, addr) = self.inner.recv_from(&mut self.buf)?;
         Ok((self.buf[0..read_count].try_into()?, addr))
     }
@@ -176,7 +176,7 @@ impl IcmpSocket for IcmpSocket6 {
         &mut self,
         timeout: Duration,
     ) -> std::io::Result<(Self::PacketType, SockAddr)> {
-        self.inner.set_read_timeout(Some(timeout));
+        self.inner.set_read_timeout(Some(timeout))?;
         let (read_count, addr) = self.inner.recv_from(&mut self.buf)?;
         Ok((self.buf[0..read_count].try_into()?, addr))
     }