ProjectHentai/alist
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: close stream after put

Browse Source
This commit is contained in:
Noah Hsu 2022-06-23 17:05:03 +08:00
parent ffa0bc294a
commit 3a1fcbef1c
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/operations/fs.go
View File

@ -3,6 +3,7 @@ package operations
import ( import (
"context" "context"
"github.com/alist-org/alist/v3/internal/errs" "github.com/alist-org/alist/v3/internal/errs"
log "github.com/sirupsen/logrus"
stdpath "path" stdpath "path"
"time" "time"
@ -195,6 +196,11 @@ func Remove(ctx context.Context, account driver.Driver, path string) error {
} }
func Put(ctx context.Context, account driver.Driver, dstDirPath string, file model.FileStreamer, up driver.UpdateProgress) error { func Put(ctx context.Context, account driver.Driver, dstDirPath string, file model.FileStreamer, up driver.UpdateProgress) error {
defer func() {
if err := file.Close(); err != nil {
log.Errorf("failed to close file streamer, %v", err)
}
}()
err := MakeDir(ctx, account, dstDirPath) err := MakeDir(ctx, account, dstDirPath)
if err != nil { if err != nil {
return errors.WithMessagef(err, "failed to make dir [%s]", dstDirPath) return errors.WithMessagef(err, "failed to make dir [%s]", dstDirPath)