From 8a15007c8a85b701957120c20a91500ed44c6e35 Mon Sep 17 00:00:00 2001 From: Antioch Peverell Date: Tue, 25 Feb 2020 20:23:32 +0000 Subject: [PATCH] ignore error from set_read_timeout (#3243) --- p2p/src/conn.rs | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/p2p/src/conn.rs b/p2p/src/conn.rs index 55a90a737..f848e746a 100644 --- a/p2p/src/conn.rs +++ b/p2p/src/conn.rs @@ -81,9 +81,7 @@ macro_rules! try_break { macro_rules! try_header { ($res:expr, $conn: expr) => {{ - $conn - .set_read_timeout(Some(HEADER_IO_TIMEOUT)) - .expect("set timeout"); + let _ = $conn.set_read_timeout(Some(HEADER_IO_TIMEOUT)); try_break!($res) }}; } @@ -301,9 +299,7 @@ where // check the read end match try_header!(read_header(&mut reader, version), &reader) { Some(MsgHeaderWrapper::Known(header)) => { - reader - .set_read_timeout(Some(BODY_IO_TIMEOUT)) - .expect("set timeout"); + let _ = reader.set_read_timeout(Some(BODY_IO_TIMEOUT)); let msg = Message::from_header(header, &mut reader, version); trace!( @@ -357,9 +353,7 @@ where .name("peer_write".to_string()) .spawn(move || { let mut retry_send = Err(()); - writer - .set_write_timeout(Some(BODY_IO_TIMEOUT)) - .expect("set timeout"); + let _ = writer.set_write_timeout(Some(BODY_IO_TIMEOUT)); loop { let maybe_data = retry_send.or_else(|_| send_rx.recv_timeout(CHANNEL_TIMEOUT)); retry_send = Err(());