We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 080b250 commit 6189116Copy full SHA for 6189116
downstairs/src/lib.rs
@@ -1308,12 +1308,7 @@ where
1308
return Ok(());
1309
}
1310
Some(Ok(msg)) => {
1311
- if matches!(msg, Message::Ruok) {
1312
- // Respond instantly to pings, don't wait.
1313
- if let Err(e) = resp_channel_tx.send(Message::Imok) {
1314
- bail!("Failed sending Imok: {}", e);
1315
- }
1316
- } else if let Err(e) = message_channel_tx.send(msg) {
+ if let Err(e) = message_channel_tx.send(msg) {
1317
bail!("Failed sending message to proc_frame: {}", e);
1318
1319
@@ -2660,6 +2655,10 @@ impl Downstairs {
2660
2655
resp_tx.send(msg)?;
2661
2656
None
2662
2657
2658
+ Message::Ruok => {
2659
+ resp_tx.send(Message::Imok)?;
+ None
+ }
2663
x => bail!("unexpected frame {:?}", x),
2664
};
2665
Ok(r)
0 commit comments