diff --git a/src/p2p/network.rs b/src/p2p/network.rs index 1bca9dc..ca080ac 100644 --- a/src/p2p/network.rs +++ b/src/p2p/network.rs @@ -222,7 +222,7 @@ fn handle_connection_event(context: Arc>, peers: &mut Peers, regi Ok(true) } -fn read_message(stream: &mut TcpStream) -> Result, Vec> { +fn read_message(stream: &mut TcpStream) -> Result, ()> { let instant = Instant::now(); let data_size = match stream.read_u32::() { Ok(size) => { size as usize } @@ -233,7 +233,7 @@ fn read_message(stream: &mut TcpStream) -> Result, Vec> { }; println!("Payload size is {}", data_size); if data_size > MAX_PACKET_SIZE { - return Err(Vec::new()); + return Err(()); } let mut buf = vec![0u8; data_size]; @@ -256,14 +256,14 @@ fn read_message(stream: &mut TcpStream) -> Result, Vec> { // Other errors we'll consider fatal. Err(_) => { println!("Error reading message, only {} bytes read", bytes_read); - return Err(buf) + return Err(()) }, } } if buf.len() == data_size { Ok(buf) } else { - Err(buf) + Err(()) } }