Revert "Do not wait in QWindowsPipe{Reader|Writer}::stop()"

This reverts commit c7ec07d40115bef849574c81d619b629af9434a9.

Reason for revert: This causes a memory leak on program termination.

The initial commit was an attempt to fix a deadlock where the user
destroys object from a thread that does not own the object. This is
an unsupported case and should be treated as an invalid report.

Pick-to: 5.15
Change-Id: I4957784b86a0361adb65b9d023542f96480f00ba
Reviewed-by: Oswald Buddenhagen <oswald.buddenhagen@gmx.de>

1 files changed, 6 insertions, 14 deletions

diff --git a/src/corelib/io/qwindowspipereader.cpp b/src/corelib/io/qwindowspipereader.cpp
index 1f03ac5d5a..c20909766d 100644
--- a/src/corelib/io/qwindowspipereader.cpp
+++ b/src/corelib/io/qwindowspipereader.cpp
@@ -58,7 +58,7 @@ void QWindowsPipeReader::Overlapped::clear()
 QWindowsPipeReader::QWindowsPipeReader(QObject *parent)
     : QObject(parent),
       handle(INVALID_HANDLE_VALUE),
-      overlapped(nullptr),
+      overlapped(this),
       readBufferMaxSize(0),
       actualReadBufferSize(0),
       stopped(true),
@@ -75,7 +75,6 @@ QWindowsPipeReader::QWindowsPipeReader(QObject *parent)
 QWindowsPipeReader::~QWindowsPipeReader()
 {
     stop();
-    delete overlapped;
 }
 
 /*!
@@ -97,16 +96,14 @@ void QWindowsPipeReader::stop()
 {
     stopped = true;
     if (readSequenceStarted) {
-        overlapped->pipeReader = nullptr;
-        if (!CancelIoEx(handle, overlapped)) {
+        if (!CancelIoEx(handle, &overlapped)) {
             const DWORD dwError = GetLastError();
             if (dwError != ERROR_NOT_FOUND) {
                 qErrnoWarning(dwError, "QWindowsPipeReader: CancelIoEx on handle %p failed.",
                               handle);
             }
         }
-        overlapped = nullptr;       // The object will be deleted in the I/O callback.
-        readSequenceStarted = false;
+        waitForNotification(-1);
     }
 }
 
@@ -227,10 +224,8 @@ void QWindowsPipeReader::startAsyncRead()
 
     stopped = false;
     readSequenceStarted = true;
-    if (!overlapped)
-        overlapped = new Overlapped(this);
-    overlapped->clear();
-    if (!ReadFileEx(handle, ptr, bytesToRead, overlapped, &readFileCompleted)) {
+    overlapped.clear();
+    if (!ReadFileEx(handle, ptr, bytesToRead, &overlapped, &readFileCompleted)) {
         readSequenceStarted = false;
 
         const DWORD dwError = GetLastError();
@@ -257,10 +252,7 @@ void QWindowsPipeReader::readFileCompleted(DWORD errorCode, DWORD numberOfBytesT
                                            OVERLAPPED *overlappedBase)
 {
     Overlapped *overlapped = static_cast<Overlapped *>(overlappedBase);
-    if (overlapped->pipeReader)
-        overlapped->pipeReader->notified(errorCode, numberOfBytesTransfered);
-    else
-        delete overlapped;
+    overlapped->pipeReader->notified(errorCode, numberOfBytesTransfered);
 }
 
 /*!