document panics better
This commit is contained in:
parent
96033a0796
commit
d917afe58c
@ -310,7 +310,9 @@ pub async fn handler(
|
|||||||
|
|
||||||
info!(%addr, number, port, "authenticated");
|
info!(%addr, number, port, "authenticated");
|
||||||
|
|
||||||
let listener = handler_metadata.listener.as_mut().unwrap(); // we are only authenticated if this is set
|
let Some(listener) = handler_metadata.listener.as_mut() else {
|
||||||
|
unreachable!("client sucessfully authenticated but did not set handler_metadata.listener");
|
||||||
|
};
|
||||||
|
|
||||||
packet.header = Header {
|
packet.header = Header {
|
||||||
kind: PacketKind::RemConfirm.raw(),
|
kind: PacketKind::RemConfirm.raw(),
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
#![warn(clippy::pedantic)]
|
#![warn(clippy::pedantic)]
|
||||||
#![allow(clippy::missing_errors_doc, clippy::missing_panics_doc)]
|
#![allow(clippy::missing_errors_doc)]
|
||||||
|
|
||||||
use std::{
|
use std::{
|
||||||
fmt::Debug,
|
fmt::Debug,
|
||||||
|
16
src/ports.rs
16
src/ports.rs
@ -228,7 +228,7 @@ impl PortState {
|
|||||||
pub fn new_state(&mut self, status: PortStatus) {
|
pub fn new_state(&mut self, status: PortStatus) {
|
||||||
self.last_change = SystemTime::now()
|
self.last_change = SystemTime::now()
|
||||||
.duration_since(UNIX_EPOCH)
|
.duration_since(UNIX_EPOCH)
|
||||||
.unwrap()
|
.expect("timestamp overflow")
|
||||||
.as_secs();
|
.as_secs();
|
||||||
|
|
||||||
self.status = status;
|
self.status = status;
|
||||||
@ -354,11 +354,9 @@ impl PortHandler {
|
|||||||
|
|
||||||
let port_guard = Rejector::start(listener, packet);
|
let port_guard = Rejector::start(listener, packet);
|
||||||
|
|
||||||
assert!(
|
if self.port_guards.insert(port, port_guard).is_some() {
|
||||||
self.port_guards.insert(port, port_guard).is_none(),
|
unreachable!("Tried to start rejector that is already running. This should have been impossible since it requires two listeners on the same port.");
|
||||||
"Tried to start rejector that is already running.
|
}
|
||||||
This should have been impossible since it requires two listeners on the same port."
|
|
||||||
);
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -451,7 +449,9 @@ impl PortHandler {
|
|||||||
self.try_recover_port(config)?
|
self.try_recover_port(config)?
|
||||||
};
|
};
|
||||||
|
|
||||||
assert!(self.allocated_ports.insert(number, port).is_none());
|
if self.allocated_ports.insert(number, port).is_some() {
|
||||||
|
unreachable!("allocated port twice");
|
||||||
|
}
|
||||||
Some(port)
|
Some(port)
|
||||||
};
|
};
|
||||||
|
|
||||||
@ -529,7 +529,7 @@ impl PortHandler {
|
|||||||
self.errored_ports.insert((
|
self.errored_ports.insert((
|
||||||
SystemTime::now()
|
SystemTime::now()
|
||||||
.duration_since(UNIX_EPOCH)
|
.duration_since(UNIX_EPOCH)
|
||||||
.unwrap()
|
.expect("timestamp overflow")
|
||||||
.as_secs(),
|
.as_secs(),
|
||||||
port,
|
port,
|
||||||
));
|
));
|
||||||
|
Loading…
Reference in New Issue
Block a user