()
| 178 | } |
| 179 | |
| 180 | func (c *BufferCache) flushHot() { |
| 181 | for _, buf := range c.hot.m { |
| 182 | c.flushBlocks(buf) |
| 183 | } |
| 184 | c.hot.m = make(map[string][]byte) |
| 185 | c.hot.cap = 0 |
| 186 | c.m.removeHot() |
| 187 | } |
| 188 | |
| 189 | func (c *BufferCache) decompressAndFlush(buf []byte, compressed bool) { |
| 190 | if !compressed { |
no test coverage detected