(res chan<- copyResult, work <-chan blob.SizedRef)
| 618 | } |
| 619 | |
| 620 | func (sh *SyncHandler) copyWorker(res chan<- copyResult, work <-chan blob.SizedRef) { |
| 621 | for sb := range work { |
| 622 | res <- copyResult{sb, sh.copyBlob(context.TODO(), sb)} |
| 623 | } |
| 624 | } |
| 625 | |
| 626 | func (sh *SyncHandler) copyBlob(ctx context.Context, sb blob.SizedRef) (err error) { |
| 627 | cs := sh.newCopyStatus(sb) |