Fix double close of abort channel - fixes #592
This commit is contained in:
parent
b4f2ada820
commit
b5faaf7116
1 changed files with 3 additions and 1 deletions
|
@ -183,7 +183,9 @@ func (s *syncCopyMove) processError(err error) {
|
|||
defer s.errorMu.Unlock()
|
||||
switch {
|
||||
case IsFatalError(err):
|
||||
close(s.abort)
|
||||
if !s.aborting() {
|
||||
close(s.abort)
|
||||
}
|
||||
s.fatalErr = err
|
||||
case IsNoRetryError(err):
|
||||
s.noRetryErr = err
|
||||
|
|
Loading…
Reference in a new issue