LSP: use asynchronous shutdown for running servers

Change-Id: I3b1853177d07c98e051de0bc9f494389fbf4c104
Reviewed-by: Eike Ziller <eike.ziller@qt.io>

src/plugins/languageclient/languageclientmanager.cpp

@@ -82,8 +82,7 @@ LanguageClientManager::LanguageClientManager()
 
 LanguageClientManager::~LanguageClientManager()
 {
-    for (auto interface : Utils::filtered(m_clients, &BaseClient::reachable))
+    QTC_ASSERT(m_clients.isEmpty(), qDeleteAll(m_clients));
-        interface->shutdown();
 }
 
 void LanguageClientManager::init()
@@ -168,6 +167,8 @@ void LanguageClientManager::removeMarks(const Core::Id &id)
 
 void LanguageClientManager::startClient(LanguageClientSettings setting)
 {
+    if (managerInstance->m_shuttingDown)
+        return;
     auto client = new StdIOClient(setting.m_executable, setting.m_arguments);
     client->setName(setting.m_name);
     if (setting.m_mimeType != noLanguageFilter)
@@ -177,6 +178,10 @@ void LanguageClientManager::startClient(LanguageClientSettings setting)
 
 void LanguageClientManager::startClient(BaseClient *client)
 {
+    if (managerInstance->m_shuttingDown) {
+        managerInstance->clientFinished(client);
+        return;
+    }
     if (!managerInstance->m_clients.contains(client))
         managerInstance->m_clients.append(client);
     connect(client, &BaseClient::finished, managerInstance, [client](){
@@ -215,6 +220,20 @@ void LanguageClientManager::deleteClient(BaseClient *client)
     delete client;
 }
 
+void LanguageClientManager::shutdown()
+{
+    if (managerInstance->m_shuttingDown)
+        return;
+    managerInstance->m_shuttingDown = true;
+    for (auto interface : managerInstance->m_clients)
+        interface->shutdown();
+}
+
+LanguageClientManager *LanguageClientManager::instance()
+{
+    return managerInstance;
+}
+
 QVector<BaseClient *> LanguageClientManager::reachableClients()
 {
     return Utils::filtered(m_clients, &BaseClient::reachable);
@@ -236,15 +255,17 @@ void LanguageClientManager::clientFinished(BaseClient *client)
     constexpr int restartTimeoutS = 5;
     const bool unexpectedFinish = client->state() != BaseClient::Shutdown
             && client->state() != BaseClient::ShutdownRequested;
-    if (unexpectedFinish) {
+    if (unexpectedFinish && !m_shuttingDown) {
-        managerInstance->removeMarks(client->id());
+        removeMarks(client->id());
-        client->disconnect(managerInstance);
+        client->disconnect(this);
         client->log(tr("Unexpectedly finished. Restarting in %1 seconds.").arg(restartTimeoutS),
                     Core::MessageManager::Flash);
         client->reset();
-        QTimer::singleShot(restartTimeoutS * 1000, this, [client](){ startClient(client); });
+        QTimer::singleShot(restartTimeoutS * 1000, client, [client](){ startClient(client); });
     } else {
         deleteClient(client);
+        if (m_shuttingDown && m_clients.isEmpty())
+            emit shutdownFinished();
     }
 }
 

src/plugins/languageclient/languageclientmanager.h

@@ -70,6 +70,13 @@ public:
 
     static void deleteClient(BaseClient *client);
 
+    static void shutdown();
+
+    static LanguageClientManager *instance();
+
+signals:
+    void shutdownFinished();
+
 private:
     LanguageClientManager();
     LanguageClientManager(const LanguageClientManager &other) = delete;
@@ -90,6 +97,7 @@ private:
 
     void clientFinished(BaseClient *client);
 
+    bool m_shuttingDown = false;
     QVector<BaseClient *> m_clients;
     QHash<Utils::FileName, QHash<Core::Id, QVector<LanguageClientMark *>>> m_marks;
     QHash<LanguageServerProtocol::MessageId, QList<BaseClient *>> m_exclusiveRequests;

src/plugins/languageclient/languageclientplugin.cpp

@@ -25,6 +25,8 @@
 
 #include "languageclientplugin.h"
 
+#include "baseclient.h"
+
 namespace LanguageClient {
 
 bool LanguageClientPlugin::initialize(const QStringList & /*arguments*/, QString * /*errorString*/)
@@ -38,4 +40,14 @@ void LanguageClientPlugin::extensionsInitialized()
     LanguageClientSettings::init();
 }
 
+ExtensionSystem::IPlugin::ShutdownFlag LanguageClientPlugin::aboutToShutdown()
+{
+    LanguageClientManager::shutdown();
+    if (LanguageClientManager::clients().isEmpty())
+        return ExtensionSystem::IPlugin::SynchronousShutdown;
+    connect(LanguageClientManager::instance(), &LanguageClientManager::shutdownFinished,
+            this, &ExtensionSystem::IPlugin::asynchronousShutdownFinished);
+    return ExtensionSystem::IPlugin::AsynchronousShutdown;
+}
+
 } // namespace LanguageClient

src/plugins/languageclient/languageclientplugin.h

@@ -43,6 +43,7 @@ public:
 private:
     bool initialize(const QStringList &arguments, QString *errorString) override;
     void extensionsInitialized() override;
+    ShutdownFlag aboutToShutdown() override;
 
 private:
     LanguageClientManager m_clientManager;