Sword-Smith
commented
11 months ago The error seems to be due to this line let peer_address = stream.peer_addr().unwrap(); in
// Handle incoming connections from peer
Ok((stream, peer_address)) = self.incoming_peer_listener.accept() => {
let state = self.global_state.clone();
let main_to_peer_broadcast_rx_clone: broadcast::Receiver<MainToPeerThread> = self.main_to_peer_broadcast_tx.subscribe();
let peer_thread_to_main_tx_clone: mpsc::Sender<PeerThreadToMain> = self.peer_thread_to_main_tx.clone();
// let peer_address = stream.peer_addr().unwrap();
let own_handshake_data: HandshakeData = state.get_own_handshakedata().await;
let incoming_peer_thread_handle = tokio::spawn(async move {
match answer_peer_wrapper(
stream,
state,
peer_address,
main_to_peer_broadcast_rx_clone,
peer_thread_to_main_tx_clone,
own_handshake_data,
).await {
Ok(()) => (),
Err(err) => error!("Got error: {:?}", err),
}
});
main_loop_state.thread_handles.push(incoming_peer_thread_handle);
main_loop_state.thread_handles.retain(|th| !th.is_finished());
}If the connection is established and immediately broken, I guess that stream.peer_addr() returns None. We can just get peer_address from the accept() method's return value instead.
aszepieniec
My node crashed on 2023-10-27. This was the tail of the log: