perf: add map estimated entry size into cache size estimation

rueian · rueian · commit 26ba6aa411e0 · 2025-01-23T14:02:47.000-08:00
Signed-off-by: Rueian &lt;rueiancsie@gmail.com&gt;
diff --git a/cache.go b/cache.go
@@ -367,7 +367,7 @@ func (f *flatten) Update(key, cmd string, val RedisMessage) (sxat int64) {
 			val.setExpireAt(sxat)
 		}
 		bs := val.CacheMarshal(nil)
-		fe := &flatentry{cmd: cmd, val: bs, ttl: sxat, size: int64(len(bs)+len(key)+len(cmd)) + int64(flattEntrySize)}
+		fe := &flatentry{cmd: cmd, val: bs, ttl: sxat, size: int64(len(bs)+len(key)+len(cmd)) + int64(flattEntrySize) + 64} // 64 for 2 map entries
 		f.mu.Lock()
 		if f.flights != nil {
 			delete(f.flights, fk)

Original file line number	Diff line number	Diff line change
`@@ -367,7 +367,7 @@ func (f *flatten) Update(key, cmd string, val RedisMessage) (sxat int64) {`
`367`	`367`	`val.setExpireAt(sxat)`
`368`	`368`	`}`
`369`	`369`	`bs := val.CacheMarshal(nil)`
`370`		`- fe := &flatentry{cmd: cmd, val: bs, ttl: sxat, size: int64(len(bs)+len(key)+len(cmd)) + int64(flattEntrySize)}`
	`370`	`+ fe := &flatentry{cmd: cmd, val: bs, ttl: sxat, size: int64(len(bs)+len(key)+len(cmd)) + int64(flattEntrySize) + 64} // 64 for 2 map entries`
`371`	`371`	`f.mu.Lock()`
`372`	`372`	`if f.flights != nil {`
`373`	`373`	`delete(f.flights, fk)`