Russian Qt Forum

/*
 * New client connection
 */
void SenseSystem::TechServer::newclient()
{
    // If server started
    qDebug() << QString::fromUtf8("New connection!!!");

    qintptr IDSocket = tcpServer->nextPendingConnection()->socketDescriptor();

    QThread *thread = new QThread();
    Client *client = new Client(IDSocket);
    client->moveToThread(thread);
    // Соединяем сигнал started потока, со слотом process "рабочего" класса, т.е. начинается выполнение нужной работы.
    connect(thread,SIGNAL(started()),client,SLOT(process()));
    connect(thread,SIGNAL(finished()),thread,SLOT(deleteLater()));
    // По завершению выходим из потока, и удаляем рабочий класс
    connect(client,SIGNAL(finished()),thread,SLOT(quit()));
    connect(client,SIGNAL(finished()),client,SLOT(deleteLater()));
    // Удаляем поток, после выполнения операции
    if(config.typeView == CONSOLE)
    {
        connect(client,SIGNAL(println(QString)),(Console *)config.display,SLOT(outStream(QString)));
        connect(client,SIGNAL(addClientToList(int)),(Console *)config.display,SLOT(addClientToList(int)));
    }
    else if(config.typeView == WINDOW)
    {
        connect(client,SIGNAL(println(QString)),((MainWindow *)config.display),SLOT(outStream(QString)));
        connect(client,SIGNAL(addClientToList(int)),(MainWindow *)config.display,SLOT(addClientToList(int)));
    }
    connect(client,SIGNAL(removeClientFromList(int)),this,SLOT(removeMap(int)));

    SenseSystem::TechServer::client.insert(IDSocket,client);
    thread->start();
}

/*
 * Run the thread
 */
void SenseSystem::Client::process(void)
{
    clientSocket = new QTcpSocket();
    // Trying to connect to socket descriptor
    if (!clientSocket->setSocketDescriptor(socketDescriptor))
    {
        // Can't connect to socket descriptor
        finished();
    }
    else
    {
        sql = new MainSQL("localhost","postirayka",
                          "root","root");

        // Initiolization settings for system
        timer = new QTimer(this);
        // setup signal and slot
        connect(timer,SIGNAL(timeout()),this,SLOT(readCommand()));
        // Reading command from MySQL
        timer->start(2000);

        // Initiolization settings for system
        autoriz = new QTimer(this);
        // setup signal and slot
        connect(autoriz,SIGNAL(timeout()),this,SLOT(finishThread()));
        // Reading command from MySQL
        autoriz->start(20000);

        // Initiolization settings for system
        timAlive = new QTimer(this);
        // setup signal and slot
        connect(timAlive,SIGNAL(timeout()),this,SLOT(finishThread()));
        // Reading command from MySQL
        timAlive->start(600000);

        timModem = new QTimer(this);
        // setup signal and slot
        connect(timModem,SIGNAL(timeout()),this,SLOT(readModem()));
        // Reading command from MySQL
        timModem->start(50000);

        timBufClear = new QTimer(this);
        // setup signal and slot
        connect(timBufClear,SIGNAL(timeout()),this,SLOT(bufferClear()));

        // Starting the thread of socket to execute events
        connect(clientSocket,SIGNAL(readyRead()),this, SLOT(socketReadClient()));
        connect(clientSocket,SIGNAL(stateChanged(QAbstractSocket::SocketState)),this, SLOT(clientChangeState()));
        connect(clientSocket,SIGNAL(error(QAbstractSocket::SocketError)),this, SLOT(socketErrorClient()));
        connect(clientSocket,SIGNAL(disconnected()),this, SLOT(socketRemoveClient()));

        // String to window
        QString strSocket;
        strSocket += QString("[") + QString::number(socketDescriptor) + "] New connection!!!" + "\r\n\r\n";
        // Set text to the text browser
        println(strSocket);
    }
}

/*
 * Constructor console task
 */
