diff options
Diffstat (limited to 'PluginLoader.cpp')
| -rw-r--r--[-rwxr-xr-x] | PluginLoader.cpp | 440 |
1 files changed, 251 insertions, 189 deletions
diff --git a/PluginLoader.cpp b/PluginLoader.cpp index 1e63633..7577885 100755..100644 --- a/PluginLoader.cpp +++ b/PluginLoader.cpp @@ -1,240 +1,302 @@ /** \file PluginLoader.h \brief Define the plugin loader \author alpha_one_x86 -\version 0.3 -\date 2010 \licence GPL3, see the file COPYING */ #include "PluginLoader.h" +#include "LanguagesManager.h" PluginLoader::PluginLoader(OptionDialog *optionDialog) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - this->optionDialog=optionDialog; - //load the overall instance - plugins=PluginsManager::getInstance(); - //load the plugin - plugins->lockPluginListEdition(); - qRegisterMetaType<PluginsAvailable>("PluginsAvailable"); - qRegisterMetaType<CatchState>("CatchState"); - connect(this,SIGNAL(previouslyPluginAdded(PluginsAvailable)), this,SLOT(onePluginAdded(PluginsAvailable)),Qt::QueuedConnection); - connect(plugins,SIGNAL(onePluginAdded(PluginsAvailable)), this,SLOT(onePluginAdded(PluginsAvailable)),Qt::QueuedConnection); - connect(plugins,SIGNAL(onePluginWillBeRemoved(PluginsAvailable)), this,SLOT(onePluginWillBeRemoved(PluginsAvailable)),Qt::DirectConnection); - connect(plugins,SIGNAL(pluginListingIsfinish()), this,SLOT(allPluginIsloaded()),Qt::QueuedConnection); - QList<PluginsAvailable> list=plugins->getPluginsByCategory(PluginType_PluginLoader); - foreach(PluginsAvailable currentPlugin,list) - emit previouslyPluginAdded(currentPlugin); - plugins->unlockPluginListEdition(); - needEnable=false; - last_state=Uncaught; - last_have_plugin=false; - last_inWaitOfReply=false; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + this->optionDialog=optionDialog; + //load the overall instance + //load the plugin + PluginsManager::pluginsManager->lockPluginListEdition(); + connect(this,&PluginLoader::previouslyPluginAdded, this,&PluginLoader::onePluginAdded,Qt::QueuedConnection); + connect(PluginsManager::pluginsManager,&PluginsManager::onePluginAdded, this,&PluginLoader::onePluginAdded,Qt::QueuedConnection); + #ifndef ULTRACOPIER_PLUGIN_ALL_IN_ONE + connect(PluginsManager::pluginsManager,&PluginsManager::onePluginWillBeRemoved,this,&PluginLoader::onePluginWillBeRemoved,Qt::DirectConnection); + #endif + connect(PluginsManager::pluginsManager,&PluginsManager::pluginListingIsfinish, this,&PluginLoader::allPluginIsloaded,Qt::QueuedConnection); + QList<PluginsAvailable> list=PluginsManager::pluginsManager->getPluginsByCategory(PluginType_PluginLoader); + foreach(PluginsAvailable currentPlugin,list) + emit previouslyPluginAdded(currentPlugin); + PluginsManager::pluginsManager->unlockPluginListEdition(); + needEnable=false; + last_state=Ultracopier::Uncaught; + last_have_plugin=false; + last_inWaitOfReply=false; + stopIt=false; } PluginLoader::~PluginLoader() { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - QList<PluginsAvailable> list=plugins->getPluginsByCategory(PluginType_PluginLoader); - foreach(PluginsAvailable currentPlugin,list) - onePluginWillBeRemoved(currentPlugin); - PluginsManager::destroyInstanceAtTheLastCall(); + stopIt=true; + #ifndef ULTRACOPIER_PLUGIN_ALL_IN_ONE_DIRECT + { + /* why it crash here? Only under Window with PluginLoader/catchcopy-v0002 + int index=0; + while(index<pluginList.size()) + { + pluginList.at(index).pluginLoaderInterface->setEnabled(false); + if(pluginList.at(index).pluginLoader!=NULL) + { + if(!pluginList.at(index).pluginLoader->isLoaded() || pluginList.at(index).pluginLoader->unload()) + { + delete pluginList.at(index).options; + pluginList.removeAt(index); + } + else + index++; + } + else + index++; + }//*/ + } + #endif } void PluginLoader::resendState() { - sendState(true); + if(stopIt) + return; + sendState(true); } void PluginLoader::onePluginAdded(const PluginsAvailable &plugin) { - if(plugin.category!=PluginType_PluginLoader) - return; - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - QString pluginPath=plugin.path+PluginsManager::getResolvedPluginName("pluginLoader"); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"try load: "+pluginPath); - QPluginLoader *pluginLoader= new QPluginLoader(pluginPath); - QObject *pluginInstance = pluginLoader->instance(); - if(pluginInstance) - { - PluginInterface_PluginLoader *PluginLoader = qobject_cast<PluginInterface_PluginLoader *>(pluginInstance); - //check if found - index=0; - loop_size=pluginList.size(); - while(index<loop_size) - { - if(pluginList.at(index).PluginLoaderInterface==PluginLoader) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("Plugin already found")); - pluginLoader->unload(); - return; - } - index++; - } - if(PluginLoader) - { - #ifdef ULTRACOPIER_DEBUG - connect(PluginLoader,SIGNAL(debugInformation(DebugLevel,QString,QString,QString,int)),this,SLOT(debugInformation(DebugLevel,QString,QString,QString,int))); - #endif // ULTRACOPIER_DEBUG - LocalPlugin newEntry; - newEntry.options=new LocalPluginOptions("PluginLoader-"+plugin.name); - newEntry.pluginLoader = pluginLoader; - newEntry.PluginLoaderInterface = PluginLoader; - newEntry.path = plugin.path; - newEntry.state = Uncaught; - newEntry.inWaitOfReply = false; - pluginList << newEntry; - PluginLoader->setResources(newEntry.options,plugin.writablePath,plugin.path,ULTRACOPIER_VERSION_PORTABLE_BOOL); - optionDialog->addPluginOptionWidget(PluginType_PluginLoader,plugin.name,newEntry.PluginLoaderInterface->options()); - connect(pluginList.last().PluginLoaderInterface,SIGNAL(newState(CatchState)),this,SLOT(newState(CatchState))); - connect(languages,SIGNAL(newLanguageLoaded(QString)),newEntry.PluginLoaderInterface,SLOT(newLanguageLoaded())); - if(needEnable) - { - pluginList.last().inWaitOfReply=true; - newEntry.PluginLoaderInterface->setEnabled(needEnable); - } + #ifndef ULTRACOPIER_PLUGIN_ALL_IN_ONE_DIRECT + if(stopIt) + return; + if(plugin.category!=PluginType_PluginLoader) + return; + LocalPlugin newEntry; + QString pluginPath=plugin.path+PluginsManager::getResolvedPluginName(QStringLiteral("pluginLoader")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("try load: ")+pluginPath); + #ifdef ULTRACOPIER_PLUGIN_ALL_IN_ONE + PluginInterface_PluginLoader *pluginLoaderInstance; + QObjectList objectList=QPluginLoader::staticInstances(); + int index=0; + QObject *pluginObject; + while(index<objectList.size()) + { + pluginObject=objectList.at(index); + pluginLoaderInstance = qobject_cast<PluginInterface_PluginLoader *>(pluginObject); + if(pluginLoaderInstance!=NULL) + break; + index++; + } + if(index==objectList.size()) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QStringLiteral("static listener not found")); + return; + } + newEntry.pluginLoader=NULL; + #else + QPluginLoader *pluginLoader= new QPluginLoader(pluginPath); + QObject *pluginInstance = pluginLoader->instance(); + if(!pluginInstance) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QStringLiteral("unable to load the plugin: ")+pluginLoader->errorString()); + return; + } + PluginInterface_PluginLoader *pluginLoaderInstance = qobject_cast<PluginInterface_PluginLoader *>(pluginInstance); + if(!pluginLoaderInstance) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QStringLiteral("unable to cast the plugin: ")+pluginLoader->errorString()); + return; + } + newEntry.pluginLoader = pluginLoader; + //check if found + int index=0; + const int &loop_size=pluginList.size(); + while(index<loop_size) + { + if(pluginList.at(index).pluginLoaderInterface==pluginLoaderInstance) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QStringLiteral("Plugin already found")); + pluginLoader->unload(); + return; + } + index++; + } + #endif + #ifdef ULTRACOPIER_DEBUG + connect(pluginLoaderInstance,&PluginInterface_PluginLoader::debugInformation,this,&PluginLoader::debugInformation,Qt::DirectConnection); + #endif // ULTRACOPIER_DEBUG - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to cast the plugin: "+pluginLoader->errorString()); - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to load the plugin: "+pluginLoader->errorString()); + newEntry.options=new LocalPluginOptions(QStringLiteral("PluginLoader-")+plugin.name); + newEntry.pluginLoaderInterface = pluginLoaderInstance; + newEntry.path = plugin.path; + newEntry.state = Ultracopier::Uncaught; + newEntry.inWaitOfReply = false; + pluginList << newEntry; + pluginLoaderInstance->setResources(newEntry.options,plugin.writablePath,plugin.path,ULTRACOPIER_VERSION_PORTABLE_BOOL); + optionDialog->addPluginOptionWidget(PluginType_PluginLoader,plugin.name,newEntry.pluginLoaderInterface->options()); + connect(pluginList.last().pluginLoaderInterface,&PluginInterface_PluginLoader::newState,this,&PluginLoader::newState,Qt::DirectConnection); + connect(LanguagesManager::languagesManager,&LanguagesManager::newLanguageLoaded,newEntry.pluginLoaderInterface,&PluginInterface_PluginLoader::newLanguageLoaded,Qt::DirectConnection); + if(needEnable) + { + pluginList.last().inWaitOfReply=true; + newEntry.pluginLoaderInterface->setEnabled(needEnable); + } + #else + Q_UNUSED(plugin); + #endif } +#ifndef ULTRACOPIER_PLUGIN_ALL_IN_ONE void PluginLoader::onePluginWillBeRemoved(const PluginsAvailable &plugin) { - if(plugin.category!=PluginType_PluginLoader) - return; - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - index=0; - loop_size=pluginList.size(); - while(index<loop_size) - { - if(plugin.path==pluginList.at(index).path) - { - pluginList.at(index).PluginLoaderInterface->setEnabled(false); - if(!pluginList.at(index).pluginLoader->isLoaded() || pluginList.at(index).pluginLoader->unload()) - { - delete pluginList.at(index).options; - pluginList.removeAt(index); - } - sendState(); - return; - } - index++; - } + if(stopIt) + return; + if(plugin.category!=PluginType_PluginLoader) + return; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + int index=0; + const int &loop_size=pluginList.size(); + while(index<loop_size) + { + if(plugin.path==pluginList.at(index).path) + { + pluginList.at(index).pluginLoaderInterface->setEnabled(false); + if(pluginList.at(index).pluginLoader!=NULL) + { + if(!pluginList.at(index).pluginLoader->isLoaded() || pluginList.at(index).pluginLoader->unload()) + { + delete pluginList.at(index).options; + pluginList.removeAt(index); + } + } + sendState(); + return; + } + index++; + } } +#endif void PluginLoader::load() { - needEnable=true; - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - int index=0; - while(index<pluginList.size()) - { - pluginList[index].inWaitOfReply=true; - pluginList.at(index).PluginLoaderInterface->setEnabled(true); - index++; - } - sendState(true); + if(stopIt) + return; + needEnable=true; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + int index=0; + while(index<pluginList.size()) + { + pluginList[index].inWaitOfReply=true; + pluginList.at(index).pluginLoaderInterface->setEnabled(true); + index++; + } + sendState(true); } void PluginLoader::unload() { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - needEnable=false; - int index=0; - while(index<pluginList.size()) - { - pluginList[index].inWaitOfReply=true; - pluginList.at(index).PluginLoaderInterface->setEnabled(false); - index++; - } - sendState(true); + if(stopIt) + return; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + needEnable=false; + int index=0; + while(index<pluginList.size()) + { + pluginList[index].inWaitOfReply=true; + pluginList.at(index).pluginLoaderInterface->setEnabled(false); + index++; + } + sendState(true); } #ifdef ULTRACOPIER_DEBUG -void PluginLoader::debugInformation(DebugLevel level,const QString& fonction,const QString& text,const QString& file,const int& ligne) +void PluginLoader::debugInformation(const Ultracopier::DebugLevel &level,const QString& fonction,const QString& text,const QString& file,const int& ligne) { - DebugEngine::addDebugInformationStatic(level,fonction,text,file,ligne,"Plugin loader plugin"); + DebugEngine::addDebugInformationStatic(level,fonction,text,file,ligne,QStringLiteral("Plugin loader plugin")); } #endif // ULTRACOPIER_DEBUG void PluginLoader::allPluginIsloaded() { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"with value: "+QString::number(pluginList.size()>0)); - sendState(true); + if(stopIt) + return; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("with value: ")+QString::number(pluginList.size()>0)); + sendState(true); } void PluginLoader::sendState(bool force) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start, pluginList.size(): %1, force: %2").arg(pluginList.size()).arg(force)); - CatchState current_state=Uncaught; - bool found_not_listen=false,found_listen=false,found_inWaitOfReply=false; - int index=0; - while(index<pluginList.size()) - { - if(current_state==Uncaught) - { - if(pluginList.at(index).state==Semiuncaught) - current_state=Semiuncaught; - else if(pluginList.at(index).state==Uncaught) - found_not_listen=true; - else if(pluginList.at(index).state==Caught) - found_listen=true; - } - if(pluginList.at(index).inWaitOfReply) - found_inWaitOfReply=true; - index++; - } - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("current_state: %1").arg(current_state)); - if(current_state==Uncaught) - { - if(!found_not_listen && !found_listen) - { - if(needEnable) - current_state=Caught; - } - else if(found_not_listen && !found_listen) - current_state=Uncaught; - else if(!found_not_listen && found_listen) - current_state=Caught; - else - current_state=Semiuncaught; - } - bool have_plugin=pluginList.size()>0; - if(force || current_state!=last_state || have_plugin!=last_have_plugin || found_inWaitOfReply!=last_inWaitOfReply) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("send pluginLoaderReady(%1,%2,%3)").arg(current_state).arg(have_plugin).arg(found_inWaitOfReply)); - emit pluginLoaderReady(current_state,have_plugin,found_inWaitOfReply); - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("Skip the signal sending")); - last_state=current_state; - last_have_plugin=have_plugin; - last_inWaitOfReply=found_inWaitOfReply; + if(stopIt) + return; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start, pluginList.size(): %1, force: %2").arg(pluginList.size()).arg(force)); + Ultracopier::CatchState current_state=Ultracopier::Uncaught; + bool found_not_listen=false,found_listen=false,found_inWaitOfReply=false; + int index=0; + while(index<pluginList.size()) + { + if(current_state==Ultracopier::Uncaught) + { + if(pluginList.at(index).state==Ultracopier::Semiuncaught) + current_state=Ultracopier::Semiuncaught; + else if(pluginList.at(index).state==Ultracopier::Uncaught) + found_not_listen=true; + else if(pluginList.at(index).state==Ultracopier::Caught) + found_listen=true; + } + if(pluginList.at(index).inWaitOfReply) + found_inWaitOfReply=true; + index++; + } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("current_state: %1").arg(current_state)); + if(current_state==Ultracopier::Uncaught) + { + if(!found_not_listen && !found_listen) + { + if(needEnable) + current_state=Ultracopier::Caught; + } + else if(found_not_listen && !found_listen) + current_state=Ultracopier::Uncaught; + else if(!found_not_listen && found_listen) + current_state=Ultracopier::Caught; + else + current_state=Ultracopier::Semiuncaught; + } + bool have_plugin=pluginList.size()>0; + if(force || current_state!=last_state || have_plugin!=last_have_plugin || found_inWaitOfReply!=last_inWaitOfReply) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("send pluginLoaderReady(%1,%2,%3)").arg(current_state).arg(have_plugin).arg(found_inWaitOfReply)); + emit pluginLoaderReady(current_state,have_plugin,found_inWaitOfReply); + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("Skip the signal sending")); + last_state=current_state; + last_have_plugin=have_plugin; + last_inWaitOfReply=found_inWaitOfReply; } -void PluginLoader::newState(const CatchState &state) +void PluginLoader::newState(const Ultracopier::CatchState &state) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start, state: %1").arg(state)); - PluginInterface_PluginLoader *temp=qobject_cast<PluginInterface_PluginLoader *>(QObject::sender()); - if(temp==NULL) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("listener not located!")); - return; - } - int index=0; - while(index<pluginList.size()) - { - if(temp==pluginList.at(index).PluginLoaderInterface) - { - pluginList[index].state=state; - pluginList[index].inWaitOfReply=false; - sendState(true); - return; - } - index++; - } - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("listener not found!")); + if(stopIt) + return; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start, state: %1").arg(state)); + PluginInterface_PluginLoader *temp=qobject_cast<PluginInterface_PluginLoader *>(QObject::sender()); + if(temp==NULL) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("listener not located!")); + return; + } + int index=0; + while(index<pluginList.size()) + { + if(temp==pluginList.at(index).pluginLoaderInterface) + { + pluginList[index].state=state; + pluginList[index].inWaitOfReply=false; + sendState(true); + return; + } + index++; + } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("listener not found!")); } |