Revize 285c6fe5

Re #8899 - Server - Implement variable-length message reception

deltarobot/curvedataserver.h

@@ -14 +14 @@
 
 public:
     struct Client {
+        /**
+         * Size of the client buffer.
+         *
+         * @note Current implementation truncates any variable-length messages longer than what would fit in the buffer.
+         */
         static const size_t BUF_SIZE = 4096;
-        static const size_t MESSAGE_ID_SIZE = 2;
+
+        static const size_t MESSAGE_ID_SIZE = sizeof(uint16_t);      ///< Size of the protocol message identifier.
+        static const size_t MESSAGE_LENGTH_SIZE = sizeof(uint32_t);  ///< Size of the variable-length message's content length.
 
         QTcpSocket* socket;
         std::map<uint64_t, uint64_t> ping;  ///< key: ping ID;  value: ping timestamp (msec);
@@ -52 +59 @@
 private:
     QList<Client>::iterator clientOf(QTcpSocket *socket);
 
-    void handleMessage(Client& client, uint16_t messageId, void* content);
+    void handleMessage(Client& client, uint16_t messageId, void* content, size_t contentSize);
     void handleProtocolMagic(Client& client, char* content);
     void handleVersion(Client& client, uint8_t content);
     void handlePong(Client& client, uint64_t* content);
-    void handleEOT(Client& client, char* content);
+    void handleEOT(Client& client, char* content, size_t contentSize);
 
     void validPreamble(Client& client);
     void removeSocket(QTcpSocket *socket);