diff options
| author | Linus Jahn <lnj@kaidan.im> | 2020-02-02 18:14:27 +0100 |
|---|---|---|
| committer | LNJ <lnj@kaidan.im> | 2020-02-03 00:11:55 +0100 |
| commit | 57f1b775197aed1d32e98b0299c0999339a7d5f6 (patch) | |
| tree | ce5702781e15f3a5c438ab153edf06f51a501b29 /src/base/QXmppSocks.cpp | |
| parent | 99b850a3008bbb03d3449d683adb87839f7d5c4b (diff) | |
| download | qxmpp-57f1b775197aed1d32e98b0299c0999339a7d5f6.tar.gz | |
Run clang-format also on all cpp files
Diffstat (limited to 'src/base/QXmppSocks.cpp')
| -rw-r--r-- | src/base/QXmppSocks.cpp | 48 |
1 files changed, 18 insertions, 30 deletions
diff --git a/src/base/QXmppSocks.cpp b/src/base/QXmppSocks.cpp index 43a36bf1..cf07a740 100644 --- a/src/base/QXmppSocks.cpp +++ b/src/base/QXmppSocks.cpp @@ -100,9 +100,9 @@ static bool parseHostAndPort(QDataStream &stream, quint8 &type, QByteArray &host QXmppSocksClient::QXmppSocksClient(const QString &proxyHost, quint16 proxyPort, QObject *parent) : QTcpSocket(parent), - m_proxyHost(proxyHost), - m_proxyPort(proxyPort), - m_step(ConnectState) + m_proxyHost(proxyHost), + m_proxyPort(proxyPort), + m_step(ConnectState) { connect(this, &QAbstractSocket::connected, this, &QXmppSocksClient::slotConnected); connect(this, &QIODevice::readyRead, this, &QXmppSocksClient::slotReadyRead); @@ -126,19 +126,17 @@ void QXmppSocksClient::slotConnected() QByteArray buffer; buffer.resize(3); buffer[0] = SocksVersion; - buffer[1] = 0x01; // number of methods + buffer[1] = 0x01; // number of methods buffer[2] = NoAuthentication; write(buffer); } void QXmppSocksClient::slotReadyRead() { - if (m_step == ConnectState) - { + if (m_step == ConnectState) { // receive connect to server response QByteArray buffer = readAll(); - if (buffer.size() != 2 || buffer.at(0) != SocksVersion || buffer.at(1) != NoAuthentication) - { + if (buffer.size() != 2 || buffer.at(0) != SocksVersion || buffer.at(1) != NoAuthentication) { qWarning("QXmppSocksClient received an invalid response during handshake"); close(); return; @@ -151,7 +149,7 @@ void QXmppSocksClient::slotReadyRead() buffer.resize(3); buffer[0] = SocksVersion; buffer[1] = ConnectCommand; - buffer[2] = 0x00; // reserved + buffer[2] = 0x00; // reserved buffer.append(encodeHostAndPort( DomainName, m_hostName.toLatin1(), @@ -167,8 +165,7 @@ void QXmppSocksClient::slotReadyRead() if (buffer.size() != 3 || buffer.at(0) != SocksVersion || buffer.at(1) != Succeeded || - buffer.at(2) != 0) - { + buffer.at(2) != 0) { qWarning("QXmppSocksClient received an invalid response to CONNECT command"); close(); return; @@ -179,8 +176,7 @@ void QXmppSocksClient::slotReadyRead() QByteArray hostName; quint16 hostPort; QDataStream stream(this); - if (!parseHostAndPort(stream, hostType, hostName, hostPort)) - { + if (!parseHostAndPort(stream, hostType, hostName, hostPort)) { qWarning("QXmppSocksClient could not parse type/host/port"); close(); return; @@ -226,7 +222,7 @@ quint16 QXmppSocksServer::serverPort() const void QXmppSocksServer::slotNewConnection() { - auto *server = qobject_cast<QTcpServer*>(sender()); + auto *server = qobject_cast<QTcpServer *>(sender()); if (!server) return; @@ -241,18 +237,16 @@ void QXmppSocksServer::slotNewConnection() void QXmppSocksServer::slotReadyRead() { - auto *socket = qobject_cast<QTcpSocket*>(sender()); + auto *socket = qobject_cast<QTcpSocket *>(sender()); if (!socket || !m_states.contains(socket)) return; - if (m_states.value(socket) == ConnectState) - { + if (m_states.value(socket) == ConnectState) { // receive connect to server request QByteArray buffer = socket->readAll(); if (buffer.size() < 3 || buffer.at(0) != SocksVersion || - buffer.at(1) + 2 != buffer.size()) - { + buffer.at(1) + 2 != buffer.size()) { qWarning("QXmppSocksServer received invalid handshake"); socket->close(); return; @@ -260,16 +254,13 @@ void QXmppSocksServer::slotReadyRead() // check authentication method bool foundMethod = false; - for (int i = 2; i < buffer.size(); i++) - { - if (buffer.at(i) == NoAuthentication) - { + for (int i = 2; i < buffer.size(); i++) { + if (buffer.at(i) == NoAuthentication) { foundMethod = true; break; } } - if (!foundMethod) - { + if (!foundMethod) { qWarning("QXmppSocksServer received bad authentication method"); buffer.resize(2); @@ -299,8 +290,7 @@ void QXmppSocksServer::slotReadyRead() if (buffer.size() != 3 || buffer.at(0) != SocksVersion || buffer.at(1) != ConnectCommand || - buffer.at(2) != 0x00) - { + buffer.at(2) != 0x00) { qWarning("QXmppSocksServer received an invalid command"); socket->close(); return; @@ -311,8 +301,7 @@ void QXmppSocksServer::slotReadyRead() QByteArray hostName; quint16 hostPort; QDataStream stream(socket); - if (!parseHostAndPort(stream, hostType, hostName, hostPort)) - { + if (!parseHostAndPort(stream, hostType, hostName, hostPort)) { qWarning("QXmppSocksServer could not parse type/host/port"); socket->close(); return; @@ -334,4 +323,3 @@ void QXmppSocksServer::slotReadyRead() socket->write(buffer); } } - |
