fix: linear

2026-01-03 10:05:16 +00:00 · 2022-12-08 23:38:37 +08:00
parent 9fde45f6fd
commit 7d4accc441
3 changed files with 28 additions and 3 deletions
--- a/prepare.go
+++ b/prepare.go
@@ -45,9 +45,9 @@ func (c *Copyer) prepare(ctx context.Context, indexed <-chan *baseJob) <-chan *w
 						return
 					}

-					wj := &writeJob{baseJob: job, src: file, ch: make(chan struct{})}
+					wj := newWriteJob(job, file, c.fromDevice.linear)
 					ch <- wj
-					<-wj.ch
+					wj.wait()
 				}
 			}
 		})