diff options
author | Holger Ihrig <holger.ihrig@nokia.com> | 2011-08-25 12:16:22 +0200 |
---|---|---|
committer | Holger Ihrig <holger.ihrig@nokia.com> | 2011-09-01 12:42:14 +0200 |
commit | 3a7e6157d1a9865a31a5641605bbe9b0fc25e1d4 (patch) | |
tree | 0fbbaff4f42115383f08aef07baa58e841ba551a /tests/auto/corelib/kernel/qsocketnotifier | |
parent | a90f50942e5304e6bf1c8a3e32f1f65c7a38f60b (diff) |
Moving relevant tests to corelib/kernel
Added Test for qmetaproperty
Marked QSocketNotifier Autotest as insignificant. See QTBUG-21204
Marked qtranslator Autotest as insignificant. See QTBUG-21125
Marked corelib/io/qfile/largefile as insignificant. See QTBUG-21175
Task-number: QTBUG-21066
Change-Id: I2a7f6587845c355091bb07c8dd3d1557d16db0be
Reviewed-on: http://codereview.qt.nokia.com/3598
Reviewed-by: Qt Sanity Bot <qt_sanity_bot@ovi.com>
Reviewed-by: Sergio Ahumada <sergio.ahumada@nokia.com>
Diffstat (limited to 'tests/auto/corelib/kernel/qsocketnotifier')
3 files changed, 379 insertions, 0 deletions
diff --git a/tests/auto/corelib/kernel/qsocketnotifier/.gitignore b/tests/auto/corelib/kernel/qsocketnotifier/.gitignore new file mode 100644 index 0000000000..2e1568660c --- /dev/null +++ b/tests/auto/corelib/kernel/qsocketnotifier/.gitignore @@ -0,0 +1 @@ +tst_qsocketnotifier diff --git a/tests/auto/corelib/kernel/qsocketnotifier/qsocketnotifier.pro b/tests/auto/corelib/kernel/qsocketnotifier/qsocketnotifier.pro new file mode 100644 index 0000000000..0768c69caa --- /dev/null +++ b/tests/auto/corelib/kernel/qsocketnotifier/qsocketnotifier.pro @@ -0,0 +1,11 @@ +load(qttest_p4) +SOURCES += tst_qsocketnotifier.cpp +QT = core-private network-private + +requires(contains(QT_CONFIG,private_tests)) + +include(../platformsocketengine/platformsocketengine.pri) + +symbian: TARGET.CAPABILITY = NetworkServices + +CONFIG += insignificant_test # QTBUG-21204 diff --git a/tests/auto/corelib/kernel/qsocketnotifier/tst_qsocketnotifier.cpp b/tests/auto/corelib/kernel/qsocketnotifier/tst_qsocketnotifier.cpp new file mode 100644 index 0000000000..2c3a6c52bf --- /dev/null +++ b/tests/auto/corelib/kernel/qsocketnotifier/tst_qsocketnotifier.cpp @@ -0,0 +1,367 @@ +/**************************************************************************** +** +** 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/QTest> +#include <QtTest/QSignalSpy> +#include <QtTest/QTestEventLoop> + +#include <QtCore/QCoreApplication> +#include <QtCore/QTimer> +#include <QtCore/QSocketNotifier> +#include <QtNetwork/QTcpServer> +#include <QtNetwork/QTcpSocket> +#ifdef Q_OS_SYMBIAN +#include <private/qsymbiansocketengine_p.h> +#define NATIVESOCKETENGINE QSymbianSocketEngine +#else +#include <private/qnativesocketengine_p.h> +#define NATIVESOCKETENGINE QNativeSocketEngine +#endif +#ifdef Q_OS_UNIX +#include <private/qnet_unix_p.h> +#include <sys/select.h> +#endif +#include <limits> + +#if defined (Q_CC_MSVC) && defined(max) +# undef max +# undef min +#endif // Q_CC_MSVC + +class tst_QSocketNotifier : public QObject +{ + Q_OBJECT +public: + tst_QSocketNotifier(); + ~tst_QSocketNotifier(); + +private slots: + void unexpectedDisconnection(); + void mixingWithTimers(); + void posixSockets(); + void bogusFds(); +}; + +tst_QSocketNotifier::tst_QSocketNotifier() +{ } + +tst_QSocketNotifier::~tst_QSocketNotifier() +{ +} + +class UnexpectedDisconnectTester : public QObject +{ + Q_OBJECT +public: + NATIVESOCKETENGINE *readEnd1, *readEnd2; + int sequence; + + UnexpectedDisconnectTester(NATIVESOCKETENGINE *s1, NATIVESOCKETENGINE *s2) + : readEnd1(s1), readEnd2(s2), sequence(0) + { + QSocketNotifier *notifier1 = + new QSocketNotifier(readEnd1->socketDescriptor(), QSocketNotifier::Read, this); + connect(notifier1, SIGNAL(activated(int)), SLOT(handleActivated())); + QSocketNotifier *notifier2 = + new QSocketNotifier(readEnd2->socketDescriptor(), QSocketNotifier::Read, this); + connect(notifier2, SIGNAL(activated(int)), SLOT(handleActivated())); + } + +public slots: + void handleActivated() + { + char data1[1], data2[1]; + ++sequence; + if (sequence == 1) { + // read from both ends + (void) readEnd1->read(data1, sizeof(data1)); + (void) readEnd2->read(data2, sizeof(data2)); + emit finished(); + } else if (sequence == 2) { + // we should never get here + QCOMPARE(readEnd2->read(data2, sizeof(data2)), qint64(-2)); + QVERIFY(readEnd2->isValid()); + } + } + +signals: + void finished(); +}; + +void tst_QSocketNotifier::unexpectedDisconnection() +{ +#ifdef Q_OS_SYMBIAN + QSKIP("Symbian socket engine pseudo descriptors can't be used for QSocketNotifier", SkipAll); +#else + /* + Given two sockets and two QSocketNotifiers registered on each + their socket. If both sockets receive data, and the first slot + invoked by one of the socket notifiers empties both sockets, the + other notifier will also emit activated(). This results in + unexpected disconnection in QAbstractSocket. + + The use case is that somebody calls one of the + waitFor... functions in a QSocketNotifier activated slot, and + the waitFor... functions do local selects that can empty both + stdin and stderr while waiting for fex bytes to be written. + */ + + QTcpServer server; + QVERIFY(server.listen(QHostAddress::LocalHost, 0)); + + NATIVESOCKETENGINE readEnd1; + readEnd1.initialize(QAbstractSocket::TcpSocket); + bool b = readEnd1.connectToHost(server.serverAddress(), server.serverPort()); + QVERIFY(readEnd1.waitForWrite()); +// while (!b && readEnd1.state() != QAbstractSocket::ConnectedState) +// b = readEnd1.connectToHost(server.serverAddress(), server.serverPort()); + QVERIFY(readEnd1.state() == QAbstractSocket::ConnectedState); + QVERIFY(server.waitForNewConnection()); + QTcpSocket *writeEnd1 = server.nextPendingConnection(); + QVERIFY(writeEnd1 != 0); + + NATIVESOCKETENGINE readEnd2; + readEnd2.initialize(QAbstractSocket::TcpSocket); + b = readEnd2.connectToHost(server.serverAddress(), server.serverPort()); + QVERIFY(readEnd2.waitForWrite()); +// while (!b) +// b = readEnd2.connectToHost(server.serverAddress(), server.serverPort()); + QVERIFY(readEnd2.state() == QAbstractSocket::ConnectedState); + QVERIFY(server.waitForNewConnection()); + QTcpSocket *writeEnd2 = server.nextPendingConnection(); + QVERIFY(writeEnd2 != 0); + + writeEnd1->write("1", 1); + writeEnd2->write("2", 1); + + writeEnd1->waitForBytesWritten(); + writeEnd2->waitForBytesWritten(); + + writeEnd1->flush(); + writeEnd2->flush(); + + UnexpectedDisconnectTester tester(&readEnd1, &readEnd2); + + QTimer timer; + timer.setSingleShot(true); + timer.start(30000); + do { + // we have to wait until sequence value changes + // as any event can make us jump out processing + QCoreApplication::processEvents(QEventLoop::WaitForMoreEvents); + QVERIFY(timer.isActive()); //escape if test would hang + } while(tester.sequence <= 0); + + QVERIFY(readEnd1.state() == QAbstractSocket::ConnectedState); + QVERIFY(readEnd2.state() == QAbstractSocket::ConnectedState); + + QCOMPARE(tester.sequence, 2); + + readEnd1.close(); + readEnd2.close(); + writeEnd1->close(); + writeEnd2->close(); + server.close(); +#endif +} + +class MixingWithTimersHelper : public QObject +{ + Q_OBJECT + +public: + MixingWithTimersHelper(QTimer *timer, QTcpServer *server); + + bool timerActivated; + bool socketActivated; + +private slots: + void timerFired(); + void socketFired(); +}; + +MixingWithTimersHelper::MixingWithTimersHelper(QTimer *timer, QTcpServer *server) +{ + timerActivated = false; + socketActivated = false; + + connect(timer, SIGNAL(timeout()), SLOT(timerFired())); + connect(server, SIGNAL(newConnection()), SLOT(socketFired())); +} + +void MixingWithTimersHelper::timerFired() +{ + timerActivated = true; +} + +void MixingWithTimersHelper::socketFired() +{ + socketActivated = true; +} + +void tst_QSocketNotifier::mixingWithTimers() +{ + QTimer timer; + timer.setInterval(0); + timer.start(); + + QTcpServer server; + QVERIFY(server.listen(QHostAddress::LocalHost, 0)); + + MixingWithTimersHelper helper(&timer, &server); + + QCoreApplication::processEvents(); + + QCOMPARE(helper.timerActivated, true); + QCOMPARE(helper.socketActivated, false); + + helper.timerActivated = false; + helper.socketActivated = false; + + QTcpSocket socket; + socket.connectToHost(server.serverAddress(), server.serverPort()); + + QCoreApplication::processEvents(); + + QCOMPARE(helper.timerActivated, true); + QCOMPARE(helper.socketActivated, true); +} + +void tst_QSocketNotifier::posixSockets() +{ +#ifndef Q_OS_UNIX + QSKIP("test only for posix", SkipAll); +#else + + QTcpServer server; + QVERIFY(server.listen(QHostAddress::LocalHost, 0)); + + int posixSocket = qt_safe_socket(AF_INET, SOCK_STREAM, 0); + sockaddr_in addr; + addr.sin_addr.s_addr = htonl(0x7f000001); + addr.sin_family = AF_INET; + addr.sin_port = htons(server.serverPort()); + qt_safe_connect(posixSocket, (const struct sockaddr*)&addr, sizeof(sockaddr_in)); + QVERIFY(server.waitForNewConnection(5000)); + QScopedPointer<QTcpSocket> passive(server.nextPendingConnection()); + + ::fcntl(posixSocket, F_SETFL, ::fcntl(posixSocket, F_GETFL) | O_NONBLOCK); + + { + QSocketNotifier rn(posixSocket, QSocketNotifier::Read); + connect(&rn, SIGNAL(activated(int)), &QTestEventLoop::instance(), SLOT(exitLoop())); + QSignalSpy readSpy(&rn, SIGNAL(activated(int))); + QSocketNotifier wn(posixSocket, QSocketNotifier::Write); + connect(&wn, SIGNAL(activated(int)), &QTestEventLoop::instance(), SLOT(exitLoop())); + QSignalSpy writeSpy(&wn, SIGNAL(activated(int))); + QSocketNotifier en(posixSocket, QSocketNotifier::Exception); + connect(&en, SIGNAL(activated(int)), &QTestEventLoop::instance(), SLOT(exitLoop())); + QSignalSpy errorSpy(&en, SIGNAL(activated(int))); + + passive->write("hello",6); + passive->waitForBytesWritten(5000); + + QTestEventLoop::instance().enterLoop(3); + QCOMPARE(readSpy.count(), 1); + QEXPECT_FAIL("", "QTBUG-20982 fails", Abort); + QCOMPARE(writeSpy.count(), 0); + QCOMPARE(errorSpy.count(), 0); + + char buffer[100]; + qt_safe_read(posixSocket, buffer, 100); + QCOMPARE(buffer, "hello"); + + qt_safe_write(posixSocket, "goodbye", 8); + + QTestEventLoop::instance().enterLoop(3); + QCOMPARE(readSpy.count(), 1); + QCOMPARE(writeSpy.count(), 1); + QCOMPARE(errorSpy.count(), 0); + QCOMPARE(passive->readAll(), QByteArray("goodbye",8)); + } + qt_safe_close(posixSocket); +#endif +} + +void tst_QSocketNotifier::bogusFds() +{ +#ifndef Q_OS_WIN + QTest::ignoreMessage(QtWarningMsg, "QSocketNotifier: Internal error"); +#endif + QSocketNotifier max(std::numeric_limits<int>::max(), QSocketNotifier::Read); + QTest::ignoreMessage(QtWarningMsg, "QSocketNotifier: Invalid socket specified"); +#ifndef Q_OS_WIN + // FIXME QTBUG-20982: this fails, and ignoreMessage can't be skipped or QEXPECT_FAILed + // QTest::ignoreMessage(QtWarningMsg, "QSocketNotifier: Internal error"); +#endif + QSocketNotifier min(std::numeric_limits<int>::min(), QSocketNotifier::Write); +#ifndef Q_OS_WIN + // FIXME QTBUG-20982: this fails, and ignoreMessage can't be skipped or QEXPECT_FAILed + // QTest::ignoreMessage(QtWarningMsg, "QSocketNotifier: Internal error"); +#endif + //bogus magic number is the first pseudo socket descriptor from symbian socket engine. + QSocketNotifier bogus(0x40000000, QSocketNotifier::Exception); + QSocketNotifier largestlegal(FD_SETSIZE - 1, QSocketNotifier::Read); + + QSignalSpy maxspy(&max, SIGNAL(activated(int))); + QSignalSpy minspy(&min, SIGNAL(activated(int))); + QSignalSpy bogspy(&bogus, SIGNAL(activated(int))); + QSignalSpy llspy(&largestlegal, SIGNAL(activated(int))); + + //generate some unrelated socket activity + QTcpServer server; + QVERIFY(server.listen(QHostAddress::LocalHost)); + connect(&server, SIGNAL(newConnection()), &QTestEventLoop::instance(), SLOT(exitLoop())); + QTcpSocket client; + client.connectToHost(QHostAddress::LocalHost, server.serverPort()); + QTestEventLoop::instance().enterLoop(5); + QVERIFY(server.hasPendingConnections()); + + //check no activity on bogus notifiers + QCOMPARE(maxspy.count(), 0); + QCOMPARE(minspy.count(), 0); + QCOMPARE(bogspy.count(), 0); + QCOMPARE(llspy.count(), 0); +} + +QTEST_MAIN(tst_QSocketNotifier) +#include <tst_qsocketnotifier.moc> |