File indexing completed on 2024-11-10 04:40:39

 /*
     SPDX-FileCopyrightText: 2007 Volker Krause <vkrause@kde.org>
 
     SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "control.h"
 #include "akonadicore_debug.h"
 #include "servermanager.h"
 
 #include <QCoreApplication>
 #include <QEventLoop>
 #include <QPointer>
 
 using namespace Akonadi;
 
 namespace Akonadi
 {
 namespace Internal
 {
 class StaticControl : public Control
 {
     Q_OBJECT
 };
 
 }
 
 Q_GLOBAL_STATIC(Internal::StaticControl, s_instance) // NOLINT(readability-redundant-member-init)
 
 /**
  * @internal
  */
 class ControlPrivate
 {
 public:
     explicit ControlPrivate(Control *parent)
         : mParent(parent)
     {
     }
 
     void cleanup()
     {
     }
 
     bool exec();
     void serverStateChanged(ServerManager::State state);
 
     QPointer<Control> mParent;
     QEventLoop *mEventLoop = nullptr;
     bool mSuccess = false;
 
     bool mStarting = false;
     bool mStopping = false;
 };
 
 bool ControlPrivate::exec()
 {
     qCDebug(AKONADICORE_LOG) << "Starting/Stopping Akonadi (using an event loop).";
     mEventLoop = new QEventLoop(mParent);
     mEventLoop->exec();
     mEventLoop->deleteLater();
     mEventLoop = nullptr;
 
     if (!mSuccess) {
         qCWarning(AKONADICORE_LOG) << "Could not start/stop Akonadi!";
     }
 
     mStarting = false;
     mStopping = false;
 
     const bool rv = mSuccess;
     mSuccess = false;
     return rv;
 }
 
 void ControlPrivate::serverStateChanged(ServerManager::State state)
 {
     qCDebug(AKONADICORE_LOG) << "Server state changed to" << state;
     if (mEventLoop && mEventLoop->isRunning()) {
         // ignore transient states going into the right direction
         if ((mStarting && (state == ServerManager::Starting || state == ServerManager::Upgrading)) || (mStopping && state == ServerManager::Stopping)) {
             return;
         }
         mEventLoop->quit();
         mSuccess = (mStarting && state == ServerManager::Running) || (mStopping && state == ServerManager::NotRunning);
     }
 }
 
 Control::Control()
     : d(new ControlPrivate(this))
 {
     connect(ServerManager::self(), &ServerManager::stateChanged, this, [this](Akonadi::ServerManager::State state) {
         d->serverStateChanged(state);
     });
     // mProgressIndicator is a widget, so it better be deleted before the QApplication is deleted
     // Otherwise we get a crash in QCursor code with Qt-4.5
     if (QCoreApplication::instance()) {
         connect(QCoreApplication::instance(), &QCoreApplication::aboutToQuit, this, [this]() {
             d->cleanup();
         });
     }
 }
 
 Control::~Control() = default;
 
 bool Control::start()
 {
     if (ServerManager::state() == ServerManager::Stopping) {
         qCDebug(AKONADICORE_LOG) << "Server is currently being stopped, won't try to start it now";
         return false;
     }
     if (ServerManager::isRunning() || s_instance->d->mEventLoop) {
         qCDebug(AKONADICORE_LOG) << "Server is already running";
         return true;
     }
     s_instance->d->mStarting = true;
     if (!ServerManager::start()) {
         qCDebug(AKONADICORE_LOG) << "ServerManager::start failed -> return false";
         return false;
     }
     return s_instance->d->exec();
 }
 
 bool Control::stop()
 {
     if (ServerManager::state() == ServerManager::Starting) {
         return false;
     }
     if (!ServerManager::isRunning() || s_instance->d->mEventLoop) {
         return true;
     }
     s_instance->d->mStopping = true;
     if (!ServerManager::stop()) {
         return false;
     }
     return s_instance->d->exec();
 }
 
 bool Control::restart()
 {
     if (ServerManager::isRunning()) {
         if (!stop()) {
             return false;
         }
     }
     return start();
 }
 
 } // namespace Akonadi
 
 #include "control.moc"
 
 #include "moc_control.cpp"