()
| 325 | } |
| 326 | |
| 327 | func (b *walBlock) readFlushes() []*walBlockFlush { |
| 328 | b.mtx.Lock() |
| 329 | defer b.mtx.Unlock() |
| 330 | return b.flushed |
| 331 | } |
| 332 | |
| 333 | func (b *walBlock) writeFlush(f *walBlockFlush) { |
| 334 | b.mtx.Lock() |
no outgoing calls
no test coverage detected