qbluetoothserver_ohos_p.cpp

Go to the documentation of this file.

// Copyright (C) 2026 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
 
#include <QtBluetooth/private/qbluetoothserver_ohos_p.h>
#include <QtBluetooth/private/qohosbluetoothserver_p.h>
 
#include <iterator>
#include <limits>
#include <optional>
#include <unordered_map>
 
QT_BEGIN_NAMESPACE
 
namespace QtOhosBluetooth {
 
namespace {
 
std::unordered_map<quint16, std::weak_ptr<QOhosBluetoothServerProxyContext>> &serverProxyContexts()
{
    static std::unordered_map<quint16, std::weak_ptr<QOhosBluetoothServerProxyContext>> contexts;
    return contexts;
}
 
void dropExpiredServerProxyContexts()
{
    auto &contexts = serverProxyContexts();
    for (auto context = contexts.begin(); context != contexts.end();)
        context = context->second.expired() ? contexts.erase(context) : std::next(context);
}
 
std::optional<quint16> tryFindFreeServerPort()
{
    constexpr int maxServerPort = std::numeric_limits<quint8>::max();
    for (int candidatePort = 1; candidatePort <= maxServerPort; ++candidatePort) {
        if (!tryGetServerProxyContext(quint16(candidatePort)))
            return quint16(candidatePort);
    }
 
    return std::nullopt;
}
 
}
 
std::shared_ptr<QOhosBluetoothServerProxyContext> makeServerProxyContext(quint16 port)
{
    dropExpiredServerProxyContexts();
 
    const auto optServerPort = port != 0
        ? std::make_optional(port)
        : tryFindFreeServerPort();
    if (!optServerPort || tryGetServerProxyContext(*optServerPort))
        return nullptr;
 
    auto serverProxyContext = std::make_shared<QOhosBluetoothServerProxyContext>();
    serverProxyContext->port = *optServerPort;
    serverProxyContext->bluetoothServerProxy = std::make_shared<QOhosBluetoothServerProxy>();
    serverProxyContext->bluetoothSocket = std::make_shared<QBluetoothSocket>();
    serverProxyContexts()[serverProxyContext->port] = serverProxyContext;
 
    return serverProxyContext;
}
 
std::shared_ptr<QOhosBluetoothServerProxyContext> tryGetServerProxyContext(quint16 port)
{
    auto &contexts = serverProxyContexts();
    const auto found = contexts.find(port);
    return found != contexts.end()
        ? found->second.lock()
        : nullptr;
}
 
bool isServiceNameAlreadyRegistered(const QString &serviceName)
{
    if (serviceName.isEmpty())
        return false;
 
    for (const auto &context : serverProxyContexts()) {
        auto serverProxyContext = context.second.lock();
        if (!serverProxyContext)
            continue;
 
        if (serverProxyContext->bluetoothServerProxy->tryGetRegisteredServiceName() == serviceName)
            return true;
    }
 
    return false;
}
 
}
 
QT_END_NAMESPACE