unable to send data via QTcpSocket

[jsulm]

@Lightshadown said in unable to send data via QTcpSocket:

TCP_socket->write(block);

Up to here you did NOT connect error() signal!
Please connect this signal BEFORE you try to send any data.

[J.Hilk]

@Lightshadown said in unable to send data via QTcpSocket:

yes = TCP_socket->waitForBytesWritten();

also do not use blocking calls when you're already using signals. QTcpSocket has the bytesWritten signal for this.

Also,also, please remove the QMessageBox from the lambda body.

Currently you're mixing synchronous and asynchronous apis and sprinkle some additional event loops in. Those 3 should never meet.

[Lightshadown]

@jsulm the error handler is already connected but forgot to uncomment on the one i posted my bad, this is the one i used error = TCP_socket->error(); , still i can access the lambda but the switch statement fails for some reason, i did updated the switch and added all the errors that comes from the enum and it still fails, i have a problem with the error handler and already tried to use my Log function that accept QString, but it crash onces i use the error variable

@J-Hilk ok sorry on that one didnt pay attention, i already erased all the QMessageBox, so its working properly until i reach TCP_socket->write i suspect its my server, its writen in python, it works but only for the first string i did check using another client writen in python

edit: i simply added TPC_socket->flush() and it kinda works, it behaves like the data is already send and even disconect from the server at the end but the data its not recieved on my server

Server.py

import asyncio
import websockets
import socket
import sqlite3 


def get_ip():    # returns primary private IP only
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    try:
        # doesn't even have to be reachable
        s.connect(('10.255.255.255', 1))
        IP = s.getsockname()[0]
    except Exception:
        IP = '127.0.0.1'
    finally:
        s.close()
    return IP


async def handle_connectio(websocket, path):  # recive and handle connection from client, would handle json or file data
    try:
        async for name in websocket:
            #name = await websocket.recv()
            print(f"<<< {name}")
    except websocket.exceptions.ConnectionClosed as e:
        print (f"Coneecion terminada")


print ("Iniciando el Server webSocket")
print ("Current Ip: " + get_ip())
servidor = websockets.serve(handle_connectio, get_ip(), 8000)

asyncio.get_event_loop().run_until_complete(servidor)
asyncio.get_event_loop().run_forever()
        
#async def main():  # main function
#    print ("Iniciando Server websocket")
#    print("Current Ip: " + get_ip())
#    async with websockets.serve(handle_connectio, get_ip(), 8000):
#        await asyncio.Future()


#if __name__ == '__main__':
#    asyncio.run(main())

[SGaist]

@Lightshadown said in unable to send data via QTcpSocket:

TCP_socket = new QTcpSocket();

You are shadowing your class member variable of the same name and likely have a warning about that when you compile.

@Lightshadown said in unable to send data via QTcpSocket:

void Server::TCP_Request(){ // this one is been called from another class and triggers everything
Gen L;
QString Ip("192.168.1.70");
L.Log("antes de coneccion");
TCP_socket->connectToHost( Ip, 8000 ); // do a broadcast and search for servers ip
//TCP_socket->waitForConnected(5000);

Using an uninitialized variable and thus crash.

[edit: must have been too tired, I thought I saw the variable declared within the constructor... SGaist]

[Lightshadown]

@SGaist that socket was declared as private on the class declaration

class Server {
   public:
        Server();
        virtual ~Server();
        void TCP_Request();
    public slots:
    private: 
         QTcpSocket *TCP_socket = nullptr;
   };

[KroMignon]

@Lightshadown said in unable to send data via QTcpSocket:

class Server {
public:
Server();
virtual ~Server();
void TCP_Request();
public slots:
private:
QTcpSocket *TCP_socket = nullptr;
};

If you want to declare slots (or signals) in your class, you have to:

• subclass QObject (or a QObject based class)
• add Q_OBJECT declaration

so you class should be:

class Server : public QObject {
   Q_OBJECT
   public:
        explicit Server(QObject * parent=nullptr);
        virtual ~Server();
        void TCP_Request();
    public slots:
    private: 
         QTcpSocket *TCP_socket = nullptr;
   };

[Lightshadown]

ok i ditched the lambda and used a normal function, for some reason it wont work inside the connect signal, but now the socket its lock, and got the error
QAbstractSocket::UnfinishedSocketOperationError i have to restart both machines to free the socket, any idea how to free the socket or check the socket if its aviable?

void Server::TCP_Request(){
    Gen L;
    QString Ip("192.168.1.70");
    L.Log("antes de coneccion");
    TCP_socket->abort();
    TCP_socket->connectToHost( Ip, 8000, QIODevice::ReadWrite );   // do a broadcast and search for servers ip
    L.Log("tcp conectado");
        
    bool yes = false;
    QByteArray block("Hola, from laptop");
    //QDataStream salida(&block, QIODevice::WriteOnly);

    //salida << "Enviando desde laptop ";
    //block.append("Enviando desde Laptop");

    if (TCP_socket->isValid()) {
        L.Log("antes de escribir");
        TCP_socket->write(block);
        yes = TCP_socket->flush();
    //TCP_socket->waitForBytesWritten(100);
    }
    if (yes == true){ L.Log("datos enviados");} else {L.Log("no se envio los datos");}
    TCP_socket->disconnectFromHost();
    //TCP_socket->abort();
    L.Log("coneecion terminada");
    }

[jsulm]

@Lightshadown said in unable to send data via QTcpSocket:

TCP_socket->disconnectFromHost();

You are disconnecting without knowing whether all data was sent (flush() does not guarantee this!).
You should listen to https://doc.qt.io/qt-5/qiodevice.html#bytesWritten signal and disconnect when all data was sent.

[Lightshadown]

@jsulm ok i did try using waitForBytesWritten() and it kinda works, now i can send the data to the server, and i just had to wait for the socket to connect, waitForConnected(1000) like it follows

void Server::TCP_Request(){
    Gen L;
    QString Ip("192.168.1.70");    
    bool yes = false;
    QByteArray block("Hola, from laptop");    
            
    TCP_socket->abort();
            
    if (TCP_socket->state() == QAbstractSocket::UnconnectedState){

        L.Log("antes de coneccion");
        TCP_socket->connectToHost( Ip, 8000, QIODevice::ReadWrite );   // do a broadcast and search for servers ip
        
        //QDataStream salida(&block, QIODevice::WriteOnly);
        //salida << "Enviando desde laptop ";
        //block.append("Enviando desde Laptop");
        if (TCP_socket->waitForConnected(1000)){
            if (TCP_socket->isValid()) { // && TCP_socket->state() == QAbstractSocket::ConnectedState) {
                L.Log("antes de escribir");
                TCP_socket->write(block);
                yes = TCP_socket->flush();
                TCP_socket->waitForBytesWritten(1000);
            }
        }
        if (yes == true){ L.Log("datos enviados");} else {L.Log("no se envio los datos");}
        TCP_socket->disconnectFromHost();
        TCP_socket->close();
        //TCP_socket->abort();
        L.Log("coneecion terminada");

    }
        
}

also i would check the signal bytes emited and try to figure it out when all the data is sent, next i would check sending files, thanks

[jsulm]

@Lightshadown Actually I suggested to use https://doc.qt.io/qt-5/qiodevice.html#bytesWritten signal instead of doing blocking calls to wait. But it is up to you.