Err(err) => {
if let Some(httperr) = err.downcast_ref::<HttpError>() {
if httperr.code == StatusCode::UNAUTHORIZED {
- tokio::time::delay_until(Instant::from_std(delay_unauth_time)).await;
+ tokio::time::sleep_until(Instant::from_std(delay_unauth_time)).await;
}
}
(formatter.format_error)(err)
// always delay unauthorized calls by 3 seconds (from start of request)
let err = http_err!(UNAUTHORIZED, "authentication failed - {}", err);
- tokio::time::delay_until(Instant::from_std(delay_unauth_time)).await;
+ tokio::time::sleep_until(Instant::from_std(delay_unauth_time)).await;
return Ok((formatter.format_error)(err));
}
}
let auth_id = rpcenv.get_auth_id();
if !check_api_permission(api_method.access.permission, auth_id.as_deref(), &uri_param, user_info.as_ref()) {
let err = http_err!(FORBIDDEN, "permission check failed");
- tokio::time::delay_until(Instant::from_std(access_forbidden_time)).await;
+ tokio::time::sleep_until(Instant::from_std(access_forbidden_time)).await;
return Ok((formatter.format_error)(err));
}
return Ok(get_index(Some(userid.clone()), Some(new_csrf_token), language, &api, parts));
},
_ => {
- tokio::time::delay_until(Instant::from_std(delay_unauth_time)).await;
+ tokio::time::sleep_until(Instant::from_std(delay_unauth_time)).await;
return Ok(get_index(None, None, language, &api, parts));
}
}
}
async fn wait_service_is_state(service: &str, state: &str) -> Result<(), Error> {
- tokio::time::delay_for(std::time::Duration::new(1, 0)).await;
+ tokio::time::sleep(std::time::Duration::new(1, 0)).await;
while get_service_state(service).await? != state {
- tokio::time::delay_for(std::time::Duration::new(5, 0)).await;
+ tokio::time::sleep(std::time::Duration::new(5, 0)).await;
}
Ok(())
}
async fn wait_service_is_not_state(service: &str, state: &str) -> Result<(), Error> {
- tokio::time::delay_for(std::time::Duration::new(1, 0)).await;
+ tokio::time::sleep(std::time::Duration::new(1, 0)).await;
while get_service_state(service).await? == state {
- tokio::time::delay_for(std::time::Duration::new(5, 0)).await;
+ tokio::time::sleep(std::time::Duration::new(5, 0)).await;
}
Ok(())
}