openai/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-09-04 15:08:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Poll MCP OAuth store locks faster

Browse Source
This commit is contained in:
Steven Lee
2026-06-18 17:55:31 +00:00
parent ea8663cccd
commit 293ce77239
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
codex-rs/rmcp-client/src/oauth.rs
View File

@@ -69,7 +69,8 @@ const MCP_OAUTH_SECRET_PREFIX: &str = "MCP_OAUTH";
const REFRESH_SKEW_MILLIS: u64 = 30_000;
const REFRESH_LOCK_DIR: &str = "mcp-oauth-refresh-locks";
const LOCK_ACQUIRE_TIMEOUT: Duration = Duration::from_secs(60);
const LOCK_RETRY_SLEEP: Duration = Duration::from_millis(500);
const CREDENTIAL_LOCK_RETRY_SLEEP: Duration = Duration::from_millis(500);
const STORE_LOCK_RETRY_SLEEP: Duration = Duration::from_millis(50);
const REFRESH_REQUEST_TIMEOUT: Duration = Duration::from_secs(45);
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
@@ -814,7 +815,7 @@ impl RefreshCredentialLock {
match file.try_lock() {
Ok(()) => return Ok(()),
Err(std::fs::TryLockError::WouldBlock) => {
sleep(LOCK_RETRY_SLEEP).await;
sleep(CREDENTIAL_LOCK_RETRY_SLEEP).await;
}
Err(error) => return Err(std::io::Error::from(error)),
}
@@ -901,7 +902,7 @@ impl OAuthStoreLock {
);
}
Err(std::fs::TryLockError::WouldBlock) => {
std::thread::sleep(LOCK_RETRY_SLEEP.min(acquire_timeout));
std::thread::sleep(STORE_LOCK_RETRY_SLEEP.min(acquire_timeout));
}
Err(error) => {
return Err(std::io::Error::from(error)).with_context(|| {