+++ /dev/null
-#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;
-}
-
projects / quassel.git / blobdiff