Browse Source

Add timeouts to rollover messages

debug-statements
Thomas Eizinger 3 years ago
parent
commit
790eaaa4f4
No known key found for this signature in database GPG Key ID: 651AC83A6C6C8B96
  1. 6
      daemon/src/setup_contract.rs

6
daemon/src/setup_contract.rs

@ -276,7 +276,9 @@ pub async fn roll_over(
.context("Failed to send Msg0")?;
let msg0 = stream
.select_next_some()
.timeout(Duration::from_secs(60))
.await
.context("Expected Msg0 within 60 seconds")?
.try_into_msg0()
.context("Failed to read Msg0")?;
@ -344,7 +346,9 @@ pub async fn roll_over(
let msg1 = stream
.select_next_some()
.timeout(Duration::from_secs(60))
.await
.context("Expected Msg1 within 60 seconds")?
.try_into_msg1()
.context("Failed to read Msg1")?;
@ -461,7 +465,9 @@ pub async fn roll_over(
let msg2 = stream
.select_next_some()
.timeout(Duration::from_secs(60))
.await
.context("Expected Msg2 within 60 seconds")?
.try_into_msg2()
.context("Failed to read Msg2")?;
let revocation_sk_theirs = msg2.revocation_sk;

Loading…
Cancel
Save