bucket_expire.go

package cbytecache

// Mark all entries on range [0..z) as expired.
//
// This method has sense only if expire listener is provided in config.
func (b *bucket) expireRange(z int) {
	el := b.elen()
	if z < 256 {
		_ = b.entry[el-1]
		for i := 0; i < z; i++ {
			b.expire(&b.entry[i])
		}
	} else {
		z8 := z - z%8
		_ = b.entry[el-1]
		for i := 0; i < z8; i += 8 {
			b.expire(&b.entry[i])
			b.expire(&b.entry[i+1])
			b.expire(&b.entry[i+2])
			b.expire(&b.entry[i+3])
			b.expire(&b.entry[i+4])
			b.expire(&b.entry[i+5])
			b.expire(&b.entry[i+6])
			b.expire(&b.entry[i+7])
		}
		for i := z8; i < z; i++ {
			b.expire(&b.entry[i])
		}
	}
}

// Perform expire operation over single entry.
func (b *bucket) expire(e *entry) {
	if e.invalid() {
		return
	}
	// Get entry data (key, body and expire timestamp).
	b.buf.ResetLen()
	_ = b.buf.GrowLen(int(e.length))
	key, body, err := b.getLF(b.buf.Bytes()[:0], e, dummyMetrics)
	if err != nil {
		return
	}
	// Pack entry and send it to the listener.
	_ = b.config.ExpireListener.Listen(Entry{Key: key, Body: body})
}