Background task, must call waitg.Done() once at end
(gitscanner *lfs.GitScanner, ref string, workingDir string, retainChan chan string, errorChan chan error, waitg *sync.WaitGroup, sem *semaphore.Weighted)
| 565 | |
| 566 | // Background task, must call waitg.Done() once at end |
| 567 | func pruneTaskGetRetainedIndex(gitscanner *lfs.GitScanner, ref string, workingDir string, retainChan chan string, errorChan chan error, waitg *sync.WaitGroup, sem *semaphore.Weighted) { |
| 568 | defer waitg.Done() |
| 569 | |
| 570 | err := gitscanner.ScanIndex(ref, workingDir, func(p *lfs.WrappedPointer, err error) { |
| 571 | if err != nil { |
| 572 | errorChan <- err |
| 573 | } else { |
| 574 | retainChan <- p.Pointer.Oid |
| 575 | tracerx.Printf("RETAIN: %v index", p.Pointer.Oid) |
| 576 | } |
| 577 | }) |
| 578 | |
| 579 | if err != nil { |
| 580 | errorChan <- err |
| 581 | return |
| 582 | } |
| 583 | } |
| 584 | |
| 585 | // Background task, must call waitg.Done() once at end |
| 586 | func pruneTaskGetReachableObjects(gitscanner *lfs.GitScanner, outObjectSet *tools.StringSet, errorChan chan error, waitg *sync.WaitGroup, sem *semaphore.Weighted) { |
no test coverage detected