limit the used memory up to 200% of --buffer-size

c568ccc1 · Davies Liu · e4331d6c · c568ccc1
隐藏空白更改
内联并排

Showing with 3 addition and 0 deletion

pkg/vfs/writer.go pkg/vfs/writer.go +3 -0

未找到文件。
--- a/pkg/vfs/writer.go
+++ b/pkg/vfs/writer.go
@@ -273,6 +273,9 @@ func (f *fileWriter) Write(ctx meta.Context, off uint64, data []byte) syscall.Er
 	if utils.UsedMemory() > f.w.bufferSize {
 		// slow down
 		time.Sleep(time.Millisecond * 10)
+		for utils.UsedMemory() > f.w.bufferSize*2 {
+			time.Sleep(time.Millisecond * 100)
+		}
 	}
 	f.Lock()
 	defer f.Unlock()