Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
61 changes: 51 additions & 10 deletions src/dde-control-center/pluginmanager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -174,10 +174,12 @@ PluginManager::PluginManager(DccManager *parent)
, m_rootModule(nullptr)
, m_threadPool(nullptr)
, m_isDeleting(false)
, m_modulePhaseFinished(false)
{
qRegisterMetaType<PluginData>("PluginData");
connect(this, &PluginManager::pluginEndStatusChanged, this, &PluginManager::loadPlugin);
connect(this, &PluginManager::updatePluginStatus, this, &PluginManager::onUpdatePluginStatus);
connect(this, &PluginManager::modulePhaseFinished, this, &PluginManager::onModulePhaseFinished);
connect(m_manager, &DccManager::hideModuleChanged, this, &PluginManager::onHideModuleChanged);
}

Expand Down Expand Up @@ -322,6 +324,18 @@ bool PluginManager::preparePluginFactory(PluginData *plugin)
return true;
}

bool PluginManager::allModulesFinished() const
{
for (auto &&plugin : m_plugins) {
uint status = plugin->status;
bool moduleFinished = (status & ModuleEnd) || (status & ModuleErr) || (status & PluginEnd);
if (!moduleFinished) {
return false;
}
}
return !m_plugins.isEmpty();
}

QThreadPool *PluginManager::threadPool()
{
if (!m_threadPool) {
Expand All @@ -346,16 +360,12 @@ void PluginManager::loadPlugin(PluginData *plugin)
} else if ((plugin->status & (DataEnd | MainObjLoad)) == DataEnd) {
loadMain(plugin);
} else if ((plugin->status & (ModuleEnd | DataBegin)) == ModuleEnd) {
if (plugin->module) {
disconnect(plugin->module, nullptr, this, nullptr);
if (plugin->module->isVisibleToApp()) {
threadPool()->start(new LoadPluginTask(plugin, this));
} else {
connect(plugin->module, &DccObject::visibleToAppChanged, this, &PluginManager::onVisibleToAppChanged);
Q_EMIT updatePluginStatus(plugin, PluginEnd, QString());
}
} else {
threadPool()->start(new LoadPluginTask(plugin, this));
if (!m_modulePhaseFinished && allModulesFinished()) {
Q_EMIT modulePhaseFinished();
return;
}
if (m_modulePhaseFinished) {
loadPluginData(plugin);
}
} else if ((plugin->status & (MetaDataEnd | ModuleLoad)) == MetaDataEnd) {
if (!preparePluginFactory(plugin)) {
Expand Down Expand Up @@ -448,6 +458,24 @@ void PluginManager::loadModule(PluginData *plugin)
}
}

void PluginManager::loadPluginData(PluginData *plugin)
{
if (isDeleting()) {
return;
}
if (plugin->module) {
disconnect(plugin->module, nullptr, this, nullptr);
if (plugin->module->isVisibleToApp()) {
threadPool()->start(new LoadPluginTask(plugin, this));
} else {
connect(plugin->module, &DccObject::visibleToAppChanged, this, &PluginManager::onVisibleToAppChanged);
Q_EMIT updatePluginStatus(plugin, PluginEnd, QString());
}
} else {
threadPool()->start(new LoadPluginTask(plugin, this));
}
}

void PluginManager::loadMain(PluginData *plugin)
{
if (isDeleting()) {
Expand Down Expand Up @@ -591,6 +619,19 @@ void PluginManager::mainLoading()
createMain(component);
}

void PluginManager::onModulePhaseFinished()
{
if (isDeleting()) {
return;
}
m_modulePhaseFinished = true;
for (auto &&plugin : m_plugins) {
if (plugin->status & ModuleEnd) {
loadPlugin(plugin);
}
}
}

void PluginManager::onHideModuleChanged(const QSet<QString> &hideModule)
{
for (auto &&plugin : m_plugins) {
Expand Down
5 changes: 5 additions & 0 deletions src/dde-control-center/pluginmanager.h
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@ public Q_SLOTS:
Q_SIGNALS:
void addObject(DccObject *obj);
void loadAllFinished();
void modulePhaseFinished();

void pluginEndStatusChanged(PluginData *plugin);
void updatePluginStatus(PluginData *plugin, uint status, const QString &log);
Expand All @@ -42,12 +43,14 @@ public Q_SLOTS:
bool compareVersion(const QString &targetVersion, const QString &baseVersion);
bool updatePluginType(PluginData *plugin);
bool preparePluginFactory(PluginData *plugin);
bool allModulesFinished() const;
QThreadPool *threadPool();

private Q_SLOTS:
void loadPlugin(PluginData *plugin);
void loadMetaData(PluginData *plugin);
void loadModule(PluginData *plugin);
void loadPluginData(PluginData *plugin);
void loadMain(PluginData *plugin);
void createModule(QQmlComponent *component);
void createMain(QQmlComponent *component);
Expand All @@ -56,6 +59,7 @@ private Q_SLOTS:
void moduleLoading();
void mainLoading();

void onModulePhaseFinished();
void onHideModuleChanged(const QSet<QString> &hideModule);
void onVisibleToAppChanged(bool visibleToApp);
void onUpdatePluginStatus(PluginData *plugin, uint status, const QString &log);
Expand All @@ -66,6 +70,7 @@ private Q_SLOTS:
DccObject *m_rootModule; // root module from MainWindow
QThreadPool *m_threadPool;
bool m_isDeleting;
bool m_modulePhaseFinished;
QQmlEngine *m_engine;
};

Expand Down
Loading