浏览代码

fix download rename

鸣镝 8 年之前
父节点
当前提交
de3f82a4aa
共有 1 个文件被更改,包括 3 次插入1 次删除
  1. 3 1
      oss/download.go

+ 3 - 1
oss/download.go

@@ -116,20 +116,22 @@ func downloadWorker(id int, arg downloadWorkerArg, jobs <-chan downloadPart, res
 			failed <- err
 			failed <- err
 			break
 			break
 		}
 		}
-		defer fd.Close()
 
 
 		_, err = fd.Seek(part.Start-part.Offset, os.SEEK_SET)
 		_, err = fd.Seek(part.Start-part.Offset, os.SEEK_SET)
 		if err != nil {
 		if err != nil {
+			fd.Close()
 			failed <- err
 			failed <- err
 			break
 			break
 		}
 		}
 
 
 		_, err = io.Copy(fd, rd)
 		_, err = io.Copy(fd, rd)
 		if err != nil {
 		if err != nil {
+			fd.Close()
 			failed <- err
 			failed <- err
 			break
 			break
 		}
 		}
 
 
+		fd.Close()
 		results <- part
 		results <- part
 	}
 	}
 }
 }