diff options
Diffstat (limited to 'CopyEngineManager.cpp')
| -rw-r--r-- | CopyEngineManager.cpp | 342 |
1 files changed, 342 insertions, 0 deletions
diff --git a/CopyEngineManager.cpp b/CopyEngineManager.cpp new file mode 100644 index 0000000..758d9b2 --- /dev/null +++ b/CopyEngineManager.cpp @@ -0,0 +1,342 @@ +/** \file CopyEngineManager.cpp +\brief Define the copy engine manager +\author alpha_one_x86 +\version 0.3 +\date 2010 +\licence GPL3, see the file COPYING */ + +#include <QDebug> +#include <QMessageBox> + +#include "CopyEngineManager.h" + +CopyEngineManager::CopyEngineManager(OptionDialog *optionDialog) +{ + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); + this->optionDialog=optionDialog; + //setup the ui layout + plugins->lockPluginListEdition(); + QList<PluginsAvailable> list=plugins->getPluginsByCategory(PluginType_CopyEngine); + foreach(PluginsAvailable currentPlugin,list) + onePluginAdded(currentPlugin); + connect(plugins,SIGNAL(onePluginAdded(PluginsAvailable)), this,SLOT(onePluginAdded(PluginsAvailable))); + connect(plugins,SIGNAL(onePluginWillBeRemoved(PluginsAvailable)), this,SLOT(onePluginWillBeRemoved(PluginsAvailable)),Qt::DirectConnection); + connect(plugins,SIGNAL(pluginListingIsfinish()), this,SLOT(allPluginIsloaded())); + plugins->unlockPluginListEdition(); + //load the options + isConnected=false; + connect(languages, SIGNAL(newLanguageLoaded(QString)), &facilityEngine,SLOT(retranslate())); +} + +void CopyEngineManager::onePluginAdded(const PluginsAvailable &plugin) +{ + if(plugin.category!=PluginType_CopyEngine) + return; + //setFileName + QString pluginPath=plugin.path+PluginsManager::getResolvedPluginName("copyEngine"); + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start: "+pluginPath); + //search into loaded session + int index=0; + while(index<pluginList.size()) + { + if(pluginList.at(index).pluginPath==pluginPath) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("Engine already found!")); + return; + } + index++; + } + CopyEnginePlugin newItem; + newItem.pluginPath=pluginPath; + newItem.path=plugin.path; + newItem.name=plugin.name; + newItem.pointer=new QPluginLoader(newItem.pluginPath); + QObject *pluginObject = newItem.pointer->instance(); + if(pluginObject==NULL) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("unable to load the plugin: %1").arg(newItem.pointer->errorString())); + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("unable to load the plugin for %1").arg(newItem.pluginPath)); + newItem.pointer->unload(); + return; + } + newItem.factory = qobject_cast<PluginInterface_CopyEngineFactory *>(pluginObject); + //check if found + index=0; + while(index<pluginList.size()) + { + if(pluginList.at(index).factory==newItem.factory) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("Plugin already found")); + newItem.pointer->unload(); + return; + } + index++; + } + if(newItem.factory==NULL) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("unable to cast the plugin: %1").arg(newItem.pointer->errorString())); + newItem.pointer->unload(); + return; + } + #ifdef ULTRACOPIER_DEBUG + qRegisterMetaType<DebugLevel>("DebugLevel"); + connect(newItem.factory,SIGNAL(debugInformation(DebugLevel,QString,QString,QString,int)),this,SLOT(debugInformation(DebugLevel,QString,QString,QString,int)),Qt::QueuedConnection); + #endif // ULTRACOPIER_DEBUG + newItem.options=new LocalPluginOptions("CopyEngine-"+newItem.name); + newItem.factory->setResources(newItem.options,plugin.writablePath,plugin.path,&facilityEngine,ULTRACOPIER_VERSION_PORTABLE_BOOL); + newItem.optionsWidget=newItem.factory->options(); + newItem.supportedProtocolsForTheSource=newItem.factory->supportedProtocolsForTheSource(); + newItem.supportedProtocolsForTheDestination=newItem.factory->supportedProtocolsForTheDestination(); + newItem.canDoOnlyCopy=newItem.factory->canDoOnlyCopy(); + newItem.type=newItem.factory->getCopyType(); + newItem.transferListOperation=newItem.factory->getTransferListOperation(); + optionDialog->addCopyEngineWidget(newItem.name,newItem.optionsWidget); + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"plugin: "+newItem.name+" loaded, send options"); + //emit newCopyEngineOptions(plugin.path,newItem.name,newItem.optionsWidget); + pluginList << newItem; + connect(languages,SIGNAL(newLanguageLoaded(QString)),newItem.factory,SLOT(newLanguageLoaded())); + if(plugins->allPluginHaveBeenLoaded()) + allPluginIsloaded(); + if(isConnected) + emit addCopyEngine(newItem.name,newItem.canDoOnlyCopy); +} + +void CopyEngineManager::onePluginWillBeRemoved(const PluginsAvailable &plugin) +{ + int index=0; + while(index<pluginList.size()) + { + if(pluginList.at(index).path==plugin.path) + { + if(pluginList.at(index).intances.size()<=0) + { + emit removeCopyEngine(pluginList.at(index).name); + pluginList.removeAt(index); + allPluginIsloaded(); + return; + } + } + index++; + } +} + +void CopyEngineManager::onePluginWillBeUnloaded(const PluginsAvailable &plugin) +{ + if(plugin.category!=PluginType_CopyEngine) + return; + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); + int index=0; + while(index<pluginList.size()) + { + if(pluginList.at(index).path==plugin.path) + { + optionDialog->removeCopyEngineWidget(pluginList.at(index).name); + delete pluginList.at(index).options; + delete pluginList.at(index).factory; + pluginList.at(index).pointer->unload(); + return; + } + index++; + } +} + +CopyEngineManager::returnCopyEngine CopyEngineManager::getCopyEngine(const CopyMode &mode,const QStringList &protocolsUsedForTheSources,const QString &protocolsUsedForTheDestination) +{ + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start, pluginList.size(): %1, mode: %2, and particular protocol").arg(pluginList.size()).arg((int)mode)); + returnCopyEngine temp; + int index=0; + bool isTheGoodEngine=false; + while(index<pluginList.size()) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("pluginList.at(%1).name: %2").arg(index).arg(pluginList.at(index).name)); + isTheGoodEngine=false; + if(mode!=Move || !pluginList.at(index).canDoOnlyCopy) + { + if(protocolsUsedForTheSources.size()==0) + isTheGoodEngine=true; + else + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("pluginList.at(index).supportedProtocolsForTheDestination: %1").arg(pluginList.at(index).supportedProtocolsForTheDestination.join(";"))); + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("protocolsUsedForTheDestination: %1").arg(protocolsUsedForTheDestination)); + if(pluginList.at(index).supportedProtocolsForTheDestination.contains(protocolsUsedForTheDestination)) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("pluginList.at(index).supportedProtocolsForTheSource: %1").arg(pluginList.at(index).supportedProtocolsForTheSource.join(";"))); + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("protocolsUsedForTheSources.at(indexProto): %1").arg(protocolsUsedForTheSources.join(";"))); + isTheGoodEngine=true; + int indexProto=0; + while(indexProto<protocolsUsedForTheSources.size()) + { + if(!pluginList.at(index).supportedProtocolsForTheSource.contains(protocolsUsedForTheSources.at(indexProto))) + { + isTheGoodEngine=false; + break; + } + indexProto++; + } + } + } + } + if(isTheGoodEngine) + { + pluginList[index].intances<<pluginList[index].factory->getInstance(); + temp.engine=pluginList[index].intances.last(); + temp.canDoOnlyCopy=pluginList.at(index).canDoOnlyCopy; + temp.type=pluginList.at(index).type; + temp.transferListOperation=pluginList.at(index).transferListOperation; + return temp; + } + index++; + } + if(mode==Move) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Cannot find any copy engine with motions support"); + QMessageBox::critical(NULL,tr("Warning"),tr("Cannot find any copy engine with motions support")); + } + else + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Cannot find any compatible engine!"); + QMessageBox::critical(NULL,tr("Warning"),tr("Cannot find any compatible engine!")); + } + temp.engine=NULL; + temp.type=File; + temp.canDoOnlyCopy=true; + return temp; +} + +CopyEngineManager::returnCopyEngine CopyEngineManager::getCopyEngine(const CopyMode &mode,const QString &name) +{ + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start, pluginList.size(): %1, with mode: %2, and name: %3").arg(pluginList.size()).arg((int)mode).arg(name)); + returnCopyEngine temp; + int index=0; + while(index<pluginList.size()) + { + if(pluginList.at(index).name==name) + { + if(mode==Move && pluginList.at(index).canDoOnlyCopy) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"This copy engine does not support motions: pluginList.at(index).canDoOnlyCopy: "+QString::number(pluginList.at(index).canDoOnlyCopy)); + QMessageBox::critical(NULL,tr("Warning"),tr("This copy engine does not support motions")); + temp.engine=NULL; + return temp; + } + pluginList[index].intances<<pluginList[index].factory->getInstance(); + temp.engine=pluginList[index].intances.last(); + temp.canDoOnlyCopy=pluginList.at(index).canDoOnlyCopy; + temp.type=pluginList.at(index).type; + temp.transferListOperation=pluginList.at(index).transferListOperation; + return temp; + } + index++; + } + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Cannot find any engine with this name"); + QMessageBox::critical(NULL,tr("Warning"),tr("Cannot find any engine with this name")); + temp.engine=NULL; + temp.type=File; + temp.canDoOnlyCopy=true; + return temp; +} + +#ifdef ULTRACOPIER_DEBUG +void CopyEngineManager::debugInformation(DebugLevel level,const QString& fonction,const QString& text,const QString& file,const int& ligne) +{ + DebugEngine::addDebugInformationStatic(level,fonction,text,file,ligne,"Copy Engine plugin"); +} +#endif // ULTRACOPIER_DEBUG + +/// \brief To notify when new value into a group have changed +void CopyEngineManager::newOptionValue(const QString &groupName,const QString &variableName,const QVariant &value) +{ + if(groupName=="CopyEngine" && variableName=="List") + { + Q_UNUSED(value) + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Information,"start(\""+groupName+"\",\""+variableName+"\",\""+value.toString()+"\")"); + allPluginIsloaded(); + } +} + +void CopyEngineManager::setIsConnected() +{ + /* ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); + prevent bug, I don't know why, in one case it bug here + */ + isConnected=true; + int index=0; + while(index<pluginList.size()) + { + emit addCopyEngine(pluginList.at(index).name,pluginList.at(index).canDoOnlyCopy); + index++; + } +} + +void CopyEngineManager::allPluginIsloaded() +{ + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); + QStringList actualList; + int index=0; + while(index<pluginList.size()) + { + actualList << pluginList.at(index).name; + index++; + } + QStringList preferedList=options->getOptionValue("CopyEngine","List").toStringList(); + preferedList.removeDuplicates(); + actualList.removeDuplicates(); + index=0; + while(index<preferedList.size()) + { + if(!actualList.contains(preferedList.at(index))) + { + preferedList.removeAt(index); + index--; + } + index++; + } + index=0; + while(index<actualList.size()) + { + if(!preferedList.contains(actualList.at(index))) + preferedList << actualList.at(index); + index++; + } + options->setOptionValue("CopyEngine","List",preferedList); + QList<CopyEnginePlugin> newPluginList; + index=0; + while(index<preferedList.size()) + { + int pluginListIndex=0; + while(pluginListIndex<pluginList.size()) + { + if(preferedList.at(index)==pluginList.at(pluginListIndex).name) + { + newPluginList << pluginList.at(pluginListIndex); + break; + } + pluginListIndex++; + } + index++; + } + pluginList=newPluginList; +} + +bool CopyEngineManager::protocolsSupportedByTheCopyEngine(PluginInterface_CopyEngine * engine,const QStringList &protocolsUsedForTheSources,const QString &protocolsUsedForTheDestination) +{ + int index=0; + while(index<pluginList.size()) + { + ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("pluginList.at(%1).name: %2").arg(index).arg(pluginList.at(index).name)); + if(pluginList.at(index).intances.contains(engine)) + { + if(!pluginList.at(index).supportedProtocolsForTheDestination.contains(protocolsUsedForTheDestination)) + return false; + int indexProto=0; + while(indexProto<protocolsUsedForTheSources.size()) + { + if(!pluginList.at(index).supportedProtocolsForTheSource.contains(protocolsUsedForTheSources.at(indexProto))) + return false; + indexProto++; + } + return true; + } + } + return false; +} |