|
@@ -191,7 +191,7 @@ async fn reader(
|
|
let mut res = client.get(url.clone()).await;
|
|
let mut res = client.get(url.clone()).await;
|
|
while res.is_err() {
|
|
while res.is_err() {
|
|
log!("Error fetching: {}", res.unwrap_err());
|
|
log!("Error fetching: {}", res.unwrap_err());
|
|
- tokio::time::sleep(retry).await;
|
|
|
|
|
|
+ sleep(retry).await;
|
|
res = client.get(url.clone()).await;
|
|
res = client.get(url.clone()).await;
|
|
}
|
|
}
|
|
});
|
|
});
|
|
@@ -260,7 +260,7 @@ async fn uploader(
|
|
let mut res = client.request(request).await;
|
|
let mut res = client.request(request).await;
|
|
while res.is_err() {
|
|
while res.is_err() {
|
|
log!("{},{},Error uploading: {}", user, url, res.unwrap_err());
|
|
log!("{},{},Error uploading: {}", user, url, res.unwrap_err());
|
|
- tokio::time::sleep(retry).await;
|
|
|
|
|
|
+ sleep(retry).await;
|
|
res = client.get(url.clone()).await;
|
|
res = client.get(url.clone()).await;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -324,7 +324,7 @@ async fn socket_updater(
|
|
str_params.recipient,
|
|
str_params.recipient,
|
|
e
|
|
e
|
|
);
|
|
);
|
|
- tokio::time::sleep(retry).await;
|
|
|
|
|
|
+ sleep(retry).await;
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
Err(MessengerError::Fatal(e)) => return e,
|
|
Err(MessengerError::Fatal(e)) => return e,
|
|
@@ -339,7 +339,7 @@ async fn socket_updater(
|
|
str_params.recipient,
|
|
str_params.recipient,
|
|
e
|
|
e
|
|
);
|
|
);
|
|
- tokio::time::sleep(retry).await;
|
|
|
|
|
|
+ sleep(retry).await;
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
};
|
|
};
|
|
@@ -379,7 +379,7 @@ async fn manage_conversation(
|
|
mut state_from_reader: StateFromReader,
|
|
mut state_from_reader: StateFromReader,
|
|
mut state_to_writer: StateToWriter<MessageHolder>,
|
|
mut state_to_writer: StateToWriter<MessageHolder>,
|
|
) {
|
|
) {
|
|
- tokio::time::sleep(Duration::from_secs_f64(config.bootstrap)).await;
|
|
|
|
|
|
+ sleep(Duration::from_secs_f64(config.bootstrap)).await;
|
|
log!("{},{},awake", &config.user, &config.group);
|
|
log!("{},{},awake", &config.user, &config.group);
|
|
|
|
|
|
let mut rng = Xoshiro256PlusPlus::from_entropy();
|
|
let mut rng = Xoshiro256PlusPlus::from_entropy();
|