Revision control
Copy as Markdown
// Copyright (C) 2016 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
// Qt-Security score:significant reason:default
#include "qabstractsocketengine_p.h"
#include "qnativesocketengine_p.h"
#include "qmutex.h"
#include "qnetworkproxy.h"
QT_BEGIN_NAMESPACE
QAbstractSocketEngineReceiver::~QAbstractSocketEngineReceiver() = default;
class QSocketEngineHandlerList : public QList<QSocketEngineHandler*>
{
public:
QMutex mutex;
};
Q_GLOBAL_STATIC(QSocketEngineHandlerList, socketHandlers)
QSocketEngineHandler::QSocketEngineHandler()
{
if (!socketHandlers())
return;
QMutexLocker locker(&socketHandlers()->mutex);
socketHandlers()->prepend(this);
}
QSocketEngineHandler::~QSocketEngineHandler()
{
if (!socketHandlers())
return;
QMutexLocker locker(&socketHandlers()->mutex);
socketHandlers()->removeAll(this);
}
QAbstractSocketEnginePrivate::QAbstractSocketEnginePrivate()
: socketError(QAbstractSocket::UnknownSocketError)
, hasSetSocketError(false)
, socketErrorString(QLatin1StringView(QT_TRANSLATE_NOOP(QSocketLayer, "Unknown error")))
, socketState(QAbstractSocket::UnconnectedState)
, socketType(QAbstractSocket::UnknownSocketType)
, socketProtocol(QAbstractSocket::UnknownNetworkLayerProtocol)
, localPort(0)
, peerPort(0)
, inboundStreamCount(0)
, outboundStreamCount(0)
, receiver(nullptr)
{
}
QAbstractSocketEngine::QAbstractSocketEngine(QObject *parent)
: QObject(*new QAbstractSocketEnginePrivate(), parent)
{
}
QAbstractSocketEngine::QAbstractSocketEngine(QAbstractSocketEnginePrivate &dd, QObject* parent)
: QObject(dd, parent)
{
}
QAbstractSocketEngine *QAbstractSocketEngine::createSocketEngine(QAbstractSocket::SocketType socketType, const QNetworkProxy &proxy, QObject *parent)
{
#ifndef QT_NO_NETWORKPROXY
// proxy type must have been resolved by now
if (proxy.type() == QNetworkProxy::DefaultProxy)
return nullptr;
#endif
QMutexLocker locker(&socketHandlers()->mutex);
for (int i = 0; i < socketHandlers()->size(); i++) {
if (QAbstractSocketEngine *ret = socketHandlers()->at(i)->createSocketEngine(socketType, proxy, parent))
return ret;
}
#ifndef QT_NO_NETWORKPROXY
// only NoProxy can have reached here
if (proxy.type() != QNetworkProxy::NoProxy)
return nullptr;
#endif
return new QNativeSocketEngine(parent);
}
QAbstractSocketEngine *QAbstractSocketEngine::createSocketEngine(qintptr socketDescripter, QObject *parent)
{
QMutexLocker locker(&socketHandlers()->mutex);
for (int i = 0; i < socketHandlers()->size(); i++) {
if (QAbstractSocketEngine *ret = socketHandlers()->at(i)->createSocketEngine(socketDescripter, parent))
return ret;
}
return new QNativeSocketEngine(parent);
}
QAbstractSocket::SocketError QAbstractSocketEngine::error() const
{
return d_func()->socketError;
}
QString QAbstractSocketEngine::errorString() const
{
return d_func()->socketErrorString;
}
void QAbstractSocketEngine::setError(QAbstractSocket::SocketError error, const QString &errorString) const
{
Q_D(const QAbstractSocketEngine);
d->socketError = error;
d->socketErrorString = errorString;
}
void QAbstractSocketEngine::setReceiver(QAbstractSocketEngineReceiver *receiver)
{
d_func()->receiver = receiver;
}
void QAbstractSocketEngine::readNotification()
{
if (QAbstractSocketEngineReceiver *receiver = d_func()->receiver)
receiver->readNotification();
}
void QAbstractSocketEngine::writeNotification()
{
if (QAbstractSocketEngineReceiver *receiver = d_func()->receiver)
receiver->writeNotification();
}
void QAbstractSocketEngine::exceptionNotification()
{
if (QAbstractSocketEngineReceiver *receiver = d_func()->receiver)
receiver->exceptionNotification();
}
void QAbstractSocketEngine::closeNotification()
{
if (QAbstractSocketEngineReceiver *receiver = d_func()->receiver)
receiver->closeNotification();
}
void QAbstractSocketEngine::connectionNotification()
{
if (QAbstractSocketEngineReceiver *receiver = d_func()->receiver)
receiver->connectionNotification();
}
#ifndef QT_NO_NETWORKPROXY
void QAbstractSocketEngine::proxyAuthenticationRequired(const QNetworkProxy &proxy, QAuthenticator *authenticator)
{
if (QAbstractSocketEngineReceiver *receiver = d_func()->receiver)
receiver->proxyAuthenticationRequired(proxy, authenticator);
}
#endif
QAbstractSocket::SocketState QAbstractSocketEngine::state() const
{
return d_func()->socketState;
}
void QAbstractSocketEngine::setState(QAbstractSocket::SocketState state)
{
d_func()->socketState = state;
}
QAbstractSocket::SocketType QAbstractSocketEngine::socketType() const
{
return d_func()->socketType;
}
void QAbstractSocketEngine::setSocketType(QAbstractSocket::SocketType socketType)
{
d_func()->socketType = socketType;
}
QAbstractSocket::NetworkLayerProtocol QAbstractSocketEngine::protocol() const
{
return d_func()->socketProtocol;
}
void QAbstractSocketEngine::setProtocol(QAbstractSocket::NetworkLayerProtocol protocol)
{
d_func()->socketProtocol = protocol;
}
QHostAddress QAbstractSocketEngine::localAddress() const
{
return d_func()->localAddress;
}
void QAbstractSocketEngine::setLocalAddress(const QHostAddress &address)
{
d_func()->localAddress = address;
}
quint16 QAbstractSocketEngine::localPort() const
{
return d_func()->localPort;
}
void QAbstractSocketEngine::setLocalPort(quint16 port)
{
d_func()->localPort = port;
}
QHostAddress QAbstractSocketEngine::peerAddress() const
{
return d_func()->peerAddress;
}
void QAbstractSocketEngine::setPeerAddress(const QHostAddress &address)
{
d_func()->peerAddress = address;
}
quint16 QAbstractSocketEngine::peerPort() const
{
return d_func()->peerPort;
}
void QAbstractSocketEngine::setPeerPort(quint16 port)
{
d_func()->peerPort = port;
}
int QAbstractSocketEngine::inboundStreamCount() const
{
return d_func()->inboundStreamCount;
}
int QAbstractSocketEngine::outboundStreamCount() const
{
return d_func()->outboundStreamCount;
}
QT_END_NAMESPACE
#include "moc_qabstractsocketengine_p.cpp"