X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fremotepeer.h;fp=src%2Fcommon%2Fremotepeer.h;h=b1c5bf4e9a2e97dc74f18f7e200d5e2ef534a94e;hp=e58d140bccbc119ad8119217bb7d5ccf376ef2e2;hb=b2169e5f4cbd3ce724c4808b62ddc2b8941219a5;hpb=02cfb595a6b78faf332ddbe2d7b997eb0e0293fb

diff --git a/src/common/remotepeer.h b/src/common/remotepeer.h
index e58d140b..b1c5bf4e 100644
--- a/src/common/remotepeer.h
+++ b/src/common/remotepeer.h
@@ -72,6 +72,9 @@ signals:
 protected:
     SignalProxy *signalProxy() const;
 
+    void writeMessage(const QByteArray &msg);
+    virtual void processMessage(const QByteArray &msg) = 0;
+
     // These protocol messages get handled internally and won't reach SignalProxy
     void handle(const Protocol::HeartBeat &heartBeat);
     void handle(const Protocol::HeartBeatReply &heartBeatReply);
@@ -79,20 +82,25 @@ protected:
     virtual void dispatch(const Protocol::HeartBeatReply &msg) = 0;
 
 protected slots:
-    virtual void onSocketDataAvailable() = 0;
     virtual void onSocketStateChanged(QAbstractSocket::SocketState state);
     virtual void onSocketError(QAbstractSocket::SocketError error);
 
 private slots:
+    void onReadyRead();
+
     void sendHeartBeat();
     void changeHeartBeatInterval(int secs);
 
+private:
+    bool readMessage(QByteArray &msg);
+
 private:
     QTcpSocket *_socket;
     SignalProxy *_signalProxy;
     QTimer *_heartBeatTimer;
     int _heartBeatCount;
     int _lag;
+    quint32 _msgSize;
 };
 
 #endif