neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add mutex for allowStale variable

Browse Source
This commit is contained in:
Ingo Oppermann 2023-07-10 20:50:42 +02:00
parent b5976f37f0
commit be79a4c327
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
cluster/kvs.go
View File

@ -1,6 +1,7 @@
package cluster
import (
"sync"
"time"
"github.com/datarhei/core/v16/cluster/kvs"
@ -140,9 +141,11 @@ type ClusterKVS interface {
}
type clusterKVS struct {
cluster Cluster
cluster Cluster
logger log.Logger
allowStale bool
logger log.Logger
staleLock sync.Mutex
}
func NewClusterKVS(cluster Cluster, logger log.Logger) (ClusterKVS, error) {
@ -159,6 +162,9 @@ func NewClusterKVS(cluster Cluster, logger log.Logger) (ClusterKVS, error) {
}
func (s *clusterKVS) AllowStaleKeys(allow bool) {
s.staleLock.Lock()
defer s.staleLock.Unlock()
s.allowStale = allow
}
@ -194,11 +200,15 @@ func (s *clusterKVS) UnsetKV(key string) error {
}
func (s *clusterKVS) GetKV(key string) (string, time.Time, error) {
s.staleLock.Lock()
stale := s.allowStale
s.staleLock.Unlock()
s.logger.Debug().WithFields(log.Fields{
"key": key,
"stale": s.allowStale,
"stale": stale,
}).Log("Get KV")
return s.cluster.GetKV("", key, s.allowStale)
return s.cluster.GetKV("", key, stale)
}
func (s *clusterKVS) ListKV(prefix string) map[string]store.Value {