aboutsummaryrefslogtreecommitdiffstats
path: root/modules/cache
diff options
context:
space:
mode:
authorLunny Xiao <xiaolunwen@gmail.com>2022-11-10 14:43:53 +0800
committerGitHub <noreply@github.com>2022-11-10 14:43:53 +0800
commit385462d36c75e809ee082d3432941f938cbdffc9 (patch)
tree938946297d1c0fa736852e1054f732ed2b0db686 /modules/cache
parentce5aafbc698de72d8acf03851dc5db057b3cc01f (diff)
downloadgitea-385462d36c75e809ee082d3432941f938cbdffc9.tar.gz
gitea-385462d36c75e809ee082d3432941f938cbdffc9.zip
Fix dashboard ignored system setting cache (#21621)
This is a performance regression from #18058 Signed-off-by: Andrew Thornton <art27@cantab.net> Co-authored-by: Andrew Thornton <art27@cantab.net>
Diffstat (limited to 'modules/cache')
-rw-r--r--modules/cache/cache.go131
1 files changed, 85 insertions, 46 deletions
diff --git a/modules/cache/cache.go b/modules/cache/cache.go
index 21d0cd0a04..d98b0a0cec 100644
--- a/modules/cache/cache.go
+++ b/modules/cache/cache.go
@@ -46,32 +46,64 @@ func GetCache() mc.Cache {
return conn
}
+// Get returns the key value from cache with callback when no key exists in cache
+func Get[V interface{}](key string, getFunc func() (V, error)) (V, error) {
+ if conn == nil || setting.CacheService.TTL == 0 {
+ return getFunc()
+ }
+
+ cached := conn.Get(key)
+ if value, ok := cached.(V); ok {
+ return value, nil
+ }
+
+ value, err := getFunc()
+ if err != nil {
+ return value, err
+ }
+
+ return value, conn.Put(key, value, setting.CacheService.TTLSeconds())
+}
+
+// Set updates and returns the key value in the cache with callback. The old value is only removed if the updateFunc() is successful
+func Set[V interface{}](key string, valueFunc func() (V, error)) (V, error) {
+ if conn == nil || setting.CacheService.TTL == 0 {
+ return valueFunc()
+ }
+
+ value, err := valueFunc()
+ if err != nil {
+ return value, err
+ }
+
+ return value, conn.Put(key, value, setting.CacheService.TTLSeconds())
+}
+
// GetString returns the key value from cache with callback when no key exists in cache
func GetString(key string, getFunc func() (string, error)) (string, error) {
if conn == nil || setting.CacheService.TTL == 0 {
return getFunc()
}
- if !conn.IsExist(key) {
- var (
- value string
- err error
- )
- if value, err = getFunc(); err != nil {
- return value, err
- }
- err = conn.Put(key, value, setting.CacheService.TTLSeconds())
+
+ cached := conn.Get(key)
+
+ if cached == nil {
+ value, err := getFunc()
if err != nil {
- return "", err
+ return value, err
}
+ return value, conn.Put(key, value, setting.CacheService.TTLSeconds())
}
- value := conn.Get(key)
- if v, ok := value.(string); ok {
- return v, nil
+
+ if value, ok := cached.(string); ok {
+ return value, nil
}
- if v, ok := value.(fmt.Stringer); ok {
- return v.String(), nil
+
+ if stringer, ok := cached.(fmt.Stringer); ok {
+ return stringer.String(), nil
}
- return fmt.Sprintf("%s", conn.Get(key)), nil
+
+ return fmt.Sprintf("%s", cached), nil
}
// GetInt returns key value from cache with callback when no key exists in cache
@@ -79,30 +111,33 @@ func GetInt(key string, getFunc func() (int, error)) (int, error) {
if conn == nil || setting.CacheService.TTL == 0 {
return getFunc()
}
- if !conn.IsExist(key) {
- var (
- value int
- err error
- )
- if value, err = getFunc(); err != nil {
- return value, err
- }
- err = conn.Put(key, value, setting.CacheService.TTLSeconds())
+
+ cached := conn.Get(key)
+
+ if cached == nil {
+ value, err := getFunc()
if err != nil {
- return 0, err
+ return value, err
}
+
+ return value, conn.Put(key, value, setting.CacheService.TTLSeconds())
}
- switch value := conn.Get(key).(type) {
+
+ switch v := cached.(type) {
case int:
- return value, nil
+ return v, nil
case string:
- v, err := strconv.Atoi(value)
+ value, err := strconv.Atoi(v)
if err != nil {
return 0, err
}
- return v, nil
+ return value, nil
default:
- return 0, fmt.Errorf("Unsupported cached value type: %v", value)
+ value, err := getFunc()
+ if err != nil {
+ return value, err
+ }
+ return value, conn.Put(key, value, setting.CacheService.TTLSeconds())
}
}
@@ -111,30 +146,34 @@ func GetInt64(key string, getFunc func() (int64, error)) (int64, error) {
if conn == nil || setting.CacheService.TTL == 0 {
return getFunc()
}
- if !conn.IsExist(key) {
- var (
- value int64
- err error
- )
- if value, err = getFunc(); err != nil {
- return value, err
- }
- err = conn.Put(key, value, setting.CacheService.TTLSeconds())
+
+ cached := conn.Get(key)
+
+ if cached == nil {
+ value, err := getFunc()
if err != nil {
- return 0, err
+ return value, err
}
+
+ return value, conn.Put(key, value, setting.CacheService.TTLSeconds())
}
- switch value := conn.Get(key).(type) {
+
+ switch v := conn.Get(key).(type) {
case int64:
- return value, nil
+ return v, nil
case string:
- v, err := strconv.ParseInt(value, 10, 64)
+ value, err := strconv.ParseInt(v, 10, 64)
if err != nil {
return 0, err
}
- return v, nil
+ return value, nil
default:
- return 0, fmt.Errorf("Unsupported cached value type: %v", value)
+ value, err := getFunc()
+ if err != nil {
+ return value, err
+ }
+
+ return value, conn.Put(key, value, setting.CacheService.TTLSeconds())
}
}