summaryrefslogtreecommitdiffstats
path: root/tests/auto/network/socket/qudpsocket/clientserver
diff options
context:
space:
mode:
authorJo Asplin <jo.asplin@nokia.com>2011-09-06 13:46:40 +0200
committerJo Asplin <jo.asplin@nokia.com>2011-09-09 09:32:17 +0200
commitc59f9ad7768a007ca7a49ea11b16617529e86d52 (patch)
treed481be2a727f8461a76c2b729fc7e93784a3cff1 /tests/auto/network/socket/qudpsocket/clientserver
parent2d41aff1e8557a43268bce631df834bfa79593cf (diff)
Moved network autotests into new directory structure
Task-number: QTBUG-21223 Change-Id: I55dbf5c42a1c5d938b9e0c9bf7d90457a6c26bbc Reviewed-on: http://codereview.qt-project.org/4259 Reviewed-by: Qt Sanity Bot <qt_sanity_bot@ovi.com> Reviewed-by: Sergio Ahumada <sergio.ahumada@nokia.com> Reviewed-by: Rohan McGovern <rohan.mcgovern@nokia.com>
Diffstat (limited to 'tests/auto/network/socket/qudpsocket/clientserver')
-rw-r--r--tests/auto/network/socket/qudpsocket/clientserver/clientserver.pro8
-rw-r--r--tests/auto/network/socket/qudpsocket/clientserver/main.cpp170
2 files changed, 178 insertions, 0 deletions
diff --git a/tests/auto/network/socket/qudpsocket/clientserver/clientserver.pro b/tests/auto/network/socket/qudpsocket/clientserver/clientserver.pro
new file mode 100644
index 0000000000..6da148659c
--- /dev/null
+++ b/tests/auto/network/socket/qudpsocket/clientserver/clientserver.pro
@@ -0,0 +1,8 @@
+QT = core network
+SOURCES += main.cpp
+CONFIG += console
+CONFIG -= app_bundle
+TARGET = clientserver
+DESTDIR = ./
+
+symbian: TARGET.CAPABILITY += NetworkServices
diff --git a/tests/auto/network/socket/qudpsocket/clientserver/main.cpp b/tests/auto/network/socket/qudpsocket/clientserver/main.cpp
new file mode 100644
index 0000000000..9145a5199f
--- /dev/null
+++ b/tests/auto/network/socket/qudpsocket/clientserver/main.cpp
@@ -0,0 +1,170 @@
+/****************************************************************************
+**
+** 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 <QtNetwork>
+
+class ClientServer : public QUdpSocket
+{
+ Q_OBJECT
+public:
+ enum Type {
+ ConnectedClient,
+ UnconnectedClient,
+ Server
+ };
+
+ ClientServer(Type type, const QString &host, quint16 port)
+ : type(type)
+ {
+ switch (type) {
+ case Server:
+ if (bind(0, ShareAddress | ReuseAddressHint)) {
+ printf("%d\n", localPort());
+ } else {
+ printf("XXX\n");
+ }
+ break;
+ case ConnectedClient:
+ connectToHost(host, port);
+ startTimer(250);
+ printf("ok\n");
+ break;
+ case UnconnectedClient:
+ peerAddress = host;
+ peerPort = port;
+ if (bind(QHostAddress::Any, port + 1, ShareAddress | ReuseAddressHint)) {
+ startTimer(250);
+ printf("ok\n");
+ } else {
+ printf("XXX\n");
+ }
+ break;
+ }
+ fflush(stdout);
+
+ connect(this, SIGNAL(readyRead()), this, SLOT(readData()));
+ }
+
+protected:
+ void timerEvent(QTimerEvent *event)
+ {
+ static int n = 0;
+ switch (type) {
+ case ConnectedClient:
+ write(QByteArray::number(n++));
+ break;
+ case UnconnectedClient:
+ writeDatagram(QByteArray::number(n++), peerAddress, peerPort);
+ break;
+ default:
+ break;
+ }
+
+ QUdpSocket::timerEvent(event);
+ }
+
+private slots:
+ void readData()
+ {
+ printf("readData()\n");
+ switch (type) {
+ case ConnectedClient: {
+ while (bytesAvailable() || hasPendingDatagrams()) {
+ QByteArray data = readAll();
+ printf("got %d\n", data.toInt());
+ }
+ break;
+ }
+ case UnconnectedClient: {
+ while (hasPendingDatagrams()) {
+ QByteArray data;
+ data.resize(pendingDatagramSize());
+ readDatagram(data.data(), data.size());
+ printf("got %d\n", data.toInt());
+ }
+ break;
+ }
+ case Server: {
+ while (hasPendingDatagrams()) {
+ QHostAddress sender;
+ quint16 senderPort;
+ QByteArray data;
+ data.resize(pendingDatagramSize());
+ readDatagram(data.data(), data.size(), &sender, &senderPort);
+ printf("got %d\n", data.toInt());
+ printf("sending %d\n", data.toInt() * 2);
+ writeDatagram(QByteArray::number(data.toInt() * 2), sender, senderPort);
+ }
+ break;
+ }
+ }
+ fflush(stdout);
+ }
+
+private:
+ Type type;
+ QHostAddress peerAddress;
+ quint16 peerPort;
+};
+
+int main(int argc, char **argv)
+{
+ QCoreApplication app(argc, argv);
+ ClientServer::Type type;
+ if (app.arguments().size() < 4) {
+ qDebug("usage: ./%s [ConnectedClient <server> <port>|UnconnectedClient <server> <port>|Server]", argv[0]);
+ return 1;
+ }
+
+ QString arg = app.arguments().at(1).trimmed().toLower();
+ if (arg == "connectedclient")
+ type = ClientServer::ConnectedClient;
+ else if (arg == "unconnectedclient")
+ type = ClientServer::UnconnectedClient;
+ else if (arg == "server")
+ type = ClientServer::Server;
+
+ ClientServer clientServer(type, app.arguments().at(2),
+ app.arguments().at(3).toInt());
+
+ return app.exec();
+}
+
+#include "main.moc"