diff options
Diffstat (limited to 'tests/auto/qlocalsocket/tst_qlocalsocket.cpp')
| -rw-r--r-- | tests/auto/qlocalsocket/tst_qlocalsocket.cpp | 1120 |
1 files changed, 0 insertions, 1120 deletions
diff --git a/tests/auto/qlocalsocket/tst_qlocalsocket.cpp b/tests/auto/qlocalsocket/tst_qlocalsocket.cpp deleted file mode 100644 index 3dc5e7392f..0000000000 --- a/tests/auto/qlocalsocket/tst_qlocalsocket.cpp +++ /dev/null @@ -1,1120 +0,0 @@ -/**************************************************************************** -** -** Copyright (C) 2011 Nokia Corporation and/or its subsidiary(-ies). -** All rights reserved. -** Contact: Nokia Corporation (qt-info@nokia.com) -** -** This file is part of the test suite of the Qt Toolkit. -** -** $QT_BEGIN_LICENSE:LGPL$ -** GNU Lesser General Public License Usage -** This file may be used under the terms of the GNU Lesser General Public -** License version 2.1 as published by the Free Software Foundation and -** appearing in the file LICENSE.LGPL included in the packaging of this -** file. Please review the following information to ensure the GNU Lesser -** General Public License version 2.1 requirements will be met: -** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. -** -** In addition, as a special exception, Nokia gives you certain additional -** rights. These rights are described in the Nokia Qt LGPL Exception -** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. -** -** GNU General Public License Usage -** Alternatively, this file may be used under the terms of the GNU General -** Public License version 3.0 as published by the Free Software Foundation -** and appearing in the file LICENSE.GPL included in the packaging of this -** file. Please review the following information to ensure the GNU General -** Public License version 3.0 requirements will be met: -** http://www.gnu.org/copyleft/gpl.html. -** -** Other Usage -** Alternatively, this file may be used in accordance with the terms and -** conditions contained in a signed written agreement between you and Nokia. -** -** -** -** -** -** $QT_END_LICENSE$ -** -****************************************************************************/ - - -#include <QtTest/QtTest> - -#include <qtextstream.h> -#include <QtNetwork/qlocalsocket.h> -#include <QtNetwork/qlocalserver.h> -#include "../../shared/util.h" - -#ifdef Q_OS_SYMBIAN - #include <unistd.h> -#endif -//TESTED_CLASS=QLocalServer, QLocalSocket -//TESTED_FILES=network/socket/qlocalserver.cpp network/socket/qlocalsocket.cpp -#ifdef Q_OS_SYMBIAN - #define STRINGIFY(x) #x - #define TOSTRING(x) STRINGIFY(x) - #define SRCDIR "C:/Private/" TOSTRING(SYMBIAN_SRCDIR_UID) "/" -#endif -Q_DECLARE_METATYPE(QLocalSocket::LocalSocketError) -Q_DECLARE_METATYPE(QLocalSocket::LocalSocketState) - -class tst_QLocalSocket : public QObject -{ - Q_OBJECT - -public: - tst_QLocalSocket(); - virtual ~tst_QLocalSocket(); - -public Q_SLOTS: - void init(); - void cleanup(); - -private slots: - // basics - void server_basic(); - void server_connectionsCount(); - void socket_basic(); - - void listen_data(); - void listen(); - - void listenAndConnect_data(); - void listenAndConnect(); - - void sendData_data(); - void sendData(); - - void readBufferOverflow(); - - void fullPath(); - - void hitMaximumConnections_data(); - void hitMaximumConnections(); - - void setSocketDescriptor(); - - void threadedConnection_data(); - void threadedConnection(); - - void processConnection_data(); - void processConnection(); - - void longPath(); - void waitForDisconnect(); - void waitForDisconnectByServer(); - - void removeServer(); - - void recycleServer(); - - void multiConnect(); - void writeOnlySocket(); - void writeToClientAndDisconnect(); - void debug(); - void bytesWrittenSignal(); - void syncDisconnectNotify(); - void asyncDisconnectNotify(); - -#ifdef Q_OS_SYMBIAN -private: - void unlink(QString serverName); -#endif -}; - -tst_QLocalSocket::tst_QLocalSocket() -{ - if (!QFile::exists("lackey/lackey" -#ifdef Q_OS_WIN - ".exe" -#endif - )) - qWarning() << "lackey executable doesn't exists!"; -} - -tst_QLocalSocket::~tst_QLocalSocket() -{ -} - -void tst_QLocalSocket::init() -{ - qRegisterMetaType<QLocalSocket::LocalSocketState>("QLocalSocket::LocalSocketState"); - qRegisterMetaType<QLocalSocket::LocalSocketError>("QLocalSocket::LocalSocketError"); -} - -void tst_QLocalSocket::cleanup() -{ -} - -class LocalServer : public QLocalServer -{ - Q_OBJECT - -public: - LocalServer() : QLocalServer() - { - connect(this, SIGNAL(newConnection()), this, SLOT(slotNewConnection())); - } - - bool listen(const QString &name) - { - removeServer(name); - return QLocalServer::listen(name); - } - - QList<int> hits; - -protected: - void incomingConnection(quintptr socketDescriptor) - { - hits.append(socketDescriptor); - QLocalServer::incomingConnection(socketDescriptor); - } - -private slots: - void slotNewConnection() { - QVERIFY(!hits.isEmpty()); - QVERIFY(hasPendingConnections()); - } -}; - -class LocalSocket : public QLocalSocket -{ - Q_OBJECT - -public: - LocalSocket(QObject *parent = 0) : QLocalSocket(parent) - { - connect(this, SIGNAL(connected()), - this, SLOT(slotConnected())); - connect(this, SIGNAL(disconnected()), - this, SLOT(slotDisconnected())); - connect(this, SIGNAL(error(QLocalSocket::LocalSocketError)), - this, SLOT(slotError(QLocalSocket::LocalSocketError))); - connect(this, SIGNAL(stateChanged(QLocalSocket::LocalSocketState)), - this, SLOT(slotStateChanged(QLocalSocket::LocalSocketState))); - connect(this, SIGNAL(readyRead()), - this, SLOT(slotReadyRead())); - } - -private slots: - void slotConnected() - { - QCOMPARE(state(), QLocalSocket::ConnectedState); - } - void slotDisconnected() - { - QCOMPARE(state(), QLocalSocket::UnconnectedState); - } - void slotError(QLocalSocket::LocalSocketError newError) - { - QVERIFY(errorString() != "Unknown error"); - QCOMPARE(error(), newError); - } - void slotStateChanged(QLocalSocket::LocalSocketState newState) - { - QCOMPARE(state(), newState); - } - void slotReadyRead() - { - QVERIFY(bytesAvailable() > 0); - } -}; - -// basic test make sure no segfaults and check default values -void tst_QLocalSocket::server_basic() -{ - LocalServer server; - QSignalSpy spyNewConnection(&server, SIGNAL(newConnection())); - server.close(); - QCOMPARE(server.errorString(), QString()); - QCOMPARE(server.hasPendingConnections(), false); - QCOMPARE(server.isListening(), false); - QCOMPARE(server.maxPendingConnections(), 30); - QCOMPARE(server.nextPendingConnection(), (QLocalSocket*)0); - QCOMPARE(server.serverName(), QString()); - QCOMPARE(server.fullServerName(), QString()); - QCOMPARE(server.serverError(), QAbstractSocket::UnknownSocketError); - server.setMaxPendingConnections(20); - bool timedOut = true; - QCOMPARE(server.waitForNewConnection(3000, &timedOut), false); - QVERIFY(!timedOut); - QCOMPARE(server.listen(QString()), false); - - QCOMPARE(server.hits.count(), 0); - QCOMPARE(spyNewConnection.count(), 0); -} - -void tst_QLocalSocket::server_connectionsCount() -{ - LocalServer server; - server.setMaxPendingConnections(10); - QCOMPARE(server.maxPendingConnections(), 10); -} - -// basic test make sure no segfaults and check default values -void tst_QLocalSocket::socket_basic() -{ - LocalSocket socket; - QSignalSpy spyConnected(&socket, SIGNAL(connected())); - QSignalSpy spyDisconnected(&socket, SIGNAL(disconnected())); - QSignalSpy spyError(&socket, SIGNAL(error(QLocalSocket::LocalSocketError))); - QSignalSpy spyStateChanged(&socket, SIGNAL(stateChanged(QLocalSocket::LocalSocketState))); - QSignalSpy spyReadyRead(&socket, SIGNAL(readyRead())); - - QCOMPARE(socket.serverName(), QString()); - QCOMPARE(socket.fullServerName(), QString()); - socket.abort(); - QVERIFY(socket.bytesAvailable() == 0); - QVERIFY(socket.bytesToWrite() == 0); - QCOMPARE(socket.canReadLine(), false); - socket.close(); - socket.disconnectFromServer(); - QCOMPARE(QLocalSocket::UnknownSocketError, socket.error()); - QVERIFY(socket.errorString() != QString()); - QCOMPARE(socket.flush(), false); - QCOMPARE(socket.isValid(), false); - QVERIFY(socket.readBufferSize() == 0); - socket.setReadBufferSize(0); - //QCOMPARE(socket.socketDescriptor(), -1); - QCOMPARE(socket.state(), QLocalSocket::UnconnectedState); - QCOMPARE(socket.waitForConnected(0), false); - QCOMPARE(socket.waitForDisconnected(0), false); - QCOMPARE(socket.waitForReadyRead(0), false); - - QCOMPARE(spyConnected.count(), 0); - QCOMPARE(spyDisconnected.count(), 0); - QCOMPARE(spyError.count(), 0); - QCOMPARE(spyStateChanged.count(), 0); - QCOMPARE(spyReadyRead.count(), 0); -} - -void tst_QLocalSocket::listen_data() -{ - QTest::addColumn<QString>("name"); - QTest::addColumn<bool>("canListen"); - QTest::addColumn<bool>("close"); - QTest::newRow("null") << QString() << false << false; - QTest::newRow("tst_localsocket") << "tst_localsocket" << true << true; - QTest::newRow("tst_localsocket") << "tst_localsocket" << true << false; -} - -// start a server that listens, but don't connect a socket, make sure everything is in order -void tst_QLocalSocket::listen() -{ - LocalServer server; - QSignalSpy spyNewConnection(&server, SIGNAL(newConnection())); - - QFETCH(QString, name); -#ifdef Q_OS_SYMBIAN - unlink(name); -#endif - QFETCH(bool, canListen); - QFETCH(bool, close); - QVERIFY2((server.listen(name) == canListen), server.errorString().toLatin1().constData()); - - // test listening - QCOMPARE(server.serverName(), name); - QVERIFY(server.fullServerName().contains(name)); - QCOMPARE(server.isListening(), canListen); - QCOMPARE(server.hasPendingConnections(), false); - QCOMPARE(server.nextPendingConnection(), (QLocalSocket*)0); - QCOMPARE(server.hits.count(), 0); - QCOMPARE(spyNewConnection.count(), 0); - if (canListen) { - QVERIFY(server.errorString() == QString()); - QCOMPARE(server.serverError(), QAbstractSocket::UnknownSocketError); - // already isListening - QVERIFY(!server.listen(name)); - } else { - QVERIFY(server.errorString() != QString()); - QCOMPARE(server.serverError(), QAbstractSocket::HostNotFoundError); - } - QCOMPARE(server.maxPendingConnections(), 30); - bool timedOut = false; - QCOMPARE(server.waitForNewConnection(3000, &timedOut), false); - QCOMPARE(timedOut, canListen); - if (close) - server.close(); -} - -void tst_QLocalSocket::listenAndConnect_data() -{ - QTest::addColumn<QString>("name"); - QTest::addColumn<bool>("canListen"); - QTest::addColumn<int>("connections"); - for (int i = 0; i < 3; ++i) { - int connections = i; - if (i == 2) - connections = 5; - QTest::newRow(QString("null %1").arg(i).toLatin1()) << QString() << false << connections; - QTest::newRow(QString("tst_localsocket %1").arg(i).toLatin1()) << "tst_localsocket" << true << connections; - } -} - -void tst_QLocalSocket::listenAndConnect() -{ - LocalServer server; - QSignalSpy spyNewConnection(&server, SIGNAL(newConnection())); - - QFETCH(QString, name); - QFETCH(bool, canListen); -#ifdef Q_OS_SYMBIAN - unlink(name); -#endif - QCOMPARE(server.listen(name), canListen); - QTest::qWait(1000); - //QVERIFY(!server.errorString().isEmpty()); - QCOMPARE(server.serverError(), - canListen ? QAbstractSocket::UnknownSocketError : QAbstractSocket::HostNotFoundError); - - // test creating connection(s) - QFETCH(int, connections); - QList<QLocalSocket*> sockets; - for (int i = 0; i < connections; ++i) { - LocalSocket *socket = new LocalSocket; - - QSignalSpy spyConnected(socket, SIGNAL(connected())); - QSignalSpy spyDisconnected(socket, SIGNAL(disconnected())); - QSignalSpy spyError(socket, SIGNAL(error(QLocalSocket::LocalSocketError))); - QSignalSpy spyStateChanged(socket, SIGNAL(stateChanged(QLocalSocket::LocalSocketState))); - QSignalSpy spyReadyRead(socket, SIGNAL(readyRead())); - - socket->connectToServer(name); -#if defined(QT_LOCALSOCKET_TCP) - QTest::qWait(250); -#endif - - QCOMPARE(socket->serverName(), name); - QVERIFY(socket->fullServerName().contains(name)); - sockets.append(socket); - if (canListen) { - QVERIFY(socket->waitForConnected()); - QVERIFY(socket->isValid()); - QCOMPARE(socket->errorString(), QString("Unknown error")); - QCOMPARE(socket->error(), QLocalSocket::UnknownSocketError); - QCOMPARE(socket->state(), QLocalSocket::ConnectedState); - //QVERIFY(socket->socketDescriptor() != -1); - QCOMPARE(spyError.count(), 0); - } else { - QVERIFY(socket->errorString() != QString()); - QVERIFY(socket->error() != QLocalSocket::UnknownSocketError); - QCOMPARE(socket->state(), QLocalSocket::UnconnectedState); - //QVERIFY(socket->socketDescriptor() == -1); - QCOMPARE(qVariantValue<QLocalSocket::LocalSocketError>(spyError.first()[0]), - QLocalSocket::ServerNotFoundError); - } - - QVERIFY(socket->bytesAvailable() == 0); - QVERIFY(socket->bytesToWrite() == 0); - QCOMPARE(socket->canReadLine(), false); - QCOMPARE(socket->flush(), false); - QCOMPARE(socket->isValid(), canListen); - QCOMPARE(socket->readBufferSize(), (qint64)0); - QCOMPARE(socket->waitForConnected(0), canListen); - QCOMPARE(socket->waitForReadyRead(0), false); - - QTRY_COMPARE(spyConnected.count(), canListen ? 1 : 0); - QCOMPARE(spyDisconnected.count(), 0); - - // error signals - QVERIFY(spyError.count() >= 0); - if (canListen) { - if (spyError.count() > 0) - QCOMPARE(qVariantValue<QLocalSocket::LocalSocketError>(spyError.first()[0]), - QLocalSocket::SocketTimeoutError); - } else { - QCOMPARE(qVariantValue<QLocalSocket::LocalSocketError>(spyError.first()[0]), - QLocalSocket::ServerNotFoundError); - } - - // Check first and last state - QCOMPARE(qVariantValue<QLocalSocket::LocalSocketState>(spyStateChanged.first()[0]), - QLocalSocket::ConnectingState); -#if 0 - for (int j = 0; j < spyStateChanged.count(); ++j) { - QLocalSocket::LocalSocketState s; - s = qVariantValue<QLocalSocket::LocalSocketState>(spyStateChanged.at(j).at(0)); - qDebug() << s; - } -#endif - if (canListen) - QCOMPARE(qVariantValue<QLocalSocket::LocalSocketState>(spyStateChanged.last()[0]), - QLocalSocket::ConnectedState); - QCOMPARE(spyStateChanged.count(), 2); - QCOMPARE(spyReadyRead.count(), 0); - - bool timedOut = true; - QCOMPARE(server.waitForNewConnection(3000, &timedOut), canListen); - QVERIFY(!timedOut); - QCOMPARE(server.hasPendingConnections(), canListen); - QCOMPARE(server.isListening(), canListen); - // NOTE: socket disconnecting is not tested here - - // server checks post connection - if (canListen) { - QCOMPARE(server.serverName(), name); - QVERIFY(server.fullServerName().contains(name)); - QVERIFY(server.nextPendingConnection() != (QLocalSocket*)0); - QTRY_COMPARE(server.hits.count(), i + 1); - QCOMPARE(spyNewConnection.count(), i + 1); - QVERIFY(server.errorString() == QString()); - QCOMPARE(server.serverError(), QAbstractSocket::UnknownSocketError); - } else { - QVERIFY(server.serverName().isEmpty()); - QVERIFY(server.fullServerName().isEmpty()); - QVERIFY(server.nextPendingConnection() == (QLocalSocket*)0); - QCOMPARE(spyNewConnection.count(), 0); - QCOMPARE(server.hits.count(), 0); - QVERIFY(server.errorString() != QString()); - QCOMPARE(server.serverError(), QAbstractSocket::HostNotFoundError); - } - } - qDeleteAll(sockets.begin(), sockets.end()); - - server.close(); - - QCOMPARE(server.hits.count(), (canListen ? connections : 0)); - QCOMPARE(spyNewConnection.count(), (canListen ? connections : 0)); -} - -void tst_QLocalSocket::sendData_data() -{ - listenAndConnect_data(); -} - -void tst_QLocalSocket::sendData() -{ - QFETCH(QString, name); -#ifdef Q_OS_SYMBIAN - unlink(name); -#endif - QFETCH(bool, canListen); - - LocalServer server; - QSignalSpy spy(&server, SIGNAL(newConnection())); - - QCOMPARE(server.listen(name), canListen); - - LocalSocket socket; - QSignalSpy spyConnected(&socket, SIGNAL(connected())); - QSignalSpy spyDisconnected(&socket, SIGNAL(disconnected())); - QSignalSpy spyError(&socket, SIGNAL(error(QLocalSocket::LocalSocketError))); - QSignalSpy spyStateChanged(&socket, SIGNAL(stateChanged(QLocalSocket::LocalSocketState))); - QSignalSpy spyReadyRead(&socket, SIGNAL(readyRead())); - - // test creating a connection - socket.connectToServer(name); - bool timedOut = true; - - QCOMPARE(server.waitForNewConnection(3000, &timedOut), canListen); - -#if defined(QT_LOCALSOCKET_TCP) - QTest::qWait(250); -#endif - QVERIFY(!timedOut); - QCOMPARE(spyConnected.count(), canListen ? 1 : 0); - QCOMPARE(socket.state(), canListen ? QLocalSocket::ConnectedState : QLocalSocket::UnconnectedState); - - // test sending/receiving data - if (server.hasPendingConnections()) { - QString testLine = "test"; -#ifdef Q_OS_SYMBIAN - for (int i = 0; i < 25 * 1024; ++i) -#else - for (int i = 0; i < 50000; ++i) -#endif - testLine += "a"; - QLocalSocket *serverSocket = server.nextPendingConnection(); - QVERIFY(serverSocket); - QCOMPARE(serverSocket->state(), QLocalSocket::ConnectedState); - QTextStream out(serverSocket); - QTextStream in(&socket); - out << testLine << endl; - bool wrote = serverSocket->waitForBytesWritten(3000); - - if (!socket.canReadLine()) - QVERIFY(socket.waitForReadyRead()); - - QVERIFY(socket.bytesAvailable() >= 0); - QCOMPARE(socket.bytesToWrite(), (qint64)0); - QCOMPARE(socket.flush(), false); - QCOMPARE(socket.isValid(), canListen); - QCOMPARE(socket.readBufferSize(), (qint64)0); - QCOMPARE(spyReadyRead.count(), 1); - - QVERIFY(testLine.startsWith(in.readLine())); - - QVERIFY(wrote || serverSocket->waitForBytesWritten(1000)); - - QCOMPARE(serverSocket->errorString(), QString("Unknown error")); - QCOMPARE(socket.errorString(), QString("Unknown error")); - } - - socket.disconnectFromServer(); - QCOMPARE(spyConnected.count(), canListen ? 1 : 0); - QCOMPARE(spyDisconnected.count(), canListen ? 1 : 0); - QCOMPARE(spyError.count(), canListen ? 0 : 1); - QCOMPARE(spyStateChanged.count(), canListen ? 4 : 2); - QCOMPARE(spyReadyRead.count(), canListen ? 1 : 0); - - server.close(); - - QCOMPARE(server.hits.count(), (canListen ? 1 : 0)); - QCOMPARE(spy.count(), (canListen ? 1 : 0)); -} - -void tst_QLocalSocket::readBufferOverflow() -{ - const int readBufferSize = 128; - const int dataBufferSize = readBufferSize * 2; - const QString serverName = QLatin1String("myPreciousTestServer"); - LocalServer server; - server.listen(serverName); - QVERIFY(server.isListening()); - - LocalSocket client; - client.setReadBufferSize(readBufferSize); - client.connectToServer(serverName); - - bool timedOut = true; - QVERIFY(server.waitForNewConnection(3000, &timedOut)); - QVERIFY(!timedOut); - - QCOMPARE(client.state(), QLocalSocket::ConnectedState); - QVERIFY(server.hasPendingConnections()); - - QLocalSocket* serverSocket = server.nextPendingConnection(); - char buffer[dataBufferSize]; - memset(buffer, 0, dataBufferSize); - serverSocket->write(buffer, dataBufferSize); - serverSocket->waitForBytesWritten(); - - // wait until the first 128 bytes are ready to read - QVERIFY(client.waitForReadyRead()); - QCOMPARE(client.read(buffer, readBufferSize), qint64(readBufferSize)); - // wait until the second 128 bytes are ready to read - QVERIFY(client.waitForReadyRead()); - QCOMPARE(client.read(buffer, readBufferSize), qint64(readBufferSize)); - // no more bytes available - QVERIFY(client.bytesAvailable() == 0); -} - -// QLocalSocket/Server can take a name or path, check that it works as expected -void tst_QLocalSocket::fullPath() -{ - QLocalServer server; - QString name = "qlocalsocket_pathtest"; -#if defined(Q_OS_SYMBIAN) - QString path = ""; -#elif defined(QT_LOCALSOCKET_TCP) - QString path = "QLocalServer"; -#elif defined(Q_OS_WIN) - QString path = "\\\\.\\pipe\\"; -#else - QString path = "/tmp"; -#endif - QString serverName = path + '/' + name; - QVERIFY2(server.listen(serverName), server.errorString().toLatin1().constData()); - QCOMPARE(server.serverName(), serverName); - QCOMPARE(server.fullServerName(), serverName); - - LocalSocket socket; - socket.connectToServer(serverName); - - QCOMPARE(socket.serverName(), serverName); - QCOMPARE(socket.fullServerName(), serverName); - socket.disconnectFromServer(); -#ifdef QT_LOCALSOCKET_TCP - QTest::qWait(250); -#endif - QCOMPARE(socket.serverName(), QString()); - QCOMPARE(socket.fullServerName(), QString()); -} - -void tst_QLocalSocket::hitMaximumConnections_data() -{ - QTest::addColumn<int>("max"); - QTest::newRow("none") << 0; - QTest::newRow("1") << 1; - QTest::newRow("3") << 3; -} - -void tst_QLocalSocket::hitMaximumConnections() -{ - QFETCH(int, max); - LocalServer server; - QString name = "tst_localsocket"; -#ifdef Q_OS_SYMBIAN - unlink(name); -#endif - server.setMaxPendingConnections(max); - QVERIFY2(server.listen(name), server.errorString().toLatin1().constData()); - int connections = server.maxPendingConnections() + 1; - QList<QLocalSocket*> sockets; - for (int i = 0; i < connections; ++i) { - LocalSocket *socket = new LocalSocket; - sockets.append(socket); - socket->connectToServer(name); - } - bool timedOut = true; - QVERIFY(server.waitForNewConnection(3000, &timedOut)); - QVERIFY(!timedOut); - QVERIFY(server.hits.count() > 0); - qDeleteAll(sockets.begin(), sockets.end()); -} - -// check that state and mode are kept -void tst_QLocalSocket::setSocketDescriptor() -{ - LocalSocket socket; - quintptr minusOne = -1; - socket.setSocketDescriptor(minusOne, QLocalSocket::ConnectingState, QIODevice::Append); - QCOMPARE(socket.socketDescriptor(), minusOne); - QCOMPARE(socket.state(), QLocalSocket::ConnectingState); - QVERIFY((socket.openMode() & QIODevice::Append) != 0); -} - -class Client : public QThread -{ - -public: - void run() - { - QString testLine = "test"; - LocalSocket socket; - QSignalSpy spyReadyRead(&socket, SIGNAL(readyRead())); - socket.connectToServer("qlocalsocket_threadtest"); - QVERIFY(socket.waitForConnected(1000)); - - // We should *not* have this signal yet! - QCOMPARE(spyReadyRead.count(), 0); - socket.waitForReadyRead(); - QCOMPARE(spyReadyRead.count(), 1); - QTextStream in(&socket); - QCOMPARE(in.readLine(), testLine); - socket.close(); - } -}; - -class Server : public QThread -{ - -public: - int clients; - QMutex mutex; - QWaitCondition wc; - void run() - { - QString testLine = "test"; - LocalServer server; - server.setMaxPendingConnections(10); - QVERIFY2(server.listen("qlocalsocket_threadtest"), - server.errorString().toLatin1().constData()); - mutex.lock(); - wc.wakeAll(); - mutex.unlock(); - int done = clients; - while (done > 0) { - bool timedOut = true; - QVERIFY(server.waitForNewConnection(7000, &timedOut)); - QVERIFY(!timedOut); - QLocalSocket *serverSocket = server.nextPendingConnection(); - QVERIFY(serverSocket); - QTextStream out(serverSocket); - out << testLine << endl; - QCOMPARE(serverSocket->state(), QLocalSocket::ConnectedState); - QVERIFY2(serverSocket->waitForBytesWritten(), serverSocket->errorString().toLatin1().constData()); - QCOMPARE(serverSocket->errorString(), QString("Unknown error")); - --done; - delete serverSocket; - } - QCOMPARE(server.hits.count(), clients); - } -}; - -void tst_QLocalSocket::threadedConnection_data() -{ - QTest::addColumn<int>("threads"); - QTest::newRow("1 client") << 1; - QTest::newRow("2 clients") << 2; - QTest::newRow("5 clients") << 5; -#ifndef Q_OS_WINCE - QTest::newRow("10 clients") << 10; - QTest::newRow("20 clients") << 20; -#endif -} - -void tst_QLocalSocket::threadedConnection() -{ -#ifdef Q_OS_SYMBIAN - unlink("qlocalsocket_threadtest"); -#endif - - QFETCH(int, threads); - Server server; -#if defined(Q_OS_SYMBIAN) - server.setStackSize(0x14000); -#endif - server.clients = threads; - server.mutex.lock(); - server.start(); - server.wc.wait(&server.mutex); - - QList<Client*> clients; - for (int i = 0; i < threads; ++i) { - clients.append(new Client()); -#if defined(Q_OS_SYMBIAN) - clients.last()->setStackSize(0x14000); -#endif - clients.last()->start(); - } - - server.wait(); - while (!clients.isEmpty()) { - QVERIFY(clients.first()->wait(3000)); - delete clients.takeFirst(); - } -} - -void tst_QLocalSocket::processConnection_data() -{ - QTest::addColumn<int>("processes"); - QTest::newRow("1 client") << 1; -#ifndef Q_OS_WIN - QTest::newRow("2 clients") << 2; - QTest::newRow("5 clients") << 5; -#endif - QTest::newRow("30 clients") << 30; -} - -/*! - Create external processes that produce and consume. - */ -void tst_QLocalSocket::processConnection() -{ -#if defined(QT_NO_PROCESS) || defined(Q_CC_NOKIAX86) - QSKIP("Qt was compiled with QT_NO_PROCESS", SkipAll); -#else - QFETCH(int, processes); - QStringList serverArguments = QStringList() << SRCDIR "lackey/scripts/server.js" << QString::number(processes); - QProcess producer; - producer.setProcessChannelMode(QProcess::ForwardedChannels); -#ifdef Q_WS_QWS - serverArguments << "-qws"; -#endif - QList<QProcess*> consumers; - producer.start("lackey/lackey", serverArguments); - QVERIFY(producer.waitForStarted(-1)); - QTest::qWait(2000); - for (int i = 0; i < processes; ++i) { - QStringList arguments = QStringList() << SRCDIR "lackey/scripts/client.js"; -#ifdef Q_WS_QWS - arguments << "-qws"; -#endif - QProcess *p = new QProcess; - p->setProcessChannelMode(QProcess::ForwardedChannels); - consumers.append(p); - p->start("lackey/lackey", arguments); - } - - while (!consumers.isEmpty()) { - consumers.first()->waitForFinished(20000); - QCOMPARE(consumers.first()->exitStatus(), QProcess::NormalExit); - QCOMPARE(consumers.first()->exitCode(), 0); - QProcess *consumer = consumers.takeFirst(); - consumer->terminate(); - delete consumer; - } - producer.waitForFinished(15000); -#endif -} - -void tst_QLocalSocket::longPath() -{ -#ifndef Q_OS_WIN - QString name; - for (int i = 0; i < 256; ++i) - name += 'a'; - LocalServer server; - QVERIFY(!server.listen(name)); - - LocalSocket socket; - socket.connectToServer(name); - QCOMPARE(socket.state(), QLocalSocket::UnconnectedState); -#endif -} - -void tst_QLocalSocket::waitForDisconnect() -{ - QString name = "tst_localsocket"; -#ifdef Q_OS_SYMBIAN - unlink(name); -#endif - LocalServer server; - QVERIFY(server.listen(name)); - LocalSocket socket; - socket.connectToServer(name); - QVERIFY(socket.waitForConnected(3000)); - QVERIFY(server.waitForNewConnection(3000)); - QLocalSocket *serverSocket = server.nextPendingConnection(); - QVERIFY(serverSocket); - socket.disconnectFromServer(); - QTime timer; - timer.start(); - QVERIFY(serverSocket->waitForDisconnected(3000)); - QVERIFY(timer.elapsed() < 2000); -} - -void tst_QLocalSocket::waitForDisconnectByServer() -{ - QString name = "tst_localsocket"; - LocalServer server; - QVERIFY(server.listen(name)); - LocalSocket socket; - QSignalSpy spy(&socket, SIGNAL(disconnected())); - QVERIFY(spy.isValid()); - socket.connectToServer(name); - QVERIFY(socket.waitForConnected(3000)); - QVERIFY(server.waitForNewConnection(3000)); - QLocalSocket *serverSocket = server.nextPendingConnection(); - QVERIFY(serverSocket); - serverSocket->close(); - QVERIFY(serverSocket->state() == QLocalSocket::UnconnectedState); - QVERIFY(socket.waitForDisconnected(3000)); - QCOMPARE(spy.count(), 1); -} - -void tst_QLocalSocket::removeServer() -{ - // this is a hostile takeover, but recovering from a crash results in the same - QLocalServer server, server2; - QVERIFY(QLocalServer::removeServer("cleanuptest")); - QVERIFY(server.listen("cleanuptest")); -#ifndef Q_OS_WIN - // on Windows, there can be several sockets listening on the same pipe - // on Unix, there can only be one socket instance - QVERIFY(! server2.listen("cleanuptest")); -#endif - QVERIFY(QLocalServer::removeServer("cleanuptest")); - QVERIFY(server2.listen("cleanuptest")); -} - -void tst_QLocalSocket::recycleServer() -{ -#ifdef Q_OS_SYMBIAN - unlink("recycletest1"); -#endif - - QLocalServer server; - QLocalSocket client; - - QVERIFY(server.listen("recycletest1")); - client.connectToServer("recycletest1"); - QVERIFY(client.waitForConnected(201)); - QVERIFY(server.waitForNewConnection(201)); - QVERIFY(server.nextPendingConnection() != 0); - - server.close(); - client.disconnectFromServer(); - qApp->processEvents(); - - QVERIFY(server.listen("recycletest2")); - client.connectToServer("recycletest2"); - QVERIFY(client.waitForConnected(202)); - QVERIFY(server.waitForNewConnection(202)); - QVERIFY(server.nextPendingConnection() != 0); -} - -void tst_QLocalSocket::multiConnect() -{ - QLocalServer server; - QLocalSocket client1; - QLocalSocket client2; - QLocalSocket client3; - - QVERIFY(server.listen("multiconnect")); - - client1.connectToServer("multiconnect"); - client2.connectToServer("multiconnect"); - client3.connectToServer("multiconnect"); - - QVERIFY(client1.waitForConnected(201)); - QVERIFY(client2.waitForConnected(202)); - QVERIFY(client3.waitForConnected(203)); - - QVERIFY(server.waitForNewConnection(201)); - QVERIFY(server.nextPendingConnection() != 0); - QVERIFY(server.waitForNewConnection(202)); - QVERIFY(server.nextPendingConnection() != 0); - QVERIFY(server.waitForNewConnection(203)); - QVERIFY(server.nextPendingConnection() != 0); -} - -void tst_QLocalSocket::writeOnlySocket() -{ - QLocalServer server; -#ifdef Q_OS_SYMBIAN - unlink("writeOnlySocket"); -#endif - QVERIFY(server.listen("writeOnlySocket")); - - QLocalSocket client; - client.connectToServer("writeOnlySocket", QIODevice::WriteOnly); - QVERIFY(client.waitForConnected()); -#if defined(Q_OS_SYMBIAN) - QTest::qWait(250); -#endif - QVERIFY(server.waitForNewConnection(200)); - QLocalSocket* serverSocket = server.nextPendingConnection(); - QVERIFY(serverSocket); - - QCOMPARE(client.bytesAvailable(), qint64(0)); - QCOMPARE(client.state(), QLocalSocket::ConnectedState); -} - -void tst_QLocalSocket::writeToClientAndDisconnect() -{ -#ifdef Q_OS_SYMBIAN - unlink("writeAndDisconnectServer"); -#endif - - QLocalServer server; - QLocalSocket client; - QSignalSpy readChannelFinishedSpy(&client, SIGNAL(readChannelFinished())); - - QVERIFY(server.listen("writeAndDisconnectServer")); - client.connectToServer("writeAndDisconnectServer"); - QVERIFY(client.waitForConnected(200)); - QVERIFY(server.waitForNewConnection(200)); - QLocalSocket* clientSocket = server.nextPendingConnection(); - QVERIFY(clientSocket); - - char buffer[100]; - memset(buffer, 0, sizeof(buffer)); - QCOMPARE(clientSocket->write(buffer, sizeof(buffer)), (qint64)sizeof(buffer)); - clientSocket->waitForBytesWritten(); - clientSocket->close(); - server.close(); - - QTRY_COMPARE(readChannelFinishedSpy.count(), 1); - QCOMPARE(client.read(buffer, sizeof(buffer)), (qint64)sizeof(buffer)); - client.waitForDisconnected(); - QCOMPARE(client.state(), QLocalSocket::UnconnectedState); -} - -void tst_QLocalSocket::debug() -{ - // Make sure this compiles - qDebug() << QLocalSocket::ConnectionRefusedError << QLocalSocket::UnconnectedState; -} - -class WriteThread : public QThread -{ -Q_OBJECT -public: - void run() { - QLocalSocket socket; - socket.connectToServer("qlocalsocket_readyread"); - - if (!socket.waitForConnected(3000)) - exec(); - connect(&socket, SIGNAL(bytesWritten(qint64)), - this, SLOT(bytesWritten(qint64)), Qt::QueuedConnection); - socket.write("testing\n"); - exec(); - } -public slots: - void bytesWritten(qint64) { - exit(); - } - -private: -}; - -/* - Tests the emission of the bytesWritten(qint64) - signal. - - Create a thread that will write to a socket. - If the bytesWritten(qint64) signal is generated, - the slot connected to it will exit the thread, - indicating test success. - -*/ -void tst_QLocalSocket::bytesWrittenSignal() -{ - QLocalServer server; - QVERIFY(server.listen("qlocalsocket_readyread")); - WriteThread writeThread; - writeThread.start(); - bool timedOut = false; - QVERIFY(server.waitForNewConnection(3000, &timedOut)); - QVERIFY(!timedOut); - QTest::qWait(2000); - QVERIFY(writeThread.wait(2000)); -} - -void tst_QLocalSocket::syncDisconnectNotify() -{ -#ifdef Q_OS_SYMBIAN - unlink("syncDisconnectNotify"); -#endif - - QLocalServer server; - QVERIFY(server.listen("syncDisconnectNotify")); - QLocalSocket client; - client.connectToServer("syncDisconnectNotify"); - QVERIFY(server.waitForNewConnection()); - QLocalSocket* serverSocket = server.nextPendingConnection(); - QVERIFY(serverSocket); - delete serverSocket; - QCOMPARE(client.waitForReadyRead(), false); -} - -void tst_QLocalSocket::asyncDisconnectNotify() -{ -#ifdef Q_OS_SYMBIAN - unlink("asyncDisconnectNotify"); -#endif - - QLocalServer server; - QVERIFY(server.listen("asyncDisconnectNotify")); - QLocalSocket client; - QSignalSpy disconnectedSpy(&client, SIGNAL(disconnected())); - client.connectToServer("asyncDisconnectNotify"); - QVERIFY(server.waitForNewConnection()); - QLocalSocket* serverSocket = server.nextPendingConnection(); - QVERIFY(serverSocket); - delete serverSocket; - QTRY_VERIFY(!disconnectedSpy.isEmpty()); -} - -#ifdef Q_OS_SYMBIAN -void tst_QLocalSocket::unlink(QString name) -{ - if(name.length() == 0) - return; - - QString fullName; - // determine the full server path - if (name.startsWith(QLatin1Char('/'))) { - fullName = name; - } else { - fullName = QDir::cleanPath(QDir::tempPath()); - fullName += QLatin1Char('/') + name; - fullName = QDir::toNativeSeparators(fullName); - } - - int result = ::unlink(fullName.toUtf8().data()); - - if(result != 0) { - qWarning() << "Unlinking " << fullName << " failed with " << strerror(errno); - } -} -#endif -QTEST_MAIN(tst_QLocalSocket) -#include "tst_qlocalsocket.moc" - |