fixuP

Author: ronag

lib/internal/fs/streams.js

@@ -406,15 +406,12 @@ function writeAll(data, size, pos, cb, retries = 0) {
     this.bytesWritten += bytesWritten;
 
     retries = bytesWritten ? 0 : retries + 1;
+    size -= bytesWritten;
+    pos += bytesWritten;
 
     if (retries > 5) {
-      return cb(new Error('writev failed'));
-    }
-
-    size -= bytesWritten
-    pos += bytesWritten
-
-    if (size) {
+      cb(new Error('writev failed'));
+    } else if (size) {
       writeAll(buffer.slice(bytesWritten), size, pos, cb, retries);
     } else {
       cb();
@@ -436,15 +433,12 @@ function writevAll(chunks, size, pos, cb, retries = 0) {
     this.bytesWritten += bytesWritten;
 
     retries = bytesWritten ? 0 : retries + 1;
+    size -= bytesWritten;
+    pos += bytesWritten;
 
     if (retries > 5) {
-      return cb(new Error('writev failed'));
-    }
-
-    size -= bytesWritten
-    pos += bytesWritten
-
-    if (size) {
+      cb(new Error('writev failed'));
+    } else if (size) {
       writevAll([Buffer.concat(buffers).slice(bytesWritten)], size, pos, cb, retries);
     } else {
       cb();