fix: resolve errcheck lint for sync.Map type assertion
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
@@ -54,8 +54,13 @@ func NewOAuthRefreshAPI(accountRepo AccountRepository, tokenCache GeminiTokenCac
|
|||||||
|
|
||||||
// getLocalLock 返回指定 cacheKey 的进程内互斥锁
|
// getLocalLock 返回指定 cacheKey 的进程内互斥锁
|
||||||
func (api *OAuthRefreshAPI) getLocalLock(cacheKey string) *sync.Mutex {
|
func (api *OAuthRefreshAPI) getLocalLock(cacheKey string) *sync.Mutex {
|
||||||
val, _ := api.localLocks.LoadOrStore(cacheKey, &sync.Mutex{})
|
actual, _ := api.localLocks.LoadOrStore(cacheKey, &sync.Mutex{})
|
||||||
return val.(*sync.Mutex)
|
mu, ok := actual.(*sync.Mutex)
|
||||||
|
if !ok {
|
||||||
|
mu = &sync.Mutex{}
|
||||||
|
api.localLocks.Store(cacheKey, mu)
|
||||||
|
}
|
||||||
|
return mu
|
||||||
}
|
}
|
||||||
|
|
||||||
// RefreshIfNeeded 在分布式锁保护下按需刷新 OAuth token
|
// RefreshIfNeeded 在分布式锁保护下按需刷新 OAuth token
|
||||||
|
|||||||
Reference in New Issue
Block a user