forked from qt-creator/qt-creator
f84199f8b7
Short live Tasking in Solutions! Add src/libs/solutions/README.md with the motivation and hints. Move TaskTree and Barrier from Utils into Tasking object lib, the first solution in Solutions project. Tasking: Some more work is still required for adapting auto and manual tests. Currently they use Async task, which stayed in Utils. For Qt purposed we most probably need to have a clone of Async task inside the Tasking namespace that is more Qt-like (no Utils::FutureSynchronizer, no priority field, global QThreadPool instead of a custom one for Creator). Change-Id: I5d10a2d68170ffa467d8c299be5995b9aa4f8f77 Reviewed-by: Cristian Adam <cristian.adam@qt.io> Reviewed-by: hjk <hjk@qt.io> Reviewed-by: Eike Ziller <eike.ziller@qt.io> Reviewed-by: Qt CI Bot <qt_ci_bot@qt-project.org>
81 lines
2.3 KiB
C++
81 lines
2.3 KiB
C++
// Copyright (C) 2023 The Qt Company Ltd.
|
|
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only WITH Qt-GPL-exception-1.0
|
|
|
|
#pragma once
|
|
|
|
#include "languageclient_global.h"
|
|
|
|
#include "client.h"
|
|
|
|
#include <languageserverprotocol/lsptypes.h>
|
|
#include <languageserverprotocol/lsputils.h>
|
|
#include <languageserverprotocol/workspace.h>
|
|
|
|
#include <solutions/tasking/tasktree.h>
|
|
|
|
namespace LanguageClient {
|
|
|
|
template <typename Request>
|
|
class LANGUAGECLIENT_EXPORT ClientRequestTask
|
|
{
|
|
public:
|
|
virtual ~ClientRequestTask()
|
|
{
|
|
if (m_id)
|
|
m_client->cancelRequest(*m_id); // In order to not to invoke a response callback anymore
|
|
}
|
|
|
|
void setClient(Client *client) { m_client = client; }
|
|
Client *client() const { return m_client; }
|
|
void setParams(const typename Request::Parameters ¶ms) { m_params = params; }
|
|
|
|
void start()
|
|
{
|
|
QTC_ASSERT(!isRunning(), return);
|
|
if (!preStartCheck()) {
|
|
m_callback({});
|
|
return;
|
|
}
|
|
Request request(m_params);
|
|
request.setResponseCallback([this](const typename Request::Response &response) {
|
|
m_response = response;
|
|
m_id = {};
|
|
m_callback(response);
|
|
});
|
|
m_id = request.id();
|
|
m_client->sendMessage(request);
|
|
}
|
|
|
|
bool isRunning() const { return m_id.has_value(); }
|
|
virtual bool preStartCheck() { return m_client && m_client->reachable() && m_params.isValid(); }
|
|
|
|
typename Request::Response response() const { return m_response; }
|
|
void setResponseCallback(typename Request::ResponseCallback callback) { m_callback = callback; }
|
|
|
|
private:
|
|
Client *m_client = nullptr;
|
|
typename Request::Parameters m_params;
|
|
typename Request::ResponseCallback m_callback;
|
|
std::optional<LanguageServerProtocol::MessageId> m_id;
|
|
typename Request::Response m_response;
|
|
};
|
|
|
|
class LANGUAGECLIENT_EXPORT WorkspaceSymbolRequestTask
|
|
: public ClientRequestTask<LanguageServerProtocol::WorkspaceSymbolRequest>
|
|
{
|
|
public:
|
|
bool preStartCheck() override;
|
|
};
|
|
|
|
class LANGUAGECLIENT_EXPORT WorkspaceSymbolRequestTaskAdapter
|
|
: public Tasking::TaskAdapter<WorkspaceSymbolRequestTask>
|
|
{
|
|
public:
|
|
WorkspaceSymbolRequestTaskAdapter();
|
|
void start() final;
|
|
};
|
|
|
|
} // namespace LanguageClient
|
|
|
|
TASKING_DECLARE_TASK(SymbolRequest, LanguageClient::WorkspaceSymbolRequestTaskAdapter);
|