github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-01-30 15:22:07 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-06-11 16:41:31 +02:00
parent 4776696418
commit 701f5c6d85
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
lib/bytesutil/internstring.go
View file

@ -26,6 +26,7 @@ type internStringMap struct {
readonly atomic.Pointer[map[string]internStringMapEntry] readonly atomic.Pointer[map[string]internStringMapEntry]
cleanupInterval uint64
nextCleanupTime atomic.Uint64 nextCleanupTime atomic.Uint64
} }
@ -35,13 +36,14 @@ type internStringMapEntry struct {
} }
func newInternStringMap() *internStringMap { func newInternStringMap() *internStringMap {
ism := &internStringMap{ m := &internStringMap{
mutable: make(map[string]string), mutable: make(map[string]string),
} }
readonly := make(map[string]internStringMapEntry) readonly := make(map[string]internStringMapEntry)
ism.readonly.Store(&readonly) m.readonly.Store(&readonly)
ism.nextCleanupTime.Store(fasttime.UnixTimestamp() + 61) m.cleanupInterval = uint64(cacheExpireDuration.Seconds() / 3)
return ism m.nextCleanupTime.Store(fasttime.UnixTimestamp() + m.cleanupInterval)
return m
} }
func (m *internStringMap) getReadonly() map[string]internStringMapEntry { func (m *internStringMap) getReadonly() map[string]internStringMapEntry {
@ -49,12 +51,12 @@ func (m *internStringMap) getReadonly() map[string]internStringMapEntry {
} }
func (m *internStringMap) intern(s string) string { func (m *internStringMap) intern(s string) string {
if *disableCache || len(s) > *internStringMaxLen { if isSkipCache(s) {
return strings.Clone(s) return strings.Clone(s)
} }
currentTime := fasttime.UnixTimestamp() currentTime := fasttime.UnixTimestamp()
if currentTime >= m.nextCleanupTime.Load() { if currentTime >= m.nextCleanupTime.Load() {
m.nextCleanupTime.Store(currentTime + 61) m.nextCleanupTime.Store(currentTime + m.cleanupInterval)
m.cleanup() m.cleanup()
} }
@ -65,11 +67,11 @@ func (m *internStringMap) intern(s string) string {
return e.s return e.s
} }
// Slower path - search for the string in mutable map // Slower path - search for the string in mutable map under the lock.
m.mu.Lock() m.mu.Lock()
sInterned, ok := m.mutable[s] sInterned, ok := m.mutable[s]
if !ok { if !ok {
// Verify whether the s has been already registered by concurrent goroutines in m.readonly // Verify whether s has been already registered by concurrent goroutines in m.readonly
readonly = m.getReadonly() readonly = m.getReadonly()
e, ok = readonly[s] e, ok = readonly[s]
if !ok { if !ok {