tor-browser

commit d24e272614b0f72b549fa2255e28c70b531077ea
parent 37667964d8b1317840994ff139bcee1351a4ea45
Author: Cosmin Sabou <csabou@mozilla.com>
Date:   Wed,  8 Oct 2025 06:55:01 +0300

Revert "Bug 1991950 - Hold onto buffer while IO is pending r=gstoll" for causing windows xpcshell failures on test_subprocess.

This reverts commit 7255750e882810a61e96a37a911b1e98cc4fcbb7.

Diffstat:
M
toolkit/modules/subprocess/subprocess_shared_win.js
 | 
1
-
M
toolkit/modules/subprocess/subprocess_win.worker.js
 | 
36
++----------------------------------

2 files changed, 2 insertions(+), 35 deletions(-)
diff --git a/toolkit/modules/subprocess/subprocess_shared_win.js b/toolkit/modules/subprocess/subprocess_shared_win.js
@@ -88,7 +88,6 @@ Object.assign(win32, {
   ERROR_BROKEN_PIPE: 109,
   ERROR_INSUFFICIENT_BUFFER: 122,
   ERROR_ABANDONED_WAIT_0: 735,
-  ERROR_IO_INCOMPLETE: 996,
   ERROR_IO_PENDING: 997,
 
   FILE_ATTRIBUTE_NORMAL: 0x00000080,
diff --git a/toolkit/modules/subprocess/subprocess_win.worker.js b/toolkit/modules/subprocess/subprocess_win.worker.js
@@ -105,20 +105,11 @@ class Pipe extends BasePipe {
       debug(`Failed to associate IOCP: ${ctypes.winLastError}`);
     }
 
-    // this.buffer is set to an ArrayBuffer, which should not be reused nor
-    // released until the IO methods (ReadFile or WriteFile) have acknowledged
-    // completion, or reported an error other than ERROR_IO_PENDING.
     this.buffer = null;
-    // Whether this.buffer is part of a pending IO operation.
-    this.bufferIsPendingIO = false;
-    // When close(force = true) is called while IO is pending, we notify
-    // read()/write() callers of completion but internally we await a IOCP
-    // message for this pipe before closing the pipe for real.
-    this.awaitingBufferClose = false;
   }
 
   hasPendingIO() {
-    return !!this.pending.length || this.bufferIsPendingIO;
+    return !!this.pending.length;
   }
 
   maybeClose() {}
@@ -147,12 +138,6 @@ class Pipe extends BasePipe {
     }
     this.pending.length = 0;
 
-    if ((this.bufferIsPendingIO &&= this.#checkIfBufferIsStillPendingIO())) {
-      // We cannot release the pipe (specifically this.buffer) until the
-      // pending ReadFile/WriteFile operation on the buffer completed.
-      this.awaitingBufferClose = true;
-      return this.closedPromise;
-    }
     this.buffer = null;
 
     if (!this.closed) {
@@ -176,18 +161,6 @@ class Pipe extends BasePipe {
   onError() {
     this.close(true);
   }
-
-  #checkIfBufferIsStillPendingIO() {
-    let numberOfBytesTransferred = win32.DWORD();
-    let ok = libc.GetOverlappedResult(
-      this.handle,
-      this.overlapped.address(),
-      numberOfBytesTransferred.address(),
-      false
-    );
-    // Ok or error other than ERROR_IO_INCOMPLETE means that I/O completed.
-    return !ok && ctypes.winLastError === win32.ERROR_IO_INCOMPLETE;
-  }
 }
 
 class InputPipe extends Pipe {
@@ -253,7 +226,6 @@ class InputPipe extends Pipe {
    */
   readBuffer(count) {
     this.buffer = new ArrayBuffer(count);
-    this.bufferIsPendingIO = true;
 
     let ok = libc.ReadFile(
       this.handle,
@@ -267,7 +239,6 @@ class InputPipe extends Pipe {
       !ok &&
       (!this.process.handle || ctypes.winLastError !== win32.ERROR_IO_PENDING)
     ) {
-      this.bufferIsPendingIO = ctypes.winLastError === win32.ERROR_IO_PENDING;
       this.onError();
     } else {
       io.updatePollEvents();
@@ -355,7 +326,6 @@ class OutputPipe extends Pipe {
    */
   writeBuffer(buffer) {
     this.buffer = buffer;
-    this.bufferIsPendingIO = true;
 
     let ok = libc.WriteFile(
       this.handle,
@@ -366,7 +336,6 @@ class OutputPipe extends Pipe {
     );
 
     if (!ok && ctypes.winLastError !== win32.ERROR_IO_PENDING) {
-      this.bufferIsPendingIO = false;
       this.onError();
     } else {
       io.updatePollEvents();
@@ -880,8 +849,7 @@ io = {
           debug(`IOCP notification for unknown pipe: ${pipeId}`);
           continue;
         }
-        pipe.bufferIsPendingIO = false;
-        if (deqWinErr === win32.ERROR_BROKEN_PIPE || pipe.awaitingBufferClose) {
+        if (deqWinErr === win32.ERROR_BROKEN_PIPE) {
           pipe.onError();
           continue;
         }