opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-24 16:03:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: policy cache get/set with atomic ops

Browse Source
This commit is contained in:
Qiu Jian
2022-08-30 07:31:00 +08:00
parent ee14c4e1d2
commit 60a2a3aa9d
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/cloudcommon/policy/policy.go
+3 -3
View File
@@ -239,14 +239,14 @@ type policyTask struct {
}
func (t *policyTask) Run() {
val := t.manager.policyCache.Get(t.key)
val := t.manager.policyCache.AtomicGet(t.key)
result := fetchResult{}
if gotypes.IsNil(val) {
pg, err := DefaultPolicyFetcher(context.Background(), t.userCred)
if err != nil {
result.err = errors.Wrap(err, "DefaultPolicyFetcher")
} else {
t.manager.policyCache.Set(t.key, pg)
t.manager.policyCache.AtomicSet(t.key, pg)
result.output = pg
}
} else {
@@ -297,7 +297,7 @@ func (manager *SPolicyManager) allow(scope rbacutils.TRbacScope, userCred mcclie
policySet = rbacutils.TPolicySet{}
}
result := manager.allowWithoutCache(policySet, scope, userCred, service, resource, action, extra...)
manager.permissionCache.Set(key, result)
manager.permissionCache.AtomicSet(key, result)
return result
}