fix: rm uploaded object files if committing meta failed with err code… (

#5133)
juicedata · Sep 25, 2024 · bd3553f · bd3553f
1 parent a407c01
commit bd3553f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/vfs/writer.go b/pkg/vfs/writer.go
@@ -203,7 +203,11 @@ func (c *chunkWriter) commitThread() {
 
 		f.Lock()
 		if err != 0 {
-			if err != syscall.ENOENT && err != syscall.ENOSPC && err != syscall.EDQUOT {
+			if err == syscall.ENOENT {
+				go func(id uint64, length int) {
+					_ = f.w.store.Remove(id, length)
+				}(s.id, int(s.length))
+			} else if err != syscall.ENOSPC && err != syscall.EDQUOT {
 				logger.Warnf("write inode:%d error: %s", f.inode, err)
 				err = syscall.EIO
 			}