gruberb/protohackers
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix hearbeat

Browse source
This commit is contained in:
Bastian Gruber 2023-05-21 14:43:52 +02:00
parent 4a5f98858b
commit 3776d7bb4c
No known key found for this signature in database
GPG key ID: BE9F8C772B188CBF
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
problem_06/src/server.rs
View file

@ -179,6 +179,7 @@ impl Handler {
frame: ClientFrames, frame: ClientFrames,
send_message: mpsc::Sender<ServerFrames>, send_message: mpsc::Sender<ServerFrames>,
) -> crate::Result<()> { ) -> crate::Result<()> {
debug!(?frame);
match frame { match frame {
ClientFrames::Plate { plate, timestamp } => { ClientFrames::Plate { plate, timestamp } => {
info!("Receive new plate {plate} {timestamp}"); info!("Receive new plate {plate} {timestamp}");
@ -201,10 +202,12 @@ impl Handler {
.await; .await;
} }
ClientFrames::WantHeartbeat { interval } => { ClientFrames::WantHeartbeat { interval } => {
tokio::spawn(async move { if interval > 0 {
let mut heartbeat = Heartbeat::new(interval, send_message.clone()); tokio::spawn(async move {
heartbeat.start().await; let mut heartbeat = Heartbeat::new(interval, send_message.clone());
}); heartbeat.start().await;
});
}
} }
ClientFrames::IAmCamera { road, mile, limit } => { ClientFrames::IAmCamera { road, mile, limit } => {
if self.connection_type.is_some() { if self.connection_type.is_some() {