X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcommon%2Fprotocols%2Fdatastream%2Fdatastreampeer.h;h=b5f931c05234764a1bc8a4df6ac96f517f49f3ee;hb=24c7de34254b5de4cf28045a6923a527e06f7290;hp=5c1a442bb1d5d6da2a35ccc68ac68a4af890672e;hpb=e8a39b4c3c92e193ab861a3fea84a261bb6fbd24;p=quassel.git diff --git a/src/common/protocols/datastream/datastreampeer.h b/src/common/protocols/datastream/datastreampeer.h index 5c1a442b..b5f931c0 100644 --- a/src/common/protocols/datastream/datastreampeer.h +++ b/src/common/protocols/datastream/datastreampeer.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2018 by the Quassel Project * + * Copyright (C) 2005-2022 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -30,7 +30,8 @@ class DataStreamPeer : public RemotePeer Q_OBJECT public: - enum RequestType { + enum RequestType + { Sync = 1, RpcCall, InitRequest, @@ -39,7 +40,7 @@ public: HeartBeatReply }; - DataStreamPeer(AuthHandler *authHandler, QTcpSocket *socket, quint16 features, Compressor::CompressionLevel level, QObject *parent = nullptr); + DataStreamPeer(AuthHandler* authHandler, QTcpSocket* socket, quint16 features, Compressor::CompressionLevel level, QObject* parent = nullptr); Protocol::Type protocol() const override { return Protocol::DataStreamProtocol; } QString protocolName() const override { return "the DataStream protocol"; } @@ -48,37 +49,37 @@ public: static bool acceptsFeatures(quint16 peerFeatures); quint16 enabledFeatures() const override; - void dispatch(const Protocol::RegisterClient &msg) override; - void dispatch(const Protocol::ClientDenied &msg) override; - void dispatch(const Protocol::ClientRegistered &msg) override; - void dispatch(const Protocol::SetupData &msg) override; - void dispatch(const Protocol::SetupFailed &msg) override; - void dispatch(const Protocol::SetupDone &msg) override; - void dispatch(const Protocol::Login &msg) override; - void dispatch(const Protocol::LoginFailed &msg) override; - void dispatch(const Protocol::LoginSuccess &msg) override; - void dispatch(const Protocol::SessionState &msg) override; + void dispatch(const Protocol::RegisterClient& msg) override; + void dispatch(const Protocol::ClientDenied& msg) override; + void dispatch(const Protocol::ClientRegistered& msg) override; + void dispatch(const Protocol::SetupData& msg) override; + void dispatch(const Protocol::SetupFailed& msg) override; + void dispatch(const Protocol::SetupDone& msg) override; + void dispatch(const Protocol::Login& msg) override; + void dispatch(const Protocol::LoginFailed& msg) override; + void dispatch(const Protocol::LoginSuccess& msg) override; + void dispatch(const Protocol::SessionState& msg) override; - void dispatch(const Protocol::SyncMessage &msg) override; - void dispatch(const Protocol::RpcCall &msg) override; - void dispatch(const Protocol::InitRequest &msg) override; - void dispatch(const Protocol::InitData &msg) override; + void dispatch(const Protocol::SyncMessage& msg) override; + void dispatch(const Protocol::RpcCall& msg) override; + void dispatch(const Protocol::InitRequest& msg) override; + void dispatch(const Protocol::InitData& msg) override; - void dispatch(const Protocol::HeartBeat &msg) override; - void dispatch(const Protocol::HeartBeatReply &msg) override; + void dispatch(const Protocol::HeartBeat& msg) override; + void dispatch(const Protocol::HeartBeatReply& msg) override; signals: - void protocolError(const QString &errorString); + void protocolError(const QString& errorString); private: using RemotePeer::writeMessage; - void writeMessage(const QVariantMap &handshakeMsg); - void writeMessage(const QVariantList &sigProxyMsg); - void processMessage(const QByteArray &msg) override; + void writeMessage(const QVariantMap& handshakeMsg); + void writeMessage(const QVariantList& sigProxyMsg); + void processMessage(const QByteArray& msg) override; - void handleHandshakeMessage(const QVariantList &mapData); - void handlePackedFunc(const QVariantList &packedFunc); - void dispatchPackedFunc(const QVariantList &packedFunc); + void handleHandshakeMessage(const QVariantList& mapData); + void handlePackedFunc(const QVariantList& packedFunc); + void dispatchPackedFunc(const QVariantList& packedFunc); }; #endif