X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fremotepeer.h;h=a8ca3b27b3217d3b370ea4a2d47d0c0792cbddce;hp=5e064252e998903f7ad7e4db7ab6e75743081b66;hb=c1cf157116de7fc3da96203aa6f03c38c7ebb650;hpb=30b159cb876a9495de42e9a3e70ca050516f0805;ds=inline diff --git a/src/common/remotepeer.h b/src/common/remotepeer.h index 5e064252..a8ca3b27 100644 --- a/src/common/remotepeer.h +++ b/src/common/remotepeer.h @@ -39,12 +39,12 @@ class COMMON_EXPORT RemotePeer : public Peer public: // import the virtuals from the baseclass - using Peer::handle; using Peer::dispatch; + using Peer::handle; - RemotePeer(AuthHandler *authHandler, QTcpSocket *socket, Compressor::CompressionLevel level, QObject *parent = nullptr); + RemotePeer(AuthHandler* authHandler, QTcpSocket* socket, Compressor::CompressionLevel level, QObject* parent = nullptr); - void setSignalProxy(SignalProxy *proxy) override; + void setSignalProxy(SignalProxy* proxy) override; virtual QString protocolName() const = 0; QString description() const override; @@ -62,30 +62,30 @@ public: bool compressionEnabled() const; void setCompressionEnabled(bool enabled); - QTcpSocket *socket() const; + QTcpSocket* socket() const; public slots: - void close(const QString &reason = QString()) override; + void close(const QString& reason = QString()) override; signals: void transferProgress(int current, int max); - void socketError(QAbstractSocket::SocketError error, const QString &errorString); - void statusMessage(const QString &msg); + void socketError(QAbstractSocket::SocketError error, const QString& errorString); + void statusMessage(const QString& msg); // Only used by LegacyPeer void protocolVersionMismatch(int actual, int expected); protected: - SignalProxy *signalProxy() const override; + SignalProxy* signalProxy() const override; - void writeMessage(const QByteArray &msg); - virtual void processMessage(const QByteArray &msg) = 0; + 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); - virtual void dispatch(const Protocol::HeartBeat &msg) = 0; - virtual void dispatch(const Protocol::HeartBeatReply &msg) = 0; + void handle(const Protocol::HeartBeat& heartBeat); + void handle(const Protocol::HeartBeatReply& heartBeatReply); + virtual void dispatch(const Protocol::HeartBeat& msg) = 0; + virtual void dispatch(const Protocol::HeartBeatReply& msg) = 0; protected slots: virtual void onSocketStateChanged(QAbstractSocket::SocketState state); @@ -99,13 +99,13 @@ private slots: void changeHeartBeatInterval(int secs); private: - bool readMessage(QByteArray &msg); + bool readMessage(QByteArray& msg); private: - QTcpSocket *_socket; - Compressor *_compressor; - SignalProxy *_signalProxy; - QTimer *_heartBeatTimer; + QTcpSocket* _socket; + Compressor* _compressor; + SignalProxy* _signalProxy; + QTimer* _heartBeatTimer; int _heartBeatCount; int _lag; quint32 _msgSize;