X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcontrib%2Flibqxt-2007-10-24%2Fsrc%2Fnetwork%2Fqxtnamedpipe_win.cpp;fp=src%2Fcontrib%2Flibqxt-2007-10-24%2Fsrc%2Fnetwork%2Fqxtnamedpipe_win.cpp;h=d7fc6da3a7099ea5a4c2ce506bbb06ccb79bec5e;hp=0000000000000000000000000000000000000000;hb=a634acadbcf6017474f68a3eaf7cb632660e9e49;hpb=cd122ca8e0d2c0ffc5397e0a813c75d791a7e6e3

diff --git a/src/contrib/libqxt-2007-10-24/src/network/qxtnamedpipe_win.cpp b/src/contrib/libqxt-2007-10-24/src/network/qxtnamedpipe_win.cpp
new file mode 100644
index 00000000..d7fc6da3
--- /dev/null
+++ b/src/contrib/libqxt-2007-10-24/src/network/qxtnamedpipe_win.cpp
@@ -0,0 +1,202 @@
+#include <windows.h>
+#include <io.h>
+#include <QSocketNotifier>
+#include <QByteArray>
+#include "qxtnamedpipe.h"
+
+#define BUFSIZE 4096
+#define PIPE_TIMEOUT  (120*1000) /*120 seconds*/
+
+#include "qxtnamedpipe_win_p.h"
+
+void QxtNamedPipePrivate::bytesAvailable()
+{
+    char chBuf[BUFSIZE];
+    bool fSuccess = false;
+    DWORD cbRead = 0;
+
+    do
+    {
+        // Read from the pipe.
+
+        memset((void *)chBuf,0,BUFSIZE*sizeof(char));
+
+        fSuccess = ReadFile(
+                       this->win32Handle,      // pipe handle
+                       chBuf,                  // buffer to receive reply
+                       BUFSIZE*sizeof(char),  // size of buffer
+                       &cbRead,                // number of bytes read
+                       NULL);                  // not overlapped
+
+        if (! fSuccess && GetLastError() != ERROR_MORE_DATA)
+            break;
+
+        this->readBuffer.append(QByteArray(chBuf,cbRead));
+
+    }
+    while (!fSuccess);  // repeat loop if ERROR_MORE_DATA
+
+    emit readyRead();
+}
+
+QxtNamedPipe::QxtNamedPipe(const QString& name, QObject* parent) : QIODevice(parent)
+{
+    QXT_INIT_PRIVATE(QxtNamedPipe);
+    qxt_d().pipeName = name;
+    qxt_d().win32Handle = INVALID_HANDLE_VALUE;
+    qxt_d().fd = -1;
+    qxt_d().serverMode = false;
+    qxt_d().notify = 0;
+
+}
+
+bool QxtNamedPipe::open(QIODevice::OpenMode mode)
+{
+    int m = PIPE_ACCESS_DUPLEX;
+    int m_client = GENERIC_READ | GENERIC_WRITE;
+
+    if (!(mode & QIODevice::ReadOnly))
+    {
+        m = PIPE_ACCESS_OUTBOUND;
+        m_client = GENERIC_WRITE;
+    }
+    else if (!(mode & QIODevice::WriteOnly))
+    {
+        m = PIPE_ACCESS_INBOUND;
+        m_client = GENERIC_READ;
+    }
+
+    QString pipePrefix("\\\\.\\pipe\\");
+
+    // first try to open in client mode
+    qxt_d().win32Handle  = CreateFileA(qPrintable(pipePrefix+qxt_d().pipeName),   // pipe name
+                                       m_client,                      // read and write access
+                                       0,                             // no sharing
+                                       NULL,                          // default security attributes
+                                       OPEN_EXISTING ,                // opens a pipe
+                                       0,                             // default attributes
+                                       NULL);                         // no template file
+
+    //if we have no success create the pipe and open it
+    if (qxt_d().win32Handle == NULL || qxt_d().win32Handle == INVALID_HANDLE_VALUE)
+    {
+        qxt_d().win32Handle  =   CreateNamedPipeA(qPrintable(pipePrefix+qxt_d().pipeName),        //pipe Name must be \\.\pipe\userdefinedname
+                                 m,                                //read/write mode
+                                 PIPE_NOWAIT,                      //don't block
+                                 1,                                //max number of instances 1
+                                 BUFSIZE,                          //ouput buffer size allocate as needed
+                                 BUFSIZE,                          //input buffer size allocate as needed
+                                 PIPE_TIMEOUT,                     //default timeout value
+                                 NULL);                            //security attributes
+        if (qxt_d().win32Handle != NULL && qxt_d().win32Handle != INVALID_HANDLE_VALUE)
+            qxt_d().serverMode = true;
+    }
+    else
+    {
+        qxt_d().serverMode = false;
+
+        DWORD pipeMode = PIPE_NOWAIT;
+        SetNamedPipeHandleState(
+            qxt_d().win32Handle,    // pipe handle
+            &pipeMode,              // new pipe mode
+            NULL,                   // don't set maximum bytes
+            NULL);                  // don't set maximum time
+
+    }
+
+
+    if (qxt_d().win32Handle != NULL && qxt_d().win32Handle != INVALID_HANDLE_VALUE)
+    {
+        qxt_d().fd = _open_osfhandle((long)qxt_d().win32Handle,0); //FIXME that is not x64 compatible
+        setOpenMode ( mode);
+
+        if (!qxt_d().notify)
+            qxt_d().notify = new QSocketNotifier(qxt_d().fd,QSocketNotifier::Read,this);
+
+        qxt_d().notify->setEnabled(true);
+        connect(qxt_d().notify,SIGNAL(activated(int)),&qxt_d(),SLOT(bytesAvailable()));
+        connect(&qxt_d(),SIGNAL(readyRead()),this,SIGNAL(readyRead()));
+
+        return true;
+    }
+    else
+    {
+        return false;
+    }
+}
+
+bool QxtNamedPipe::open(const QString& name, QIODevice::OpenMode mode)
+{
+    qxt_d().pipeName = name;
+    return QxtNamedPipe::open(mode);
+}
+
+void QxtNamedPipe::close()
+{
+    if (qxt_d().win32Handle != NULL && qxt_d().win32Handle != INVALID_HANDLE_VALUE)
+    {
+        FlushFileBuffers(qxt_d().win32Handle);
+        if (qxt_d().serverMode)
+        {
+            DisconnectNamedPipe(qxt_d().win32Handle);
+        }
+
+        qxt_d().notify->setEnabled(false);
+        delete qxt_d().notify;
+        qxt_d().notify = 0;
+        qxt_d().readBuffer.clear();
+
+        //this will close native and C handle
+        _close(qxt_d().fd);
+        qxt_d().win32Handle = INVALID_HANDLE_VALUE;
+        qxt_d().fd = -1;
+    }
+    setOpenMode(QIODevice::NotOpen);
+}
+
+QByteArray QxtNamedPipe::readAvailableBytes()
+{
+    char ch;
+    QByteArray rv;
+    while (getChar(&ch)) rv += ch;
+    return rv;
+}
+
+qint64 QxtNamedPipe::bytesAvailable () const
+{
+    return qxt_d().readBuffer.size();
+}
+
+qint64 QxtNamedPipe::readData ( char * data, qint64 maxSize )
+{
+    qint64 toRead = qxt_d().readBuffer.size() < maxSize ? qxt_d().readBuffer.size() : maxSize;
+
+    memcpy(data,qxt_d().readBuffer.data(),toRead);
+    qxt_d().readBuffer.remove(0,toRead);
+
+    return toRead;
+
+}
+
+qint64 QxtNamedPipe::writeData ( const char * data, qint64 maxSize )
+{
+    DWORD bytesWritten = 0;
+
+    bool fSuccess = WriteFile(
+                        qxt_d().win32Handle,    // pipe handle
+                        data,                   // message
+                        maxSize,                // message length
+                        &bytesWritten,          // bytes written
+                        NULL);                  // not overlapped
+    if (!fSuccess)
+    {
+        return -1;
+    }
+    return bytesWritten;
+}
+
+bool QxtNamedPipe::isSequential () const
+{
+    return true;
+}
+