github
/
alist
mirror of https://github.com/Xhofe/alist
1
0
Fork 0
Code Issues Releases Wiki Activity

fix(123,189pc,alidriver,xunlei):tempfile remove

pull/1110/head
foxxorcat 2022-05-16 09:48:33 +08:00
parent 39b8f28fc4
commit f2b2728be7
4 changed files with 24 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
drivers/123/driver.go
View File

@ -306,8 +306,10 @@ func (driver Pan123) Upload(file *model.FileStream, account *model.Account) erro
if err != nil { if err != nil {
return err return err
} }
defer tempFile.Close() defer func() {
defer os.Remove(tempFile.Name()) _ = tempFile.Close()
_ = os.Remove(tempFile.Name())
}()
h := md5.New() h := md5.New()
if _, err = io.Copy(io.MultiWriter(tempFile, h), file); err != nil { if _, err = io.Copy(io.MultiWriter(tempFile, h), file); err != nil {
return err return err

19
drivers/189pc/driver.go
View File

@ -650,9 +650,10 @@ func (driver Cloud189) FastUpload(file *model.FileStream, parentFile *model.File
if err != nil { if err != nil {
return err return err
} }
defer tempFile.Close() defer func() {
defer os.Remove(tempFile.Name()) _ = tempFile.Close()
_ = os.Remove(tempFile.Name())
}()
// 初始化上传 // 初始化上传
state := GetState(account) state := GetState(account)
@ -756,8 +757,10 @@ func (driver Cloud189) uploadFamily(file *model.FileStream, parentFile *model.Fi
return err return err
} }
defer tempFile.Close() defer func() {
defer os.Remove(tempFile.Name()) _ = tempFile.Close()
_ = os.Remove(tempFile.Name())
}()
fileMd5 := md5.New() fileMd5 := md5.New()
if _, err = io.Copy(io.MultiWriter(fileMd5, tempFile), file); err != nil { if _, err = io.Copy(io.MultiWriter(fileMd5, tempFile), file); err != nil {
@ -805,8 +808,10 @@ func (driver Cloud189) uploadPerson(file *model.FileStream, parentFile *model.Fi
return err return err
} }
defer tempFile.Close() defer func() {
defer os.Remove(tempFile.Name()) _ = tempFile.Close()
_ = os.Remove(tempFile.Name())
}()
fileMd5 := md5.New() fileMd5 := md5.New()
if _, err = io.Copy(io.MultiWriter(fileMd5, tempFile), file); err != nil { if _, err = io.Copy(io.MultiWriter(fileMd5, tempFile), file); err != nil {

6
drivers/alidrive/driver.go
View File

@ -467,8 +467,10 @@ func (driver AliDrive) Upload(file *model.FileStream, account *model.Account) er
return err return err
} }
defer tempFile.Close() defer func() {
defer os.Remove(tempFile.Name()) _ = tempFile.Close()
_ = os.Remove(tempFile.Name())
}()
delete(reqBody, "pre_hash") delete(reqBody, "pre_hash")
h := sha1.New() h := sha1.New()

6
drivers/xunlei/driver.go
View File

@ -363,8 +363,10 @@ func (driver XunLeiCloud) Upload(file *model.FileStream, account *model.Account)
return err return err
} }
defer tempFile.Close() defer func() {
defer os.Remove(tempFile.Name()) _ = tempFile.Close()
_ = os.Remove(tempFile.Name())
}()
gcid, err := getGcid(io.TeeReader(file, tempFile), int64(file.Size)) gcid, err := getGcid(io.TeeReader(file, tempFile), int64(file.Size))
if err != nil { if err != nil {