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 }