QTcpSocket / QTcpServer, two way communication

[SGaist]

Hi,

How have you implemented the socket handling server-side ?

There's likely something wrong there as you should be able to send data back.

[SPlatten]

@SGaist , I'm really not sure why I can't send, I can send an Acknowledge back and this works in response to receiving a message, but when I try to send an unsolicited message it fails.

[SGaist]

Hence my question: how did you implement the socket handling server side ?

[SPlatten]

@SGaist , Yes, however it could probably be improved, did you see the edit of my post which has the only signal and slot I'm connecting to on the server?

When a message is send from the server to the client, the code halts on line 127 of qsocketnotifier.h:

return lhs.sockfd != rhs.sockfd;

[SGaist]

Your connect call looks fishy.

Why are you using this twice in your connect statement ? It looks like you are connecting the signal of the base class to either the same signal in a derived class or that you have a slot of the exact same name as the signal.

Also, why did you subclass QTcpServer ?

[SPlatten]

@SGaist , because the class is derived from QTcpServer:

    class clsSocketServer : public QTcpServer {
    Q_OBJECT

    private:
        static quint16 msuint16nextModulePort;

        void discardClient();

    protected:
        void incomingConnection(qintptr sfd) override;

    public:
        static const QString mscstrCRLF;
        static const quint16 mscuint16port;

        explicit clsSocketServer(QObject* pParent = nullptr, quint16 uint16Port = clsSocketServer::mscuint16port);
        ~clsSocketServer();

        static quint16 uint16NextModulePort() {
            return ++clsSocketServer::msuint16nextModulePort;
        }

    signals:
        void newConnWithSocket(QAbstractSocket* pSocket);

    public slots:
        void acceptError(QAbstractSocket::SocketError socketError);
        void newConnection();
    };

[KroMignon]

@SPlatten said in QTcpSocket / QTcpServer, two way communication:

When a message is send from the server to the client, the code halts on line 127 of qsocketnotifier.h:

Why do you have create a QTcpServer sub-class? Are you doing something special in incomingConnection()?
Most of the time there is not need to sub-class QTcpServer, by the way, I never had to do it!

[SGaist]

So first question: why do you feel the need to subclass QTcpServer ? 95% of the time it's not necessary, always think composition over inheritance first.

I know that the usual way to build a Qt application is to create a class derived from QWidget/QMainWindow/QDialog and that you will have to do that for custom widgets as well, but you usually do that on a specific set of classes to then do composition with other elements unless you actively need some custom behaviour.

Next: why do you name a slot with exactly the same name a signal already existing in the base class ? That's actively searching for troubles. A recommandation for slot names: they usually match an action. Here for example: onNewConnection would make it clear that you are acting on a new connection.

[SPlatten]

The only purpose of this application is to act as a gateway / server between another application and the various modules it creates, I sub-classed QTcpServer because the main class and purpose is to be a server, I see no problem in doing this and its cleaner.

I agree with you on naming slots with a prefix of 'on' and this is exactly what I usually do.

[KroMignon]

@SPlatten said in QTcpSocket / QTcpServer, two way communication:

purpose is to be a server, I see no problem in doing this and its cleaner.

But why did you reimplement incomingConnection() ?
Don't understand my wrong, it is not a judgement in any form, I only wonder why you have to do it.

[SPlatten]

@KroMignon , My incomingConnection:

void clsSocketServer::incomingConnection(qintptr sfd) {
    clsSocketClient* pClient = new clsSocketClient(this);
    pClient->setSocketDescriptor(sfd);
    addPendingConnection(pClient);   
}

This part of the application is working ok, in that an external application can send messages to the server, but its sending messages from the server to the external application that is failing...all except the Acknowledge message which does make to the external application.

[KroMignon]

@SPlatten said in QTcpSocket / QTcpServer, two way communication:

its sending messages from the server to the external application that is failing...all except the Acknowledge message which does make to the external application.

Just be sure we are talking about the same issue:
You have a TCP client which is connected to the TCP server, the connected client has an instance of clsSocketClient (which seems to be a subclass of QTcpSocket). Let's call the instance mClient.
When you do mClient.write(<something>), you've got an error.

Is that your problem?

[SPlatten]

@KroMignon , there is no error sending data from the client to the server application, it regularly sends a message, a heartbeat message, which the server responds with an acknowledge. This acknowledge is also sent from the server with no error.

However if the server attempts to send any other message to the client, this fails and is not written, the return is -1.

[KroMignon]

@SPlatten said in QTcpSocket / QTcpServer, two way communication:

However if the server attempts to send any other message to the client, this fails and is not written, the return is -1.

I don't understand this, what do you mean with "server attempts to send to client"?
The server TCP socket can not send/receive anything, it can only accept/reject connection requests, which are transferred to a new TCP socket. This is TCP basics, or did I misunderstood something?

Can you be more explicit or show a code extract?

[SPlatten]

@KroMignon , the intention is for the server to be able to send messages to the client. However when I've tried to do this is always fails, yet a response to a message received by the server is always successful..

[SGaist]

Not knowing your code base it's difficult to answer since we do not know what happens client side and we do not know how you handle the sending of message back to the client.

One thing however is that it looks like you are making things more complicated than necessary. From your description, you seem to need a QTcpServer to get the connections and then a list of QTcpSocket for the exchange of messages. So I fail to see the need to subclass both of them in order to implement your proxy.

[SPlatten]

@SGaist , subclass or not subclass, the implementation would be the same?

The clients all send the server regular heartbeats, if a client does not receive an ack in response to the heartbeat then it can determine that the server is no longer running and self terminate.

From time to time the server will issue commands to the clients, its these that do not work.

In trying to fix this I've managed to break everything so once I get it back up I will publish some source.

[SGaist]

@SPlatten said in QTcpSocket / QTcpServer, two way communication:

@SGaist , subclass or not subclass, the implementation would be the same?

Not necessarily, it depends on what your code does.

[KroMignon]

@SPlatten said in QTcpSocket / QTcpServer, two way communication:

From time to time the server will issue commands to the clients, its these that do not work.
In trying to fix this I've managed to break everything so once I get it back up I will publish some source.

It looks to me as you want to reimplement TCP KeepAlive feature.
Why do not simply activate KeepAlive option on TCP socket?

But perhaps I don't understand very well your explanation.
When you are talking about "server" and "client" do you mean the application or the socket?

[SPlatten]

@KroMignon , by server I mean the application using QTcpServer that is in effect the master because it is the application that starts the other processes, listens for incoming messages and issues commands to the other processes.

The clients use QTcpSocket to connect to the server application. If the server goes away then the clients will self terminate. I don't know about the KeepAlive feature so I will read up, but basically the heartbeat is an alternative to pinging the server to see if it is active and responding. Can I self terminate if the server doesn't respond using the KeepAlive?