()
| 440 | } |
| 441 | |
| 442 | func (c *channelCacheImpl) isCompactActive() bool { |
| 443 | return c.compactRunning.IsTrue() |
| 444 | } |
| 445 | |
| 446 | // startCacheCompaction starts a goroutine for cache compaction if it's not already running. |
| 447 | func (c *channelCacheImpl) startCacheCompaction(ctx context.Context) { |
no test coverage detected