rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-11-03 13:30:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(api_locking): add delay between api-locking retries (#9308)

Browse Source
This commit is contained in:
Hrithikesh
2025-09-09 18:10:28 +05:30
committed by GitHub
parent 72c0f896ce
commit 4052f8a28c
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/router/src/core/api_locking.rs
View File

@ -79,6 +79,10 @@ impl LockAction {
.map(|input| input.get_redis_locking_key(&merchant_id)) .map(|input| input.get_redis_locking_key(&merchant_id))
.map(|key| (RedisKey::from(key.as_str()), request_id.clone())) .map(|key| (RedisKey::from(key.as_str()), request_id.clone()))
.collect::<Vec<_>>(); .collect::<Vec<_>>();
let delay_between_retries_in_milliseconds = state
.conf()
.lock_settings
.delay_between_retries_in_milliseconds;
for _retry in 0..lock_retries { for _retry in 0..lock_retries {
let results: Vec<redis::SetGetReply<_>> = redis_conn let results: Vec<redis::SetGetReply<_>> = redis_conn
.set_multiple_keys_if_not_exists_and_get_values( .set_multiple_keys_if_not_exists_and_get_values(
@ -95,6 +99,11 @@ impl LockAction {
if lock_aqcuired { if lock_aqcuired {
logger::info!("Lock acquired for locking inputs {:?}", inputs); logger::info!("Lock acquired for locking inputs {:?}", inputs);
return Ok(()); return Ok(());
} else {
actix_time::sleep(tokio::time::Duration::from_millis(u64::from(
delay_between_retries_in_milliseconds,
)))
.await;
} }
} }
Err(report!(errors::ApiErrorResponse::ResourceBusy)) Err(report!(errors::ApiErrorResponse::ResourceBusy))