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=0000000000000000000000000000000000000000;hp=d7fc6da3a7099ea5a4c2ce506bbb06ccb79bec5e;hb=140d8a132103d2fa9baf55036e09b165624de167;hpb=97d674034551438238c568e8b42efb08e1ba7354

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
deleted file mode 100644
index d7fc6da3..00000000
--- a/src/contrib/libqxt-2007-10-24/src/network/qxtnamedpipe_win.cpp
+++ /dev/null
@@ -1,202 +0,0 @@
-#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;
-}
-