G2/minidisc-cli
1
0
Fork 0
mirror of https://github.com/G2-Games/minidisc-cli.git synced 2025-04-20 04:02:53 -05:00
Code Issues Projects Releases Packages Wiki Activity

Fixed issue with _read_reply() in base.rs

Browse source
This commit is contained in:
G2-Games 2024-01-31 21:20:01 -06:00
parent c563a41781
commit e7d21253d8
1 changed files with 11 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
minidisc-rs/src/netmd/base.rs
View file

@ -243,12 +243,19 @@ impl NetMD {
use_factory_command: bool, use_factory_command: bool,
override_length: Option<i32>, override_length: Option<i32>,
) -> Result<Vec<u8>, Box<dyn Error>> { ) -> Result<Vec<u8>, Box<dyn Error>> {
let mut length = self.poll().await?.0; let mut length = 0;
for attempt in 0..75 { for attempt in 0..40 {
if attempt == 75 { if attempt == 39 {
return Err("Failed to get response length".into()); return Err("Failed to get response length".into());
} }
length = self.poll().await?.0;
if length > 0 {
break
}
// Back off while trying again // Back off while trying again
let sleep_time = Self::READ_REPLY_RETRY_INTERVAL as u64 let sleep_time = Self::READ_REPLY_RETRY_INTERVAL as u64
* (u64::pow(2, attempt as u32 / 10) - 1); * (u64::pow(2, attempt as u32 / 10) - 1);
@ -259,10 +266,7 @@ impl NetMD {
#[cfg(target_family = "wasm")] #[cfg(target_family = "wasm")]
TimeoutFuture::new(sleep_time as u32).await; TimeoutFuture::new(sleep_time as u32).await;
length = self.poll().await?.0; println!("{}", attempt);
if length > 0 {
break
}
} }
if let Some(value) = override_length { if let Some(value) = override_length {