We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d575d2b commit f294ebcCopy full SHA for f294ebc
internal/dmap/eviction.go
@@ -20,6 +20,7 @@ import (
20
"math/rand"
21
"runtime"
22
"sort"
23
+ "strings"
24
"time"
25
26
"github.com/olric-data/olric/internal/cluster/partitions"
@@ -102,8 +103,9 @@ func (s *Service) evictKeys() {
102
103
partID := uint64(rand.Intn(int(s.config.PartitionCount)))
104
part := s.primary.PartitionByID(partID)
105
part.Map().Range(func(name, tmp interface{}) bool {
106
+ dmapName := strings.TrimPrefix(name.(string), "dmap.")
107
f := tmp.(*fragment)
- s.scanFragmentForEviction(partID, name.(string), f)
108
+ s.scanFragmentForEviction(partID, dmapName, f)
109
// this breaks the loop, we only scan one dmap instance per call
110
return false
111
})
0 commit comments