Fixed panic on accessing expired node
This commit is contained in:
parent
61c52f15a3
commit
38f4a06f1d
@ -471,6 +471,10 @@ impl<Message> Host<Message> where Message: Send + Sync + Clone {
|
|||||||
node.last_attempted = Some(::time::now());
|
node.last_attempted = Some(::time::now());
|
||||||
node.endpoint.address
|
node.endpoint.address
|
||||||
}
|
}
|
||||||
|
else {
|
||||||
|
debug!("Connection to expired node aborted");
|
||||||
|
return;
|
||||||
|
}
|
||||||
};
|
};
|
||||||
match TcpStream::connect(&address) {
|
match TcpStream::connect(&address) {
|
||||||
Ok(socket) => socket,
|
Ok(socket) => socket,
|
||||||
@ -647,7 +651,7 @@ impl<Message> Host<Message> where Message: Send + Sync + Clone {
|
|||||||
let mut session = match Session::new(h, &self.info.read().unwrap()) {
|
let mut session = match Session::new(h, &self.info.read().unwrap()) {
|
||||||
Ok(s) => s,
|
Ok(s) => s,
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
warn!("Session creation error: {:?}", e);
|
debug!("Session creation error: {:?}", e);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
Loading…
Reference in New Issue
Block a user