Function TestBufferCacheAutoFlushCold

pkg/buffercache/cache_test.go:163–195

(t *testing.T)

}

func TestBufferCacheAutoFlushCold(t *testing.T) {
	// Fill the cold cache and check flush is called and that the locationMap
	// reflects the state of the cache.
	flushed := false
	cfg := Config{
		MaxBufferLength: 128,
		MaxCapacity:     512,
		CellsPerBucket:  64,
		Buckets:         []int{64},
		OnFlush:         func([]byte) { flushed = true },
	}

	c, _ := New(cfg)

	for i := 0; i < cfg.CellsPerBucket; i++ {
		c.Put(fmt.Sprintf("key%d", i), genBuffer("ciao", 32))
	}
	if flushed {
		t.Errorf("got flushed = true, want false")
	}
	c.Put("extrakey", genBuffer("ciao", 32))
	if !flushed {
		t.Errorf("got flushed = false, want true")
	}

	// check all keys are absent from the cache
	for i := 0; i < cfg.CellsPerBucket; i++ {
		key := fmt.Sprintf("key%d", i)
		assertKeyNotInCache(t, c, key)
	}

	assertKeyInColdCache(t, c, "extrakey")
}

func (c *BufferCache) cacheTotalize() int {
	coldCacheSize := 0