Revize 0cda8e8d

Re #8735 - Implement base server message retrieval

deltarobot/curvedataserver.h

@@ -4 +4 @@
 #include <QObject>
 #include <QTcpServer>
 #include <QTcpSocket>
+#include <map>
+#include <mutex>
 
 class CurveDataServer : QObject
 {
     Q_OBJECT
 
 public:
-    CurveDataServer();
+    struct Client {
+        static const size_t BUF_SIZE = 32;
+        static const size_t MESSAGE_ID_SIZE = 2;
+
+        QTcpSocket* socket;
+        std::map<long, long> ping;  ///< key: ping ID;  value: ping timestamp (msec);
+        long latency;               ///< client's latency
+        long lastPong;              ///< timestamp of last pong
+
+        char buf[BUF_SIZE];
+        size_t bufUsed;
+
+        Client(QTcpSocket* socket);
+    };
+
+    explicit CurveDataServer();
+    ~CurveDataServer();
+
     void sendActuatorPosition(float x, float y, float z);
 
 public slots:
@@ -19 +38 @@
     void onReadyRead();
 
 private:
-    QByteArray *putFloatIntoMessage(QByteArray *message, int index, float f);
+    QList<Client>::iterator clientOf(QTcpSocket *socket);
+
+    void handleMessage(Client& client, uint16_t messageId, void* content);
+
     void sendPreamble(QTcpSocket *socket);
     void sendProtocolMagic(QTcpSocket *socket);
     void sendVersion(QTcpSocket *socket);
+    void sendEot(QTcpSocket *socket, std::string&& message);
 
     QTcpServer _server;
-    QList<QTcpSocket*> _sockets;
+
+    std::recursive_mutex _socketsLock;
+    QList<Client> _sockets;
 };
 
 #endif // CURVEDATASERVER_H