mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-16 19:33:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Review comments

Browse source
This commit is contained in:
Neil Alexander 2020-04-22 12:23:08 +01:00
parent 243081831a
commit 1373929ffc
2 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
common/caching/immutablecache.go
View file

@ -3,7 +3,6 @@ package caching
import "github.com/matrix-org/gomatrixserverlib"
const (
RoomVersionCachingEnabled = true
RoomVersionMaxCacheEntries = 128
)

8
common/caching/immutableinmemorylru.go
View file

@ -1,6 +1,8 @@
package caching
import (
"fmt"
lru "github.com/hashicorp/golang-lru"
"github.com/matrix-org/gomatrixserverlib"
)
@ -21,12 +23,12 @@ func NewImmutableInMemoryLRUCache() (*ImmutableInMemoryLRUCache, error) {
func checkForInvalidMutation(cache *lru.Cache, key string, value interface{}) {
if peek, ok := cache.Peek(key); ok && peek != value {
panic("invalid use of immutable cache tries to mutate existing value")
panic(fmt.Sprintf("invalid use of immutable cache tries to mutate existing value of %q", key))
}
}
func (c *ImmutableInMemoryLRUCache) GetRoomVersion(roomID string) (gomatrixserverlib.RoomVersion, bool) {
if c == nil || !RoomVersionCachingEnabled {
if c == nil {
return "", false
}
val, found := c.roomVersions.Get(roomID)
@ -39,7 +41,7 @@ func (c *ImmutableInMemoryLRUCache) GetRoomVersion(roomID string) (gomatrixserve
}
func (c *ImmutableInMemoryLRUCache) StoreRoomVersion(roomID string, roomVersion gomatrixserverlib.RoomVersion) {
if c == nil || !RoomVersionCachingEnabled {
if c == nil {
return
}
checkForInvalidMutation(c.roomVersions, roomID, roomVersion)