aa37e67ef7
We've been requiring C++17 since Qt 6.0, and our qAsConst use finally starts to bother us (QTBUG-99313), so time to port away from it now. Since qAsConst has exactly the same semantics as std::as_const (down to rvalue treatment, constexpr'ness and noexcept'ness), there's really nothing more to it than a global search-and-replace, with manual unstaging of the actual definition and documentation in dist/, src/corelib/doc/ and src/corelib/global/. Task-number: QTBUG-99313 Change-Id: I4c7114444a325ad4e62d0fcbfd347d2bbfb21541 Reviewed-by: Ivan Solovev <ivan.solovev@qt.io>
67 lines
2.0 KiB
C++
67 lines
2.0 KiB
C++
// Copyright (C) 2016 The Qt Company Ltd.
|
|
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR BSD-3-Clause
|
|
|
|
#include "connectionmanager.h"
|
|
#include "peerwireclient.h"
|
|
#include "ratecontroller.h"
|
|
#include "torrentclient.h"
|
|
#include "torrentserver.h"
|
|
|
|
Q_GLOBAL_STATIC(TorrentServer, torrentServer)
|
|
|
|
TorrentServer *TorrentServer::instance()
|
|
{
|
|
return torrentServer();
|
|
}
|
|
|
|
void TorrentServer::addClient(TorrentClient *client)
|
|
{
|
|
clients << client;
|
|
}
|
|
|
|
void TorrentServer::removeClient(TorrentClient *client)
|
|
{
|
|
clients.removeAll(client);
|
|
}
|
|
|
|
void TorrentServer::incomingConnection(qintptr socketDescriptor)
|
|
{
|
|
PeerWireClient *client =
|
|
new PeerWireClient(ConnectionManager::instance()->clientId(), this);
|
|
|
|
if (client->setSocketDescriptor(socketDescriptor)) {
|
|
if (ConnectionManager::instance()->canAddConnection() && !clients.isEmpty()) {
|
|
connect(client, &PeerWireClient::infoHashReceived,
|
|
this, &TorrentServer::processInfoHash);
|
|
connect(client, &PeerWireClient::errorOccurred,
|
|
this, QOverload<>::of(&TorrentServer::removeClient));
|
|
RateController::instance()->addSocket(client);
|
|
ConnectionManager::instance()->addConnection(client);
|
|
return;
|
|
}
|
|
}
|
|
client->abort();
|
|
delete client;
|
|
}
|
|
|
|
void TorrentServer::removeClient()
|
|
{
|
|
PeerWireClient *peer = qobject_cast<PeerWireClient *>(sender());
|
|
RateController::instance()->removeSocket(peer);
|
|
ConnectionManager::instance()->removeConnection(peer);
|
|
peer->deleteLater();
|
|
}
|
|
|
|
void TorrentServer::processInfoHash(const QByteArray &infoHash)
|
|
{
|
|
PeerWireClient *peer = qobject_cast<PeerWireClient *>(sender());
|
|
for (TorrentClient *client : std::as_const(clients)) {
|
|
if (client->state() >= TorrentClient::Searching && client->infoHash() == infoHash) {
|
|
peer->disconnect(peer, nullptr, this, nullptr);
|
|
client->setupIncomingConnection(peer);
|
|
return;
|
|
}
|
|
}
|
|
removeClient();
|
|
}
|