← Back to branch summary

~oif-team/ubuntu/natty/qt4-x11/xi2.1

« back to all changes in this revision

Viewing changes to tools/qtestlib/wince/cetcpsyncserver/connectionmanager.cpp

  • Committer: Bazaar Package Importer
  • Author(s): Alessandro Ghersi
  • Date: 2009-11-02 18:30:08 UTC
  • mfrom: (1.2.2 upstream)
  • mto: (15.2.5 experimental)
  • mto: This revision was merged to the branch mainline in revision 88.
  • Revision ID: james.westby@ubuntu.com-20091102183008-b6a4gcs128mvfb3m
Tags: upstream-4.6.0~beta1
Import upstream version 4.6.0~beta1

Show diffs side-by-side

added added

removed removed

Lines of Context:
tools/qtestlib/wince/cetcpsyncserver/connectionmanager.cpp
 
1
/****************************************************************************
 
2
**
 
3
** Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies).
 
4
** All rights reserved.
 
5
** Contact: Nokia Corporation (qt-info@nokia.com)
 
6
**
 
7
** This file is part of the tools applications of the Qt Toolkit.
 
8
**
 
9
** $QT_BEGIN_LICENSE:LGPL$
 
10
** No Commercial Usage
 
11
** This file contains pre-release code and may not be distributed.
 
12
** You may use this file in accordance with the terms and conditions
 
13
** contained in the Technology Preview License Agreement accompanying
 
14
** this package.
 
15
**
 
16
** GNU Lesser General Public License Usage
 
17
** Alternatively, this file may be used under the terms of the GNU Lesser
 
18
** General Public License version 2.1 as published by the Free Software
 
19
** Foundation and appearing in the file LICENSE.LGPL included in the
 
20
** packaging of this file.  Please review the following information to
 
21
** ensure the GNU Lesser General Public License version 2.1 requirements
 
22
** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
 
23
**
 
24
** In addition, as a special exception, Nokia gives you certain additional
 
25
** rights.  These rights are described in the Nokia Qt LGPL Exception
 
26
** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
 
27
**
 
28
** If you have questions regarding the use of this file, please contact
 
29
** Nokia at qt-info@nokia.com.
 
30
**
 
31
**
 
32
**
 
33
**
 
34
**
 
35
**
 
36
**
 
37
**
 
38
** $QT_END_LICENSE$
 
39
**
 
40
****************************************************************************/
 
41
#include "connectionmanager.h"
 
42
#include "commands.h"
 
43
#include <QtCore/QDebug>
 
44
 
 
45
ConnectionManager::ConnectionManager()
 
46
    : QObject()
 
47
    , m_server(0)
 
48
{
 
49
    debugOutput(0, "ConnectionManager::ConnectionManager()");
 
50
}
 
51
 
 
52
ConnectionManager::~ConnectionManager()
 
53
{
 
54
    debugOutput(0, "ConnectionManager::~ConnectionManager()");
 
55
    cleanUp();
 
56
}
 
57
 
 
58
bool ConnectionManager::init()
 
59
{
 
60
    debugOutput(0, "ConnectionManager::init()");
 
61
    debugOutput(3, "Initializing server...");
 
62
    cleanUp();
 
63
    m_server = new QTcpServer(this);
 
64
    connect(m_server, SIGNAL(newConnection()), this, SLOT(newConnection()));
 
65
    bool result = m_server->listen(QHostAddress::Any, SERVER_PORT);
 
66
    if (!result)
 
67
        debugOutput(3, QString::fromLatin1("   Error: Server start failed:") + m_server->errorString());
 
68
    debugOutput(3, "   Waiting for action");
 
69
    return result;
 
70
}
 
71
 
 
72
void ConnectionManager::cleanUp()
 
73
{
 
74
    debugOutput(0, "ConnectionManager::cleanUp()");
 
75
 
 
76
    if (m_server) {
 
77
        debugOutput(1, "Removing server instance...");
 
78
        disconnect(m_server, SIGNAL(newConnection()), this, SLOT(newConnection()));
 
79
        delete m_server;
 
80
        m_server = 0;
 
81
    }
 
82
}
 
83
 
 
84
void ConnectionManager::newConnection()
 
85
{
 
86
    debugOutput(0, "ConnectionManager::newConnection()");
 
87
 
 
88
    QTcpSocket* connection = m_server->nextPendingConnection();
 
89
    if (!connection) {
 
90
        debugOutput(3, "Received connection has empty socket");
 
91
        return;
 
92
    }
 
93
    debugOutput(0, QString::fromLatin1("   received a connection: %1").arg((int) connection));
 
94
    new Connection(connection);
 
95
}
 
96
 
 
97
Connection::Connection(QTcpSocket *socket)
 
98
        : QObject()
 
99
        , m_connection(socket)
 
100
        , m_command(0)
 
101
{
 
102
    connect(m_connection, SIGNAL(readyRead()), this, SLOT(receiveCommand()));
 
103
    connect(m_connection, SIGNAL(disconnected()), this, SLOT(closedConnection()));
 
104
}
 
105
 
 
106
Connection::~Connection()
 
107
{
 
108
    if (m_command) {
 
109
        m_command->commandFinished();
 
110
        delete m_command;
 
111
        m_command = 0;
 
112
    }
 
113
    delete m_connection;
 
114
}
 
115
 
 
116
void Connection::receiveCommand()
 
117
{
 
118
    QByteArray arr = m_connection->readAll();
 
119
    debugOutput(1, QString::fromLatin1("Command received: ") + (arr));
 
120
    QList<CommandInfo> commands = availableCommands();
 
121
    for(QList<CommandInfo>::iterator it = commands.begin(); it != commands.end(); ++it) {
 
122
        if (it->commandName == QString::fromLatin1(arr)) {
 
123
            debugOutput(1, "Found command in list");
 
124
            disconnect(m_connection, SIGNAL(readyRead()), this, SLOT(receiveCommand()));
 
125
            AbstractCommand* command = (*it).commandFunc();
 
126
            command->setSocket(m_connection);
 
127
            m_command = command;
 
128
            return;
 
129
        }
 
130
    }
 
131
    debugOutput(2, QString::fromLatin1("Unknown command received: ") + (arr));
 
132
}
 
133
 
 
134
void Connection::closedConnection()
 
135
{
 
136
    debugOutput(0, "connection being closed...");
 
137
    this->deleteLater();
 
138
}