Function prioritizeLatestConnection

plugins/network/networkreplymodel.cpp:36–84

namespace {
bool prioritizeLatestConnection(QObject *sender, const char *normalizedSignalName, QObject *receiver)
{
    const auto senderPrivate = QObjectPrivate::get(sender);
    const auto sigIndex = senderPrivate->signalIndex(normalizedSignalName);
    if (sigIndex < 0) {
        return false;
    }

    const auto connectionData = senderPrivate->connections.loadRelaxed();
    if (!connectionData) {
        return false;
    }

    auto signalsVector = connectionData->signalVector.loadRelaxed();
    if (!signalsVector) {
        return false;
    }

    QObjectPrivate::Connection *ourConn = nullptr;
    for (int i = 0; i < signalsVector->count(); ++i) {
        QObjectPrivate::Connection *conn = signalsVector->at(i).first;
        while (conn) {
            if (conn->signal_index == sigIndex && conn->receiver == receiver) {
                ourConn = conn;
                // We continue because we want to locate the latest connection,
                // i.e. the connection we just made
            }

            conn = conn->nextConnectionList;
        }

        // TODO: The whole thing needs to be atomic
        if (ourConn) {
            if (ourConn == signalsVector->at(i).first) {
                qDebug() << "We are already the first, nothing to do";
                return true;
            }

            qDebug() << "Swapping" << ourConn->receiver << "with"
                     << static_cast<QObjectPrivate::Connection *>(signalsVector->at(i).first)->receiver;
            ourConn->prevConnectionList->nextConnectionList.storeRelaxed(ourConn->nextConnectionList);
            ourConn->nextConnectionList.storeRelaxed(signalsVector->at(i).first);
            signalsVector->at(i).first.storeRelaxed(ourConn);
            return true;
        }
    }

    return false;
}

NetworkReply::ContentType contentType(const QVariant &v)
{