hulthe/lighter
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Reset socket on error

Browse Source
This commit is contained in:
Joakim Hulthe
2023-12-05 14:16:30 +01:00
parent e1c1fa71af
commit ab46f56753
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
manager/src/provider/mqtt.rs
View File

@ -124,8 +124,11 @@ impl BulbProvider for BulbsMqtt {
loop { loop {
match inner(self, &command).await { match inner(self, &command).await {
Ok(t) => break Ok(t), Ok(t) => break Ok(t),
Err(FailMode::Retry(e)) => info!("Retrying on error: {e:?}"),
Err(FailMode::Fatal(e)) => break Err(e), Err(FailMode::Fatal(e)) => break Err(e),
Err(FailMode::Retry(e)) => {
info!("Retrying on error: {e:?}");
self.socket.socket = None;
}
} }
} }
} }
@ -204,8 +207,11 @@ impl BulbProvider for BulbsMqtt {
loop { loop {
match inner(self).await { match inner(self).await {
Ok(t) => break Ok(t), Ok(t) => break Ok(t),
Err(FailMode::Retry(e)) => info!("Retrying on error: {e:?}"),
Err(FailMode::Fatal(e)) => break Err(e), Err(FailMode::Fatal(e)) => break Err(e),
Err(FailMode::Retry(e)) => {
info!("Retrying on error: {e:?}");
self.socket.socket = None;
}
} }
} }
} }