Complete MPU when allowed and under memory pressure

yandex-cloud · Mar 20, 2024 · f47f1d9 · f47f1d9
1 parent 2366e87
commit f47f1d9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/file.go b/internal/file.go
@@ -769,7 +769,7 @@ func (inode *Inode) sendUpload() bool {
 
 	canComplete = canComplete && !inode.IsRangeLocked(0, inode.Attributes.Size, true)
 
-	if canComplete && (inode.fileHandles == 0 || inode.forceFlush) {
+	if canComplete && (inode.fileHandles == 0 || inode.forceFlush || atomic.LoadInt32(&inode.fs.wantFree) > 0) {
 		// Complete the multipart upload
 		inode.IsFlushing += inode.fs.flags.MaxParallelParts
 		atomic.AddInt64(&inode.fs.stats.flushes, 1)