Console::Console(QStringList agruments,QObject *parent) :
        QObject(parent)
{
    Console::agruments = agruments;
    // Function of fetch of user interface
    server = new SenseSystem::TechServer(config.port);
    connect(this,SIGNAL(println(QString)),this,SLOT(outStream(QString)));
    // Checking if server is started ?
    if(server != NULL)
    {
        // Set text to the text browser
        println("Server is working!\r\n");
        println("UTC: "+QDateTime::currentDateTimeUtc().toString()+"\r\n");
    }
    // If server isn't working
    else
    {
        // Set text to the text browser
        println("Server isn\'t working!!!\r\n");
        println("Please check the internet connection\r\n");
    }
}

    // Checking if we need console application
    if(config.typeView == SenseSystem::CONSOLE)
    {
        QCoreApplication app(argc, argv);
        config.display = new Console(app.arguments());
        // Return end of application
        return app.exec();
    }
    // Checking if we need window application
    else
    {
        QApplication app(argc, argv);
        config.display = new MainWindow();
        ((MainWindow *) config.display)->show();
        // Return end of application
        return app.exec();
    }

connect(tcpServer, SIGNAL(newConnection()), this, SLOT(newclient()));

/*
 * Recive of the request to the server
 */
void SenseSystem::Client::socketReadClient(void)
{
    if(clientSocket->bytesAvailable() == 0)
        return;
    qDebug() << "Recieved some data";
.......................................................................
}

/*
 * New client connection
 */
void SenseSystem::TechServer::newclient()
{
    // If server started
    qDebug() << QString::fromUtf8("New connection!!!");

    QTcpSocket *socket = tcpServer->nextPendingConnection();
    qintptr IDSocket = socket->socketDescriptor();

    QThread *thread = new QThread(this);
    Client *client = new Client(socket);
    socket->moveToThread(thread);
    client->moveToThread(thread);

/*
 * New client connection
 */
void SenseSystem::TechServer::incomingConnection(qintptr socketDescriptor)
{
    // If server started
    qDebug() << "New request to connect!!!!!";

    QTcpSocket *clientSocket = new QTcpSocket();
    socket.insert(socketDescriptor,clientSocket);

    // Trying to connect to socket descriptor
    if (!socket[socketDescriptor]->setSocketDescriptor(socketDescriptor))
    {
        // Can't connect to socket descriptor
        socket[socketDescriptor]->deleteLater();
        socket.remove(socketDescriptor);
    }
    else
    {
        // setup signal and slot
        connect(socket[socketDescriptor],SIGNAL(readyRead()),this,SLOT(socketReadClient()));
        // Initiolization settings for system
        QTimer *timerOut = new QTimer(this);
        autoriz.insert(socketDescriptor,timerOut);
        // setup signal and slot
        connect(autoriz[socketDescriptor],SIGNAL(timeout()),this,SLOT(autorizTimeout()));
        // Reading command from MySQL
        autoriz[socketDescriptor]->start(15000);
    }
}

            QThread *thread = new QThread(this);
            clientSocket->moveToThread(thread);
            Client *client = new Client(clientSocket,sql,IDSystem);
            client->moveToThread(thread);
            // Соединяем сигнал started потока, со слотом process "рабочего" класса, т.е. начинается выполнение нужной работы.
            connect(thread,SIGNAL(started()),client,SLOT(process()));
            connect(thread,SIGNAL(finished()),thread,SLOT(deleteLater()));
            // По завершению выходим из потока, и удаляем рабочий класс
            connect(client,SIGNAL(finished()),thread,SLOT(quit()));
            connect(client,SIGNAL(finished()),client,SLOT(deleteLater()));
            // Starting the thread of socket to execute events
            connect(clientSocket,SIGNAL(readyRead()),client, SLOT(socketReadClient()));
            connect(clientSocket,SIGNAL(stateChanged(QAbstractSocket::SocketState)),client, SLOT(clientChangeState()));
            connect(clientSocket,SIGNAL(error(QAbstractSocket::SocketError)),client, SLOT(socketErrorClient()));
            connect(clientSocket,SIGNAL(disconnected()),client, SLOT(socketRemoveClient()));
            // Удаляем поток, после выполнения операции
            if(config.typeView == CONSOLE)
            {
                connect(client,SIGNAL(println(QString)),((Console *)config.display),SLOT(outStream(QString)));
                connect(client,SIGNAL(addClientToList(qintptr)),((Console *)config.display),SLOT(addClientToList(qintptr)));
            }
            else if(config.typeView == WINDOW)
            {
                connect(client,SIGNAL(println(QString)),((MainWindow *)config.display),SLOT(outStream(QString)));
                connect(client,SIGNAL(addClientToList(qintptr)),((MainWindow *)config.display),SLOT(addClientToList(qintptr)));
            }
            connect(client,SIGNAL(removeClientFromList(qintptr)),this,SLOT(removeMap(qintptr)));

            SenseSystem::TechServer::client.insert(socketDescriptor,client);
            thread->start();