|
|
|
@ -148,11 +148,6 @@ impl M3u8Download { |
|
|
|
break
|
|
|
|
} else {
|
|
|
|
info!("All {} tasks wait for unavailable service", waits.len());
|
|
|
|
if self.do_reconnect {
|
|
|
|
info!("reconnect http connections");
|
|
|
|
client.reconnect().await;
|
|
|
|
}
|
|
|
|
|
|
|
|
let pause_time = waits
|
|
|
|
. into_iter()
|
|
|
|
. fold(self.time_wait, |a, w| w.min(a));
|
|
|
|
@ -162,6 +157,11 @@ impl M3u8Download { |
|
|
|
} else {
|
|
|
|
join_all(non_waits).await;
|
|
|
|
}
|
|
|
|
|
|
|
|
if self.do_reconnect {
|
|
|
|
info!("reconnect http connections");
|
|
|
|
client.reconnect().await;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|