QT QSocketNotifier: Socket notifiers cannot be enabled or disabled from another thread

[J.Hilk]

Hier a little helper, code is untested, so you'll may have to modify /bugfix it:

asynchronus and threaded.

//main.cpp

#include <QApplication>
#include <QThread>
#include "client.h"

int main(int argc, char *argv[])
{
    QApplication a(argc, argv);

    QThread *thread = new QThread ();
    client *m_client = new client();
    m_client->moveToThread(thread);
    QObject::connect(thread, &QThread::started, m_client, &client::startconnection);
    QObject::connect(thread, &QThread::finished, m_client, &client::deleteLater);
    QObject::connect(thread, &QThread::finished, thread, &QThread::deleteLater);
    thread->start();

    return a.exec();
}

#include "client.h"

client::client(QObject *parent):QObject(parent)
{

}
void client::startconnection()
{
    QTcpSocket client_socket = new QTcpSocket(this);
    
    connect(client_socket, &QTcpSocket::bytesWritten, this, &client::BytesWritten);
    connect(client_socket, &QTcpSocket::readyRead, this, &client::ReadyRead);
    
    connect(client_socket,SIGNAL(connected()),this,SLOT(connection()));
    connect(client_socket,SIGNAL(disconnected()),this,SLOT(disconnection()));
    
    client_socket->connectToHost("127.0.0.1",100);
}

void client::BytesWritten(const quint64 &bytes){
    qDebug() << bytes << "Bytes written";
}

void client::ReadyRead(){
    qDebug() << Q_FUNC_INFO << client_socket->readAll();
}

void client::connection(){
    qDebug()<<"connection is successfull, now write test data";
    writedata("TestString");
}

void client::disconnection(){
    qDebug()<<"disconnected..";
}
void client::writedata(const QString &str){
    qDebug()<<"to write somthing";
    client_socket->write(str.c_str());
}

[JadeN001]

@jsulm I'm trying to create a chat application kind of program without using QWidgets .
So I need to make program work parallelly in aspect of sending and receiving messages without being blocked. I tried it without using QThread and QConcurrent (meaning I used signals and SLOTs only).
So in that code , the readyRead() gets called only after I write something. It means even if there's data to read , I can't get that data till I write something first.
So what I want here is when a client is sending some data, the other client should not get blocked into writing mode and it should be able to read the data and display. So the problem that i am facing is ,when readyRead() is called data gets stored into buffer and after write() function completed it display whole messages which was in buffer.

[JadeN001]

@J.Hilk thanks , I'll definitely look into it. Thanks again.

[JadeN001]

@J.Hilk thnaks , after doing some changes to this code , I no longer see those warnings in client code...but client doesn't read untill I write something(using cin.readline() function). Is there a way through which client doesn't wait to write something and reads the message from other client, in short it doesn't get blocked in writing.

[J.Hilk]

@JadeN001 ready read is emitted as soon as data is available at the socket.

The fact that you only get data when you write something has nothing to do with qt, but with the server you connect to.

Change the server you have, so that he sends without beeing triggered first. A Timer for example.

[SGaist]

@JadeN001 said in QT QSocketNotifier: Socket notifiers cannot be enabled or disabled from another thread:

text=cin.readLine();

Isn't that a blocking operation ? If so, the event loop is blocked until you get something from stdin.

[JadeN001]

@J.Hilk My server is just sending message when it arrives from client.i think at client side, i have to change the logic of calling write() function only when if there is no data in buffer for reading..I have tried to use bytesavailable().but it is not working.Do you have any idea about it?

[JadeN001]

@SGaist yes , that too is causing trouble. can you suggest any nonblocking userinput method? I'm really stuck at this point , SocketNotifier warning and this cin.readLine().

[SGaist]

It would rather be: do your blocking input in one thread and manage your network in another one.

[JadeN001]

@SGaist thanks very much
I followed your suggestion and now it seems like , I'm getting this notification only when I write() something. @SGaist Is there a way to get the current SocketNotifier and handle it ?

[SGaist]

You might be interested by this small example for reading std using Qt.

[JadeN001]

@SGaist thanks very much
I tried this way too, but here I must pass the socketDescriptor as a parameter in QSocketNotifier. Its a bit confusing on client side how we can get socketDescriptor as in my knowledge we can only get socketdescriptor at serverside because of its Incommingconnection(). now, One more thing....Is it possible to get a warning of socket Notifier because reading and writing functions are being called at the same time ??

[SGaist]

The socket notifier was only for stdin. As for your client side network connection, do everything in your dedicated worker object.