Q{LocalSocket|Process}/Win: handle write errors

To match the Unix behavior, we should emit errorOccurred() signal and
close the channel if the write operation fails.

Change-Id: Iac3acb18dbbfe6e7e8afb2555d9adaff1fe98d0f
Reviewed-by: Oswald Buddenhagen <oswald.buddenhagen@gmx.de>
Reviewed-by: Mårten Nordheim <marten.nordheim@qt.io>

1 files changed, 12 insertions, 0 deletions

diff --git a/src/network/socket/qlocalsocket_win.cpp b/src/network/socket/qlocalsocket_win.cpp
index c4da59c278..019829cc9c 100644
--- a/src/network/socket/qlocalsocket_win.cpp
+++ b/src/network/socket/qlocalsocket_win.cpp
@@ -310,6 +310,8 @@ qint64 QLocalSocket::writeData(const char *data, qint64 len)
         d->pipeWriter = new QWindowsPipeWriter(d->handle, this);
         QObjectPrivate::connect(d->pipeWriter, &QWindowsPipeWriter::bytesWritten,
                                 d, &QLocalSocketPrivate::_q_bytesWritten);
+        QObjectPrivate::connect(d->pipeWriter, &QWindowsPipeWriter::writeFailed,
+                                d, &QLocalSocketPrivate::_q_writeFailed);
     }
 
     if (d->isWriteChunkCached(data, len))
@@ -455,6 +457,16 @@ void QLocalSocketPrivate::_q_bytesWritten(qint64 bytes)
         q->disconnectFromServer();
 }
 
+void QLocalSocketPrivate::_q_writeFailed()
+{
+    Q_Q(QLocalSocket);
+    error = QLocalSocket::PeerClosedError;
+    errorString = QLocalSocket::tr("Remote closed");
+    emit q->errorOccurred(error);
+
+    _q_pipeClosed();
+}
+
 qintptr QLocalSocket::socketDescriptor() const
 {
     Q_D(const QLocalSocket);