aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/backend/disk_file.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-04-08 11:03:14 -0700
committerchrislu <chris.lu@gmail.com>2024-04-08 11:03:14 -0700
commitcc1c69f312a967dfb636a677db910eb64ab65a06 (patch)
tree086fa2b7ce6e7b80c4a00516cba2810655579709 /weed/storage/backend/disk_file.go
parentccdd9cd8decf66089ac201b7c2ca1f5889582b93 (diff)
parentf08f95ac800b788e42290e58eb6444e094acf97f (diff)
downloadseaweedfs-cc1c69f312a967dfb636a677db910eb64ab65a06.tar.xz
seaweedfs-cc1c69f312a967dfb636a677db910eb64ab65a06.zip
Merge branch 'master' into mq-subscribe
Diffstat (limited to 'weed/storage/backend/disk_file.go')
-rw-r--r--weed/storage/backend/disk_file.go15
1 files changed, 11 insertions, 4 deletions
diff --git a/weed/storage/backend/disk_file.go b/weed/storage/backend/disk_file.go
index 050ded613..68ffbd7e7 100644
--- a/weed/storage/backend/disk_file.go
+++ b/weed/storage/backend/disk_file.go
@@ -81,13 +81,20 @@ func (df *DiskFile) Close() error {
if df.File == nil {
return nil
}
- if err := df.Sync(); err != nil {
- return err
+ err := df.Sync()
+ var err1 error
+ if df.File != nil {
+ // always try to close
+ err1 = df.File.Close()
}
- if err := df.File.Close(); err != nil {
+ // assume closed
+ df.File = nil
+ if err != nil {
return err
}
- df.File = nil
+ if err1 != nil {
+ return err1
+ }
return nil
}