GlcoinCore/cln-nip47
1
0
Fork 0
mirror of https://github.com/daywalker90/cln-nip47.git synced 2026-08-13 12:33:43 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix reuse of retries counter in check_hold_support

Browse source
This commit is contained in:
daywalker90 2026-08-09 17:46:36 +02:00
parent 1d5bd7c821
commit d93a03014b
1 changed files with 11 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

19
src/main.rs
View file

@ -329,12 +329,12 @@ async fn check_hold_support(plugin: Plugin<PluginState>) -> Result<(), anyhow::E
cert_dir.to_str().unwrap()
);
let max_retries = 10;
let mut retries = 0;
while retries < max_retries && !do_certificates_exist(&cert_dir) {
let cert_max_retries = 10;
let mut cert_retries = 0;
while cert_retries < cert_max_retries && !do_certificates_exist(&cert_dir) {
log::debug!("Hold certificates incomplete. Waiting...");
time::sleep(Duration::from_millis(500)).await;
retries += 1;
cert_retries += 1;
}
let ca_cert = tokio::fs::read(cert_dir.join("ca.pem")).await?;
@ -355,15 +355,18 @@ async fn check_hold_support(plugin: Plugin<PluginState>) -> Result<(), anyhow::E
.keep_alive_while_idle(true)
.connect_timeout(Duration::from_secs(5));
let max_retries = 20;
let chan_max_retries = 20;
let mut chan_retries = 0;
let channel = loop {
match endpoint.connect().await {
Ok(channel) => break channel,
Err(e) if retries < max_retries => {
retries += 1;
Err(e) if chan_retries < chan_max_retries => {
chan_retries += 1;
log::debug!("Hold gRPC server not ready, retrying ({retries}/{max_retries}): {e}");
log::debug!(
"Hold gRPC server not ready, retrying ({chan_retries}/{chan_max_retries}): {e}"
);
time::sleep(Duration::from_millis(500)).await;
}