QSocketNotifier ASSERT Error

[alexandros]

Есть серверное приложение, хочу к нему добавить возможность изменение настроек/конфигураций "на лету" то есть без рестарта, с консоли вводятся команды на которые сервер сразу же реагирует.

Код

C++ (Qt)
#include <QtCore/QCoreApplication>
 
#include "threadio.h"
 
int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
 
    int port = SettingsStorage::getInstance()->getValue("core/port").toInt();
    int maxclients = SettingsStorage::getInstance()->getValue("core/maxclients").toInt();
    int maxthreads = SettingsStorage::getInstance()->getValue("core/maxthreads").toInt();
 
    CoreServer *coreServer = new CoreServer();
 
    coreServer->setMaxPendingConnections(maxclients);
    coreServer->initDaemon(port);
 
    QThreadPool::globalInstance()->setMaxThreadCount(maxthreads);
    ...
    return a.exec();
}
 

 /*
        Вариант 1 (не работает)
       
        блокирует работу приложения, сервер не принимает запросы

        while(std::getline(std::cin,command)){

        }
    */

    /*
    Вариант 2
 
    ThreadIO *tio = new ThreadIO();
    tio->setCoreServer(coreServer);
    tio->start(); // тут и содержится while(std::getline(std::cin,command)){...}
    ссылка на объект сервера была через синглтон

    НО!!!

    вываливается следующее:

    QSocketNotifier: socket notifiers cannot be enabled from another thread
    (типа невозможно управлять объектом из другого потока)
   
   
    */

как быть?

[xokc]

Транслировать команды, полученные внутри ThreadIO основному потоку (тому, в котором CoreServer создан) через сигнал/слоты. Т.е. в ThreadIO добавить сигнал commandReady(QString command), а в CoreServer соответствующий слот, и всю обработку команд делать непосредственно в CoreServer.

[alexandros]

В общем делается так:

Код

C++ (Qt)
signals:
    void execCommandEvent(QString action, QStringList args);
public slots:
    void execCommandSlot(QString action, QStringList args);
 

Код

C++ (Qt)
void ThreadIO::run()
{
    std::string command = "";
    QStringList qcommand = QStringList();
 
    while(std::getline(std::cin,command)){
        qcommand = QString(command.c_str()).split(QChar(' '));
 
        QString action = qcommand[0];
        qcommand.removeAt(0);
 
        emit CoreServer::getInstance()->execCommandEvent(action,qcommand);
    }
}
 

Код

C++ (Qt)
void CoreServer::execCommandSlot(QString action,QStringList args)
{
    if(action == "shutdown"){
 
    }else if(action == "reboot"){
 
    }else{
 
    }