(lc *y.Closer)
| 363 | } |
| 364 | |
| 365 | func (s *levelsController) startCompact(lc *y.Closer) { |
| 366 | n := s.kv.opt.NumCompactors |
| 367 | lc.AddRunning(n - 1) |
| 368 | for i := 0; i < n; i++ { |
| 369 | go s.runWorker(lc) |
| 370 | } |
| 371 | } |
| 372 | |
| 373 | func (s *levelsController) runWorker(lc *y.Closer) { |
| 374 | defer lc.Done() |
no test coverage detected