diff options
| author | Thomas Preud'homme <robotux@celest.fr> | 2017-11-24 23:24:09 +0000 |
|---|---|---|
| committer | Thomas Preud'homme <robotux@celest.fr> | 2017-11-24 23:24:09 +0000 |
| commit | b3c8bdcc0d1e4b2ab298847a7902b6d60410a5bc (patch) | |
| tree | 8fce8a51adfb245db8ab2a76831661780c0c713e /Core.cpp | |
| parent | e297dbd8052ef4e66f069e2dd1865ae7fa8af28e (diff) | |
New upstream version 1.2.3.6
Diffstat (limited to 'Core.cpp')
| -rw-r--r--[-rwxr-xr-x] | Core.cpp | 1790 |
1 files changed, 985 insertions, 805 deletions
@@ -1,304 +1,284 @@ /** \file Core.cpp \brief Define the class for the core \author alpha_one_x86 -\version 0.3 -\date 2010 \licence GPL3, see the file COPYING */ #include <QMessageBox> #include <QtPlugin> +#include <cmath> #include "Core.h" +#include "ThemesManager.h" Core::Core(CopyEngineManager *copyEngineList) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - this->copyEngineList=copyEngineList; - nextId=0; - forUpateInformation.setInterval(ULTRACOPIER_TIME_INTERFACE_UPDATE); - loadInterface(); - //connect(©EngineList, SIGNAL(newCanDoOnlyCopy(bool)), this, SIGNAL(newCanDoOnlyCopy(bool))); - connect(themes, SIGNAL(theThemeNeedBeUnloaded()), this, SLOT(unloadInterface())); - connect(themes, SIGNAL(theThemeIsReloaded()), this, SLOT(loadInterface())); - connect(&forUpateInformation, SIGNAL(timeout()), this, SLOT(periodicSynchronization())); - - qRegisterMetaType<QList<returnActionOnCopyList> >("QList<returnActionOnCopyList>"); - qRegisterMetaType<QList<ProgressionItem> >("QList<ProgressionItem>"); - qRegisterMetaType<QList<int> >("QList<int>"); - qRegisterMetaType<QList<QUrl> >("QList<QUrl>"); - qRegisterMetaType<EngineActionInProgress>("EngineActionInProgress"); - qRegisterMetaType<CopyMode >("CopyMode"); - qRegisterMetaType<QList<returnActionOnCopyList> >("QList<returnActionOnCopyList>"); - qRegisterMetaType<QList<ProgressionItem> >("QList<ProgressionItem>"); -} - -void Core::newCopy(const quint32 &orderId,const QStringList &protocolsUsedForTheSources,const QStringList &sources) -{ - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - if(openNewCopyEngineInstance(Copy,false,protocolsUsedForTheSources)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - copyList.last().orderId<<orderId; - copyList.last().engine->newCopy(sources); - copyList.last().interface->haveExternalOrder(); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + this->copyEngineList=copyEngineList; + nextId=0; + forUpateInformation.setInterval(ULTRACOPIER_TIME_INTERFACE_UPDATE); + loadInterface(); + //connect(©EngineList, &CopyEngineManager::newCanDoOnlyCopy, this, &Core::newCanDoOnlyCopy); + connect(ThemesManager::themesManager, &ThemesManager::theThemeNeedBeUnloaded, this, &Core::unloadInterface); + connect(ThemesManager::themesManager, &ThemesManager::theThemeIsReloaded, this, &Core::loadInterface, Qt::QueuedConnection); + connect(&forUpateInformation, &QTimer::timeout, this, &Core::periodicSynchronization); +} + +Core::~Core() +{ + int index=0; + while(index<copyList.size()) + { + copyList[index].engine->cancel(); + delete copyList.at(index).nextConditionalSync; + delete copyList.at(index).interface; + delete copyList.at(index).engine; + index++; + } +} + +void Core::newCopyWithoutDestination(const quint32 &orderId,const QStringList &protocolsUsedForTheSources,const QStringList &sources) +{ + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + if(openNewCopyEngineInstance(Ultracopier::Copy,false,protocolsUsedForTheSources)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to get a copy engine instance"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); + return; + } + copyList.last().orderId<<orderId; + copyList.last().engine->newCopy(sources); + copyList.last().interface->haveExternalOrder(); +} + +void Core::newTransfer(const Ultracopier::CopyMode &mode,const quint32 &orderId,const QStringList &protocolsUsedForTheSources,const QStringList &sources,const QString &protocolsUsedForTheDestination,const QString &destination) +{ + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start: ")+sources.join(QStringLiteral(";"))+QStringLiteral(", dest: ")+destination+QStringLiteral(", mode: ")+QString::number(mode)); + //search to group the window + int GroupWindowWhen=OptionEngine::optionEngine->getOptionValue(QStringLiteral("Ultracopier"),QStringLiteral("GroupWindowWhen")).toInt(); + bool haveSameSource=false,haveSameDestination=false; + if(GroupWindowWhen!=0) + { + bool needConfirmation=OptionEngine::optionEngine->getOptionValue(QStringLiteral("Ultracopier"),QStringLiteral("confirmToGroupWindows")).toInt(); + int index=0; + while(index<copyList.size()) + { + bool rightMode=false; + if(mode==Ultracopier::Copy) + rightMode=copyList.at(index).mode==Ultracopier::Copy; + else + rightMode=copyList.at(index).mode==Ultracopier::Move; + if(!copyList.at(index).ignoreMode && rightMode && !copyList.at(index).canceled) + { + if(GroupWindowWhen!=5) + { + if(GroupWindowWhen!=2) + haveSameSource=copyList.at(index).engine->haveSameSource(sources); + if(GroupWindowWhen!=1) + haveSameDestination=copyList.at(index).engine->haveSameDestination(destination); + } + if( + GroupWindowWhen==5 || + (GroupWindowWhen==1 && haveSameSource) || + (GroupWindowWhen==2 && haveSameDestination) || + (GroupWindowWhen==3 && (haveSameSource && haveSameDestination)) || + (GroupWindowWhen==4 && (haveSameSource || haveSameDestination)) + ) + { + /*protocols are same*/ + if(copyEngineList->protocolsSupportedByTheCopyEngine(copyList.at(index).engine,protocolsUsedForTheSources,protocolsUsedForTheDestination)) + { + bool confirmed=true; + if(needConfirmation) + { + QMessageBox::StandardButton reply = QMessageBox::question(copyList.at(index).interface,tr("Group window"),tr("Do you want group the transfer with another actual running transfer?"),QMessageBox::Yes|QMessageBox::No,QMessageBox::No); + confirmed=(reply==QMessageBox::Yes); + } + if(confirmed) + { + copyList[index].orderId<<orderId; + if(mode==Ultracopier::Copy) + copyList.at(index).engine->newCopy(sources,destination); + else + copyList.at(index).engine->newMove(sources,destination); + copyList.at(index).interface->haveExternalOrder(); + return; + } + } + } + } + index++; + } + } + //else open new windows + if(openNewCopyEngineInstance(mode,false,protocolsUsedForTheSources,protocolsUsedForTheDestination)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QStringLiteral("Unable to get a engine instance")); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a engine instance")); + return; + } + copyList.last().orderId<<orderId; + if(mode==Ultracopier::Copy) + copyList.last().engine->newCopy(sources,destination); + else + copyList.last().engine->newMove(sources,destination); + copyList.last().interface->haveExternalOrder(); } void Core::newCopy(const quint32 &orderId,const QStringList &protocolsUsedForTheSources,const QStringList &sources,const QString &protocolsUsedForTheDestination,const QString &destination) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start: "+sources.join(";")+", dest: "+destination); - //search to group the window - int GroupWindowWhen=options->getOptionValue("Ultracopier","GroupWindowWhen").toInt(); - bool haveSameSource=false,haveSameDestination=false; - if(GroupWindowWhen!=0) - { - int index=0; - while(index<copyList.size()) - { - if(!copyList.at(index).ignoreMode && copyList.at(index).mode==Copy) - { - if(GroupWindowWhen!=5) - { - if(GroupWindowWhen!=2) - haveSameSource=copyList.at(index).engine->haveSameSource(sources); - if(GroupWindowWhen!=1) - haveSameDestination=copyList.at(index).engine->haveSameDestination(destination); - } - if( - GroupWindowWhen==5 || - (GroupWindowWhen==1 && haveSameSource) || - (GroupWindowWhen==2 && haveSameDestination) || - (GroupWindowWhen==3 && (haveSameSource && haveSameDestination)) || - (GroupWindowWhen==4 && (haveSameSource || haveSameDestination)) - ) - { - /*protocols are same*/ - if(copyEngineList->protocolsSupportedByTheCopyEngine(copyList.at(index).engine,protocolsUsedForTheSources,protocolsUsedForTheDestination)) - { - copyList[index].orderId<<orderId; - copyList.at(index).engine->newCopy(sources,destination); - copyList.at(index).interface->haveExternalOrder(); - return; - } - } - } - index++; - } - } - //else open new windows - if(openNewCopyEngineInstance(Copy,false,protocolsUsedForTheSources,protocolsUsedForTheDestination)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - copyList.last().orderId<<orderId; - copyList.last().engine->newCopy(sources,destination); - copyList.last().interface->haveExternalOrder(); -} - -void Core::newMove(const quint32 &orderId,const QStringList &protocolsUsedForTheSources,const QStringList &sources) -{ - if(openNewCopyEngineInstance(Move,false,protocolsUsedForTheSources)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - copyList.last().orderId<<orderId; - copyList.last().engine->newMove(sources); - copyList.last().interface->haveExternalOrder(); + newTransfer(Ultracopier::Copy,orderId,protocolsUsedForTheSources,sources,protocolsUsedForTheDestination,destination); } void Core::newMove(const quint32 &orderId,const QStringList &protocolsUsedForTheSources,const QStringList &sources,const QString &protocolsUsedForTheDestination,const QString &destination) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start: "+sources.join(";")+", dest: "+destination); - //search to group the window - int GroupWindowWhen=options->getOptionValue("Ultracopier","GroupWindowWhen").toInt(); - bool haveSameSource=false,haveSameDestination=false; - if(GroupWindowWhen!=0) - { - int index=0; - while(index<copyList.size()) - { - if(!copyList.at(index).ignoreMode && copyList.at(index).mode==Move) - { - if(GroupWindowWhen!=5) - { - if(GroupWindowWhen!=2) - haveSameSource=copyList.at(index).engine->haveSameSource(sources); - if(GroupWindowWhen!=1) - haveSameDestination=copyList.at(index).engine->haveSameDestination(destination); - } - if( - GroupWindowWhen==5 || - (GroupWindowWhen==1 && haveSameSource) || - (GroupWindowWhen==2 && haveSameDestination) || - (GroupWindowWhen==3 && (haveSameSource && haveSameDestination)) || - (GroupWindowWhen==4 && (haveSameSource || haveSameDestination)) - ) - { - /*protocols are same*/ - if(copyEngineList->protocolsSupportedByTheCopyEngine(copyList.at(index).engine,protocolsUsedForTheSources,protocolsUsedForTheDestination)) - { - copyList[index].orderId<<orderId; - copyList.at(index).engine->newCopy(sources,destination); - copyList.at(index).interface->haveExternalOrder(); - return; - } - } - } - index++; - } - } - //else open new windows - if(openNewCopyEngineInstance(Move,false,protocolsUsedForTheSources,protocolsUsedForTheDestination)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - copyList.last().orderId<<orderId; - copyList.last().engine->newMove(sources,destination); - copyList.last().interface->haveExternalOrder(); + newTransfer(Ultracopier::Move,orderId,protocolsUsedForTheSources,sources,protocolsUsedForTheDestination,destination); +} + +void Core::newMoveWithoutDestination(const quint32 &orderId,const QStringList &protocolsUsedForTheSources,const QStringList &sources) +{ + if(openNewCopyEngineInstance(Ultracopier::Move,false,protocolsUsedForTheSources)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to get a copy engine instance"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); + return; + } + copyList.last().orderId<<orderId; + copyList.last().engine->newMove(sources); + copyList.last().interface->haveExternalOrder(); } /// \brief name to open the right copy engine -void Core::addWindowCopyMove(const CopyMode &mode,const QString &name) -{ - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start: "+name); - if(openNewCopyEngineInstance(mode,false,name)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - ActionOnManualOpen ActionOnManualOpen_value=(ActionOnManualOpen)options->getOptionValue("Ultracopier","ActionOnManualOpen").toInt(); - if(ActionOnManualOpen_value!=ActionOnManualOpen_Nothing) - { - if(ActionOnManualOpen_value==ActionOnManualOpen_Folder) - copyList.last().engine->userAddFolder(mode); - else - copyList.last().engine->userAddFile(mode); - } +void Core::addWindowCopyMove(const Ultracopier::CopyMode &mode,const QString &name) +{ + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start: ")+name); + if(openNewCopyEngineInstance(mode,false,name)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to get a copy engine instance"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); + return; + } + ActionOnManualOpen ActionOnManualOpen_value=(ActionOnManualOpen)OptionEngine::optionEngine->getOptionValue(QStringLiteral("Ultracopier"),QStringLiteral("ActionOnManualOpen")).toInt(); + if(ActionOnManualOpen_value!=ActionOnManualOpen_Nothing) + { + if(ActionOnManualOpen_value==ActionOnManualOpen_Folder) + copyList.last().engine->userAddFolder(mode); + else + copyList.last().engine->userAddFile(mode); + } } /// \brief name to open the right copy engine void Core::addWindowTransfer(const QString &name) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"+name); - if(openNewCopyEngineInstance(Copy,true,name)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")+name); + if(openNewCopyEngineInstance(Ultracopier::Copy,true,name)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to get a copy engine instance"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); + return; + } } /** new transfer list pased by the CLI */ void Core::newTransferList(QString engine,QString mode,QString file) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("engine: %1, mode: %2, file: %3").arg(engine).arg(mode).arg(file)); - if(mode=="Transfer") - { - if(openNewCopyEngineInstance(Copy,true,engine)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - } - else if(mode=="Copy") - { - if(openNewCopyEngineInstance(Copy,false,engine)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - } - else if(mode=="Move") - { - if(openNewCopyEngineInstance(Move,false,engine)==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to get a copy engine instance"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); - return; - } - } - else - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"The argument for the mode is not understand"); - QMessageBox::critical(NULL,tr("Error"),tr("The argument for the mode is not understand")); - return; - } - copyList.last().engine->newTransferList(file); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("engine: %1, mode: %2, file: %3").arg(engine).arg(mode).arg(file)); + if(mode==QStringLiteral("Transfer")) + { + if(openNewCopyEngineInstance(Ultracopier::Copy,true,engine)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to get a copy engine instance"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); + return; + } + } + else if(mode==QStringLiteral("Copy")) + { + if(openNewCopyEngineInstance(Ultracopier::Copy,false,engine)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to get a copy engine instance"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); + return; + } + } + else if(mode==QStringLiteral("Move")) + { + if(openNewCopyEngineInstance(Ultracopier::Move,false,engine)==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to get a copy engine instance"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to get a copy engine instance")); + return; + } + } + else + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"The argument for the mode is not valid"); + QMessageBox::critical(NULL,tr("Error"),tr("The argument for the mode is not valid")); + return; + } + copyList.last().engine->newTransferList(file); } void Core::loadInterface() { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - //load the extra files to check the themes availability - if(copyList.size()>0) - { - bool error=false; - index=0; - loop_size=copyList.size(); - while(index<loop_size) - { - copyList[index].interface=themes->getThemesInstance(); - if(copyList[index].interface==NULL) - { - copyInstanceCanceledByIndex(index); - index--; - error=true; - } - else - { - if(!copyList.at(index).ignoreMode) - copyList.at(index).interface->forceCopyMode(copyList.at(index).mode); - connectInterfaceAndSync(copyList.count()-1); - copyList.at(index).engine->syncTransferList(); - } - index++; - } - if(error) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to load the interface, copy aborted"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to load the interface, copy aborted")); - } - } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + //load the extra files to check the themes availability + if(copyList.size()>0) + { + bool error=false; + int index=0; + while(index<copyList.size()) + { + copyList[index].interface=ThemesManager::themesManager->getThemesInstance(); + if(copyList.at(index).interface==NULL) + { + copyInstanceCanceledByIndex(index); + error=true; + } + else + { + if(!copyList.at(index).ignoreMode) + copyList.at(index).interface->forceCopyMode(copyList.at(index).mode); + connectInterfaceAndSync(copyList.count()-1); + copyList.at(index).engine->syncTransferList(); + index++; + } + } + if(error) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to load the interface, copy aborted"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to load the interface, copy aborted")); + } + } } void Core::unloadInterface() { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - index=0; - loop_size=copyList.size(); - while(index<loop_size) - { - if(copyList.at(index).interface!=NULL) - { - disconnectInterface(index); - delete copyList.at(index).interface; - copyList[index].interface=NULL; - copyList[index].copyEngineIsSync=false; - } - index++; - } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + int index=0; + const int &loop_size=copyList.size(); + while(index<loop_size) + { + if(copyList.at(index).interface!=NULL) + { + //disconnectInterface(index); + delete copyList.at(index).interface; + copyList[index].interface=NULL; + copyList[index].copyEngineIsSync=false; + } + index++; + } } int Core::incrementId() { - do - { - nextId++; - if(nextId>2000000) - nextId=0; - } while(idList.contains(nextId)); - return nextId; + do + { + nextId++; + if(nextId>2000000) + nextId=0; + } while(idList.contains(nextId)); + return nextId; } /** open with specific source/destination @@ -307,13 +287,13 @@ int Core::incrementId() \param protocolsUsedForTheSources protocols used for sources \param protocolsUsedForTheDestination protocols used for destination */ -int Core::openNewCopyEngineInstance(const CopyMode &mode,const bool &ignoreMode,const QStringList &protocolsUsedForTheSources,const QString &protocolsUsedForTheDestination) +int Core::openNewCopyEngineInstance(const Ultracopier::CopyMode &mode,const bool &ignoreMode,const QStringList &protocolsUsedForTheSources,const QString &protocolsUsedForTheDestination) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - CopyEngineManager::returnCopyEngine returnInformations=copyEngineList->getCopyEngine(mode,protocolsUsedForTheSources,protocolsUsedForTheDestination); - if(returnInformations.engine==NULL) - return -1; - return connectCopyEngine(mode,ignoreMode,returnInformations); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + CopyEngineManager::returnCopyEngine returnInformations=copyEngineList->getCopyEngine(mode,protocolsUsedForTheSources,protocolsUsedForTheDestination); + if(returnInformations.engine==NULL) + return -1; + return connectCopyEngine(mode,ignoreMode,returnInformations); } /** open with specific copy engine @@ -322,649 +302,849 @@ int Core::openNewCopyEngineInstance(const CopyMode &mode,const bool &ignoreMode, \param protocolsUsedForTheSources protocols used for sources \param protocolsUsedForTheDestination protocols used for destination */ -int Core::openNewCopyEngineInstance(const CopyMode &mode,const bool &ignoreMode,const QString &name) +int Core::openNewCopyEngineInstance(const Ultracopier::CopyMode &mode,const bool &ignoreMode,const QString &name) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start, mode: "+QString::number(mode)+", name: "+name); - CopyEngineManager::returnCopyEngine returnInformations=copyEngineList->getCopyEngine(mode,name); - if(returnInformations.engine==NULL) - return -1; - return connectCopyEngine(mode,ignoreMode,returnInformations); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,"start, mode: "+QString::number(mode)+", name: "+name); + CopyEngineManager::returnCopyEngine returnInformations=copyEngineList->getCopyEngine(mode,name); + if(returnInformations.engine==NULL) + return -1; + return connectCopyEngine(mode,ignoreMode,returnInformations); } /** Connect the copy engine instance provided previously to the management */ -int Core::connectCopyEngine(const CopyMode &mode,bool ignoreMode,const CopyEngineManager::returnCopyEngine &returnInformations) -{ - if(returnInformations.canDoOnlyCopy) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Mode force for unknow reason"); - ignoreMode=false;//force mode if need, normaly not used - } - CopyInstance newItem; - newItem.engine=returnInformations.engine; - if(newItem.engine!=NULL) - { - PluginInterface_Themes *theme=themes->getThemesInstance(); - if(theme!=NULL) - { - newItem.id=incrementId(); - newItem.lastProgression=0; - newItem.interface=theme; - newItem.ignoreMode=ignoreMode; - newItem.mode=mode; - newItem.type=returnInformations.type; - newItem.transferListOperation=returnInformations.transferListOperation; - newItem.baseTime=0; - newItem.numberOfFile=0; - newItem.numberOfTransferedFile=0; - newItem.currentProgression=0; - newItem.totalProgression=0; - newItem.action=Idle; - newItem.lastProgression=0;//store the real byte transfered, used in time remaining calculation - newItem.isPaused=false; - newItem.baseTime=0;//stored in ms - newItem.isRunning=false; - newItem.haveError=false; - newItem.lastConditionalSync.start(); - newItem.nextConditionalSync=new QTimer(); - newItem.nextConditionalSync->setSingleShot(true); - newItem.copyEngineIsSync=true; - - if(!ignoreMode) - { - newItem.interface->forceCopyMode(mode); - newItem.engine->forceMode(mode); - } - if(copyList.size()==0) - forUpateInformation.start(); - copyList << newItem; - connectEngine(copyList.count()-1); - connectInterfaceAndSync(copyList.count()-1); - return newItem.id; - } - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to load the interface, copy aborted"); - delete newItem.engine; - QMessageBox::critical(NULL,tr("Error"),tr("Unable to load the interface, copy aborted")); - } - else - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to load the copy engine, copy aborted"); - QMessageBox::critical(NULL,tr("Error"),tr("Unable to load the copy engine, copy aborted")); - } - return -1; +int Core::connectCopyEngine(const Ultracopier::CopyMode &mode,bool ignoreMode,const CopyEngineManager::returnCopyEngine &returnInformations) +{ + if(returnInformations.canDoOnlyCopy) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Mode force for unknow reason"); + ignoreMode=false;//force mode if need, normaly not used + } + CopyInstance newItem; + newItem.engine=returnInformations.engine; + if(newItem.engine!=NULL) + { + PluginInterface_Themes *theme=ThemesManager::themesManager->getThemesInstance(); + if(theme!=NULL) + { + newItem.id=incrementId(); + newItem.lastProgression=0; + newItem.interface=theme; + newItem.ignoreMode=ignoreMode; + newItem.mode=mode; + newItem.type=returnInformations.type; + newItem.transferListOperation=returnInformations.transferListOperation; + newItem.numberOfFile=0; + newItem.numberOfTransferedFile=0; + newItem.currentProgression=0; + newItem.totalProgression=0; + newItem.action=Ultracopier::Idle; + newItem.lastProgression=0;//store the real byte transfered, used in time remaining calculation + newItem.isPaused=false; + newItem.isRunning=false; + newItem.haveError=false; + newItem.lastConditionalSync.start(); + newItem.nextConditionalSync=new QTimer(); + newItem.nextConditionalSync->setSingleShot(true); + newItem.copyEngineIsSync=true; + newItem.canceled=false; + + switch(OptionEngine::optionEngine->getOptionValue(QStringLiteral("Ultracopier"),QStringLiteral("remainingTimeAlgorithm")).toUInt()) + { + default: + case 0: + newItem.remainingTimeAlgo=Ultracopier::RemainingTimeAlgo_Traditional; + break; + case 1: + newItem.remainingTimeAlgo=Ultracopier::RemainingTimeAlgo_Logarithmic; + { + int index=0; + while(index<ULTRACOPIER_MAXREMAININGTIMECOL) + { + RemainingTimeLogarithmicColumn remainingTimeLogarithmicColumn; + remainingTimeLogarithmicColumn.totalSize=0; + remainingTimeLogarithmicColumn.transferedSize=0; + newItem.remainingTimeLogarithmicValue << remainingTimeLogarithmicColumn; + index++; + } + } + break; + } + + if(!ignoreMode) + { + newItem.interface->forceCopyMode(mode); + newItem.engine->forceMode(mode); + } + if(copyList.size()==0) + forUpateInformation.start(); + copyList << newItem; + connectEngine(copyList.count()-1); + connectInterfaceAndSync(copyList.count()-1); + return newItem.id; + } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to load the interface, copy aborted"); + delete newItem.engine; + QMessageBox::critical(NULL,tr("Error"),tr("Unable to load the interface, copy aborted")); + } + else + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to load the copy engine, copy aborted"); + QMessageBox::critical(NULL,tr("Error"),tr("Unable to load the copy engine, copy aborted")); + } + return -1; } void Core::resetSpeedDetectedEngine() { - int index=indexCopySenderCopyEngine(); - if(index!=-1) - resetSpeedDetected(index); + int index=indexCopySenderCopyEngine(); + if(index!=-1) + resetSpeedDetected(index); } void Core::resetSpeedDetectedInterface() { - int index=indexCopySenderInterface(); - if(index!=-1) - resetSpeedDetected(index); + int index=indexCopySenderInterface(); + if(index!=-1) + resetSpeedDetected(index); } void Core::resetSpeedDetected(const int &index) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start on %1").arg(index)); - copyList[index].runningTime.restart(); - copyList[index].lastSpeedDetected.clear(); - copyList[index].lastSpeedTime.clear(); -} - -void Core::actionInProgess(const EngineActionInProgress &action) -{ - index=indexCopySenderCopyEngine(); - if(index!=-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("action: %1, from %2").arg(action).arg(index)); - //drop here the duplicate action - if(copyList[index].action==action) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("The copy engine have send 2x the same EngineActionInProgress")); - return; - } - //update time runing for time remaning caculation - if(action==Copying || action==CopyingAndListing) - { - if(!copyList.at(index).isRunning) - { - copyList[index].isRunning=true; - copyList[index].runningTime.restart(); - } - } - else - { - if(copyList.at(index).isRunning) - { - copyList[index].isRunning=false; - copyList[index].baseTime+=copyList[index].runningTime.elapsed(); - } - } - //do sync - periodicSynchronization(index); - copyList[index].action=action; - if(copyList.at(index).interface!=NULL) - copyList.at(index).interface->actionInProgess(action); - if(action==Idle) - { - index_sub_loop=0; - loop_size=copyList.at(index).orderId.size(); - while(index_sub_loop<loop_size) - { - emit copyCanceled(copyList.at(index).orderId.at(index_sub_loop)); - index_sub_loop++; - } - copyList[index].orderId.clear(); - resetSpeedDetected(index); - } - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the interface sender"); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start on %1").arg(index)); + switch(copyList.at(index).remainingTimeAlgo) + { + case Ultracopier::RemainingTimeAlgo_Logarithmic: + { + int sub_index=0; + while(sub_index<ULTRACOPIER_MAXREMAININGTIMECOL) + { + copyList[index].remainingTimeLogarithmicValue[sub_index].lastProgressionSpeed.clear(); + copyList[index].remainingTimeLogarithmicValue[sub_index].totalSize=0; + copyList[index].remainingTimeLogarithmicValue[sub_index].transferedSize=0; + sub_index++; + } + } + default: + case Ultracopier::RemainingTimeAlgo_Traditional: + copyList[index].lastSpeedDetected.clear(); + copyList[index].lastSpeedTime.clear(); + copyList[index].lastAverageSpeedDetected.clear(); + copyList[index].lastAverageSpeedTime.clear(); + break; + } } -void Core::newFolderListing(const QString &path) +void Core::doneTime(const QList<QPair<quint64,quint32> > &timeList) { - int index=indexCopySenderCopyEngine(); - if(index!=-1) - { - copyList[index].folderListing=path; - copyList.at(index).interface->newFolderListing(path); - } + int index=indexCopySenderCopyEngine(); + if(index!=-1) + { + switch(copyList.at(index).remainingTimeAlgo) + { + case Ultracopier::RemainingTimeAlgo_Logarithmic: + if(copyList.at(index).remainingTimeLogarithmicValue.size()<ULTRACOPIER_MAXREMAININGTIMECOL) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("bug, copyList.at(index).remainingTimeLogarithmicValue.size() %1 <ULTRACOPIER_MAXREMAININGTIMECOL").arg(copyList.at(index).remainingTimeLogarithmicValue.size())); + else + { + int size=timeList.size(); + int sub_index=0; + while(sub_index<size) + { + const QPair<quint64,quint32> &timeUnit=timeList.at(sub_index); + const quint8 &col=fileCatNumber(timeUnit.first); + if(copyList.at(index).remainingTimeLogarithmicValue.size()<=col) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("bug, copyList.at(index).remainingTimeLogarithmicValue.size() %1 < col %2").arg(copyList.at(index).remainingTimeLogarithmicValue.size()).arg(col)); + break; + } + else + { + if(timeUnit.second>0) + { + copyList[index].remainingTimeLogarithmicValue[col].lastProgressionSpeed << timeUnit.first/timeUnit.second; + if(copyList[index].remainingTimeLogarithmicValue[col].lastProgressionSpeed.size()>ULTRACOPIER_MAXVALUESPEEDSTORED) + copyList[index].remainingTimeLogarithmicValue[col].lastProgressionSpeed.removeFirst(); + } + } + sub_index++; + } + } + default: + case Ultracopier::RemainingTimeAlgo_Traditional: + break; + } + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the interface sender"); } -void Core::newCollisionAction(const QString &action) +void Core::actionInProgess(const Ultracopier::EngineActionInProgress &action) { - int index=indexCopySenderCopyEngine(); - if(index!=-1) - { - copyList[index].collisionAction=action; - copyList.at(index).interface->newCollisionAction(action); - } + int index=indexCopySenderCopyEngine(); + if(index!=-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("action: %1, from %2").arg(action).arg(index)); + //drop here the duplicate action + if(copyList.at(index).action==action) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("The copy engine have send 2x the same EngineActionInProgress")); + return; + } + //update time runing for time remaning caculation + if(action==Ultracopier::Copying || action==Ultracopier::CopyingAndListing) + { + if(!copyList.at(index).isRunning) + copyList[index].isRunning=true; + } + else + { + if(copyList.at(index).isRunning) + copyList[index].isRunning=false; + } + //do sync + periodicSynchronizationWithIndex(index); + copyList[index].action=action; + if(copyList.at(index).interface!=NULL) + copyList.at(index).interface->actionInProgess(action); + if(action==Ultracopier::Idle) + { + int index_sub_loop=0; + const int &loop_size=copyList.at(index).orderId.size(); + while(index_sub_loop<loop_size) + { + emit copyCanceled(copyList.at(index).orderId.at(index_sub_loop)); + index_sub_loop++; + } + copyList[index].orderId.clear(); + resetSpeedDetected(index); + } + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the interface sender"); } -void Core::newErrorAction(const QString &action) +void Core::newFolderListing(const QString &path) { - int index=indexCopySenderCopyEngine(); - if(index!=-1) - { - copyList[index].errorAction=action; - copyList.at(index).interface->newErrorAction(action); - } + int index=indexCopySenderCopyEngine(); + if(index!=-1) + { + copyList[index].folderListing=path; + copyList.at(index).interface->newFolderListing(path); + } } void Core::isInPause(const bool &isPaused) { - int index=indexCopySenderCopyEngine(); - if(index!=-1) - { - if(!isPaused) - resetSpeedDetected(index); - copyList[index].isPaused=isPaused; - copyList.at(index).interface->isInPause(isPaused); - } + int index=indexCopySenderCopyEngine(); + if(index!=-1) + { + if(!isPaused) + resetSpeedDetected(index); + copyList[index].isPaused=isPaused; + copyList.at(index).interface->isInPause(isPaused); + } } /// \brief get the right copy instance (copy engine + interface), by signal emited from copy engine int Core::indexCopySenderCopyEngine() { - QObject * senderObject=sender(); - if(senderObject==NULL) - { - //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Qt sender() NULL"); - return -1; - } - index=0; - loop_size=copyList.size(); - while(index<loop_size) - { - if(copyList.at(index).engine==senderObject) - return index; - index++; - } - //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Sender not located in the list"); - return -1; + const QObject * senderObject=sender(); + if(senderObject==NULL) + { + //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Qt sender() NULL"); + return -1; + } + int index=0; + const int &loop_size=copyList.size(); + while(index<loop_size) + { + if(copyList.at(index).engine==senderObject) + return index; + index++; + } + //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Sender not located in the list"); + return -1; } /// \brief get the right copy instance (copy engine + interface), by signal emited from interface int Core::indexCopySenderInterface() { - QObject * senderObject=sender(); - if(senderObject==NULL) - { - //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Qt sender() NULL"); - return -1; - } - index=0; - loop_size=copyList.size(); - while(index<loop_size) - { - if(copyList.at(index).interface==senderObject) - return index; - index++; - } - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Unable to locate QObject * sender"); - PluginInterface_Themes * interface = qobject_cast<PluginInterface_Themes *>(senderObject); - if(interface==NULL) - { - //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Qt sender themes NULL"); - return -1; - } - index=0; - while(index<loop_size) - { - if(copyList.at(index).interface==interface) - return index; - index++; - } - //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Sender not located in the list"); - return -1; + QObject * senderObject=sender(); + if(senderObject==NULL) + { + //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Qt sender() NULL"); + return -1; + } + int index=0; + const int &loop_size=copyList.size(); + while(index<loop_size) + { + if(copyList.at(index).interface==senderObject) + return index; + index++; + } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Unable to locate QObject * sender"); + PluginInterface_Themes * interface = qobject_cast<PluginInterface_Themes *>(senderObject); + if(interface==NULL) + { + //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Qt sender themes NULL"); + return -1; + } + index=0; + while(index<loop_size) + { + if(copyList.at(index).interface==interface) + return index; + index++; + } + //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Sender not located in the list"); + return -1; } void Core::connectEngine(const int &index) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start with index: %1: %2").arg(index).arg((quint64)sender())); - disconnectEngine(index); - - CopyInstance& currentCopyInstance=copyList[index]; - if(!connect(currentCopyInstance.engine,SIGNAL(newFolderListing(QString)), this,SLOT(newFolderListing(QString)),Qt::QueuedConnection))//to check to change - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for newFolderListing()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(newCollisionAction(QString)), this,SLOT(newCollisionAction(QString)),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for newCollisionAction()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(newErrorAction(QString)), this,SLOT(newErrorAction(QString)),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for newErrorAction()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(actionInProgess(EngineActionInProgress)), this,SLOT(actionInProgess(EngineActionInProgress)),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for actionInProgess()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(isInPause(bool)), this,SLOT(isInPause(bool)),Qt::QueuedConnection))//to check to change - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for isInPause()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(cancelAll()), this,SLOT(copyInstanceCanceledByEngine()),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for cancelAll()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(error(QString,quint64,QDateTime,QString)), this,SLOT(error(QString,quint64,QDateTime,QString)),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for error()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(rmPath(QString)), this,SLOT(rmPath(QString)),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for rmPath()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(mkPath(QString)), this,SLOT(mkPath(QString)),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for mkPath()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(syncReady()), this,SLOT(syncReady()),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for syncReady()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(canBeDeleted()), this,SLOT(deleteCopyEngine()),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the engine can not work correctly: %1: %2 for syncReady()").arg(index).arg((quint64)sender())); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start with index: %1: %2").arg(index).arg((quint64)sender())); + //disconnectEngine(index); + + CopyInstance& currentCopyInstance=copyList[index]; + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::newFolderListing, this,&Core::newFolderListing,Qt::QueuedConnection))//to check to change + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for newFolderListing()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::actionInProgess, this,&Core::actionInProgess,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for actionInProgess()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::isInPause, this,&Core::isInPause,Qt::QueuedConnection))//to check to change + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for isInPause()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::cancelAll, this,&Core::copyInstanceCanceledByEngine,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for cancelAll()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::error, this,&Core::error,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for error()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::rmPath, this,&Core::rmPath,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for rmPath()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::mkPath, this,&Core::mkPath,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for mkPath()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::syncReady, this,&Core::syncReady,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for syncReady()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::canBeDeleted, this,&Core::deleteCopyEngine,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for syncReady()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::doneTime, this,&Core::doneTime,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the engine can not work correctly: %1: %2 for doneTime()").arg(index).arg((quint64)sender())); } void Core::connectInterfaceAndSync(const int &index) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start with index: %1: %2").arg(index).arg((quint64)sender())); - disconnectInterface(index); - - CopyInstance& currentCopyInstance=copyList[index]; - if(!connect(currentCopyInstance.interface,SIGNAL(pause()), currentCopyInstance.engine,SLOT(pause()))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for pause()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(resume()), currentCopyInstance.engine,SLOT(resume()))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for resume()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(skip(quint64)), currentCopyInstance.engine,SLOT(skip(quint64)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for skip()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(sendErrorAction(QString)), currentCopyInstance.engine,SLOT(setErrorAction(QString)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for sendErrorAction()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(newSpeedLimitation(qint64)), currentCopyInstance.engine,SLOT(setSpeedLimitation(qint64)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for newSpeedLimitation()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(sendCollisionAction(QString)), currentCopyInstance.engine,SLOT(setCollisionAction(QString)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for sendCollisionAction()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(userAddFolder(CopyMode)), currentCopyInstance.engine,SLOT(userAddFolder(CopyMode)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for userAddFolder()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(userAddFile(CopyMode)), currentCopyInstance.engine,SLOT(userAddFile(CopyMode)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for userAddFile()").arg(index).arg((quint64)sender())); - - if(!connect(currentCopyInstance.interface,SIGNAL(removeItems(QList<int>)), currentCopyInstance.engine,SLOT(removeItems(QList<int>)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for removeItems()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(moveItemsOnTop(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsOnTop(QList<int>)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for moveItemsOnTop()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(moveItemsUp(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsUp(QList<int>)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for moveItemsUp()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(moveItemsDown(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsDown(QList<int>)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for moveItemsDown()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(moveItemsOnBottom(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsOnBottom(QList<int>)))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for moveItemsOnBottom()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(exportTransferList()), currentCopyInstance.engine,SLOT(exportTransferList()))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for exportTransferList()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(importTransferList()), currentCopyInstance.engine,SLOT(importTransferList()))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for importTransferList()").arg(index).arg((quint64)sender())); - - if(!connect(currentCopyInstance.interface,SIGNAL(newSpeedLimitation(qint64)), this,SLOT(resetSpeedDetectedInterface()))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for newSpeedLimitation()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(resume()), this,SLOT(resetSpeedDetectedInterface()))) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for resume()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(cancel()), this,SLOT(copyInstanceCanceledByInterface()),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for cancel()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.interface,SIGNAL(urlDropped(QList<QUrl>)), this,SLOT(urlDropped(QList<QUrl>)),Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for urlDropped()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(newActionOnList(QList<returnActionOnCopyList>)),this,SLOT(getActionOnList(QList<returnActionOnCopyList>)), Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for newActionOnList()").arg(index).arg((quint64)sender())); - - if(!connect(currentCopyInstance.engine,SIGNAL(pushFileProgression(QList<ProgressionItem>)), currentCopyInstance.interface,SLOT(setFileProgression(QList<ProgressionItem>)), Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for pushFileProgression()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(pushGeneralProgression(quint64,quint64)), currentCopyInstance.interface,SLOT(setGeneralProgression(quint64,quint64)), Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for pushGeneralProgression()").arg(index).arg((quint64)sender())); - if(!connect(currentCopyInstance.engine,SIGNAL(pushGeneralProgression(quint64,quint64)), this,SLOT(pushGeneralProgression(quint64,quint64)), Qt::QueuedConnection)) - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,QString("error at connect, the interface can not work correctly: %1: %2 for pushGeneralProgression() for this").arg(index).arg((quint64)sender())); - - currentCopyInstance.interface->setSpeedLimitation(currentCopyInstance.engine->getSpeedLimitation()); - currentCopyInstance.interface->setErrorAction(currentCopyInstance.engine->getErrorAction()); - currentCopyInstance.interface->setCollisionAction(currentCopyInstance.engine->getCollisionAction()); - currentCopyInstance.interface->setCopyType(currentCopyInstance.type); - currentCopyInstance.interface->setTransferListOperation(currentCopyInstance.transferListOperation); - currentCopyInstance.interface->actionInProgess(currentCopyInstance.action); - currentCopyInstance.interface->isInPause(currentCopyInstance.isPaused); - if(currentCopyInstance.haveError) - currentCopyInstance.interface->errorDetected(); - QWidget *tempWidget=currentCopyInstance.interface->getOptionsEngineWidget(); - if(tempWidget!=NULL) - currentCopyInstance.interface->getOptionsEngineEnabled(currentCopyInstance.engine->getOptionsEngine(tempWidget)); - //important, to have the modal dialog - currentCopyInstance.engine->setInterfacePointer(currentCopyInstance.interface); - - //put entry into the interface - currentCopyInstance.engine->syncTransferList(); - - //force the updating, without wait the timer - periodicSynchronization(index); -} - -void Core::disconnectEngine(const int &index) -{ - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start with index: %1").arg(index)); -// CopyInstance& currentCopyInstance=copyList[index]; -/* disconnect(currentCopyInstance.engine,SIGNAL(newFolderListing(QString)), this,SLOT(newFolderListing(QString)));//to check to change - disconnect(currentCopyInstance.engine,SIGNAL(newCollisionAction(QString)), this,SLOT(newCollisionAction(QString))); - disconnect(currentCopyInstance.engine,SIGNAL(newErrorAction(QString)), this,SLOT(newErrorAction(QString))); - disconnect(currentCopyInstance.engine,SIGNAL(actionInProgess(EngineActionInProgress)), this,SLOT(actionInProgess(EngineActionInProgress))); - disconnect(currentCopyInstance.engine,SIGNAL(isInPause(bool)), this,SLOT(isInPause(bool)));//to check to change - disconnect(currentCopyInstance.engine,SIGNAL(cancelAll()), this,SLOT(copyInstanceCanceledByEngine())); - disconnect(currentCopyInstance.engine,SIGNAL(error(QString,quint64,QDateTime,QString)), this,SLOT(error(QString,quint64,QDateTime,QString))); - disconnect(currentCopyInstance.engine,SIGNAL(rmPath(QString)), this,SLOT(rmPath(QString))); - disconnect(currentCopyInstance.engine,SIGNAL(mkPath(QString)), this,SLOT(mkPath(QString)));*/ - -} - -void Core::disconnectInterface(const int &index) -{ - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("start with index: %1").arg(index)); - Q_UNUSED(index); -/* CopyInstance& currentCopyInstance=copyList[index]; - disconnect(currentCopyInstance.interface,SIGNAL(pause()), currentCopyInstance.engine,SLOT(pause())); - disconnect(currentCopyInstance.interface,SIGNAL(resume()), currentCopyInstance.engine,SLOT(resume())); - disconnect(currentCopyInstance.interface,SIGNAL(skip(quint64)), currentCopyInstance.engine,SLOT(skip(quint64))); - disconnect(currentCopyInstance.interface,SIGNAL(sendErrorAction(QString)), currentCopyInstance.engine,SLOT(setErrorAction(QString))); - disconnect(currentCopyInstance.interface,SIGNAL(newSpeedLimitation(qint64)), currentCopyInstance.engine,SLOT(setSpeedLimitation(qint64))); - disconnect(currentCopyInstance.interface,SIGNAL(sendCollisionAction(QString)), currentCopyInstance.engine,SLOT(setCollisionAction(QString))); - disconnect(currentCopyInstance.interface,SIGNAL(userAddFolder(CopyMode)), currentCopyInstance.engine,SLOT(userAddFolder(CopyMode))); - disconnect(currentCopyInstance.interface,SIGNAL(userAddFile(CopyMode)), currentCopyInstance.engine,SLOT(userAddFile(CopyMode))); - - disconnect(currentCopyInstance.interface,SIGNAL(removeItems(QList<int>)), currentCopyInstance.engine,SLOT(removeItems(QList<int>))); - disconnect(currentCopyInstance.interface,SIGNAL(moveItemsOnTop(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsOnTop(QList<int>))); - disconnect(currentCopyInstance.interface,SIGNAL(moveItemsUp(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsUp(QList<int>))); - disconnect(currentCopyInstance.interface,SIGNAL(moveItemsDown(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsDown(QList<int>))); - disconnect(currentCopyInstance.interface,SIGNAL(moveItemsOnBottom(QList<int>)), currentCopyInstance.engine,SLOT(moveItemsOnBottom(QList<int>))); - - disconnect(currentCopyInstance.interface,SIGNAL(newSpeedLimitation(qint64)), this,SLOT(resetSpeedDetectedInterface())); - disconnect(currentCopyInstance.interface,SIGNAL(resume()), this,SLOT(resetSpeedDetectedInterface())); - disconnect(currentCopyInstance.interface,SIGNAL(cancel()), this,SLOT(copyInstanceCanceledByInterface())); - disconnect(currentCopyInstance.interface,SIGNAL(urlDropped(QList<QUrl>)), this,SLOT(urlDropped(QList<QUrl>))); - - disconnect(currentCopyInstance.engine,SIGNAL(newActionOnList(QList<returnActionOnCopyList>)), currentCopyInstance.interface,SLOT(getActionOnList(QList<returnActionOnCopyList>))); - disconnect(currentCopyInstance.engine,SIGNAL(pushFileProgression(QList<ProgressionItem>)), currentCopyInstance.interface,SLOT(setFileProgression(QList<ProgressionItem>))); - disconnect(currentCopyInstance.engine,SIGNAL(pushGeneralProgression(quint64,quint64)), currentCopyInstance.interface,SLOT(setGeneralProgression(quint64,quint64)));*/ + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start with index: %1: %2").arg(index).arg((quint64)sender())); + //disconnectInterface(index); + + CopyInstance& currentCopyInstance=copyList[index]; + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::pause, currentCopyInstance.engine,&PluginInterface_CopyEngine::pause)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for pause()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::resume, currentCopyInstance.engine,&PluginInterface_CopyEngine::resume)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for resume()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::skip, currentCopyInstance.engine,&PluginInterface_CopyEngine::skip)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for skip()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::newSpeedLimitation, currentCopyInstance.engine,&PluginInterface_CopyEngine::setSpeedLimitation)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for newSpeedLimitation()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::userAddFolder, currentCopyInstance.engine,&PluginInterface_CopyEngine::userAddFolder)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for userAddFolder()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::userAddFile, currentCopyInstance.engine,&PluginInterface_CopyEngine::userAddFile)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for userAddFile()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::removeItems, currentCopyInstance.engine,&PluginInterface_CopyEngine::removeItems)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for removeItems()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::moveItemsOnTop, currentCopyInstance.engine,&PluginInterface_CopyEngine::moveItemsOnTop)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for moveItemsOnTop()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::moveItemsUp, currentCopyInstance.engine,&PluginInterface_CopyEngine::moveItemsUp)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for moveItemsUp()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::moveItemsDown, currentCopyInstance.engine,&PluginInterface_CopyEngine::moveItemsDown)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for moveItemsDown()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::moveItemsOnBottom, currentCopyInstance.engine,&PluginInterface_CopyEngine::moveItemsOnBottom)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for moveItemsOnBottom()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::exportTransferList, currentCopyInstance.engine,&PluginInterface_CopyEngine::exportTransferList)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for exportTransferList()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::exportErrorIntoTransferList, currentCopyInstance.engine,&PluginInterface_CopyEngine::exportErrorIntoTransferList)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for exportErrorIntoTransferList()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::importTransferList, currentCopyInstance.engine,&PluginInterface_CopyEngine::importTransferList)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for importTransferList()").arg(index).arg((quint64)sender())); + + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::newSpeedLimitation, this,&Core::resetSpeedDetectedInterface)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for newSpeedLimitation()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::resume, this,&Core::resetSpeedDetectedInterface)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for resume()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::cancel, this,&Core::copyInstanceCanceledByInterface,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for cancel()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.interface,&PluginInterface_Themes::urlDropped, this,&Core::urlDropped,Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for urlDropped()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::newActionOnList,this,&Core::getActionOnList, Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for newActionOnList()").arg(index).arg((quint64)sender())); + + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::pushFileProgression, currentCopyInstance.interface,&PluginInterface_Themes::setFileProgression, Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for pushFileProgression()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::pushGeneralProgression, currentCopyInstance.interface,&PluginInterface_Themes::setGeneralProgression, Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for pushGeneralProgression()").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::pushGeneralProgression, this,&Core::pushGeneralProgression, Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for pushGeneralProgression() for this").arg(index).arg((quint64)sender())); + if(!connect(currentCopyInstance.engine,&PluginInterface_CopyEngine::errorToRetry, currentCopyInstance.interface,&PluginInterface_Themes::errorToRetry, Qt::QueuedConnection)) + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,QStringLiteral("error at connect, the interface can not work correctly: %1: %2 for errorToRetry() for this").arg(index).arg((quint64)sender())); + + currentCopyInstance.interface->setSupportSpeedLimitation(currentCopyInstance.engine->supportSpeedLimitation()); + currentCopyInstance.interface->setCopyType(currentCopyInstance.type); + currentCopyInstance.interface->setTransferListOperation(currentCopyInstance.transferListOperation); + currentCopyInstance.interface->actionInProgess(currentCopyInstance.action); + currentCopyInstance.interface->isInPause(currentCopyInstance.isPaused); + if(currentCopyInstance.haveError) + currentCopyInstance.interface->errorDetected(); + QWidget *tempWidget=currentCopyInstance.interface->getOptionsEngineWidget(); + if(tempWidget!=NULL) + currentCopyInstance.interface->getOptionsEngineEnabled(currentCopyInstance.engine->getOptionsEngine(tempWidget)); + //important, to have the modal dialog + currentCopyInstance.engine->setInterfacePointer(currentCopyInstance.interface); + + //put entry into the interface + currentCopyInstance.engine->syncTransferList(); + + //force the updating, without wait the timer + periodicSynchronizationWithIndex(index); } void Core::periodicSynchronization() { - index_sub_loop=0; - loop_size=copyList.size(); - while(index_sub_loop<loop_size) - { - if(copyList.at(index_sub_loop).action==Copying || copyList.at(index_sub_loop).action==CopyingAndListing) - periodicSynchronization(index_sub_loop); - index_sub_loop++; - } -} - -void Core::periodicSynchronization(const int &index) -{ - CopyInstance& currentCopyInstance=copyList[index]; - if(currentCopyInstance.engine==NULL || currentCopyInstance.interface==NULL) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,"some thread is null"); - return; - } - - /** ***************** Do time calcul ******************* **/ - if(!currentCopyInstance.isPaused) - { - //calcul the last difference of the transfere - realByteTransfered=currentCopyInstance.engine->realByteTransfered(); - diffCopiedSize=0; - if(realByteTransfered>=currentCopyInstance.lastProgression) - diffCopiedSize=realByteTransfered-currentCopyInstance.lastProgression; - currentCopyInstance.lastProgression=realByteTransfered; - - // algo 1: - // ((double)currentProgression)/totalProgression -> example: done 80% -> 0.8 - // baseTime+runningTime -> example: done into 80s, remaining time: 80/0.8-80=80*(1/0.8-1)=20s - // algo 2 (not used): - // remaining byte/current speed - - transferAddedTime=currentCopyInstance.baseTime+currentCopyInstance.runningTime.elapsed(); - - //remaining time: (total byte - lastProgression)/byte per ms since the start - if(currentCopyInstance.totalProgression==0 || currentCopyInstance.currentProgression==0) - currentCopyInstance.interface->remainingTime(-1); - else - currentCopyInstance.interface->remainingTime(transferAddedTime*((double)currentCopyInstance.totalProgression/(double)currentCopyInstance.currentProgression-1)/1000); - - //do the speed calculation - if(lastProgressionTime.isNull()) - lastProgressionTime.start(); - else - { - if((currentCopyInstance.action==Copying || currentCopyInstance.action==CopyingAndListing)) - { - currentCopyInstance.lastSpeedTime << lastProgressionTime.elapsed(); - currentCopyInstance.lastSpeedDetected << diffCopiedSize; - while(currentCopyInstance.lastSpeedDetected.size()>ULTRACOPIER_MAXVALUESPEEDSTORED) - { - currentCopyInstance.lastSpeedTime.removeFirst(); - currentCopyInstance.lastSpeedDetected.removeFirst(); - } - totTime=0; - totSpeed=0; - index_sub_loop=0; - loop_size=currentCopyInstance.lastSpeedDetected.size(); - while(index_sub_loop<loop_size) - { - totTime+=currentCopyInstance.lastSpeedTime.at(index_sub_loop); - totSpeed+=currentCopyInstance.lastSpeedDetected.at(index_sub_loop); - index_sub_loop++; - } - totTime/=1000; - currentCopyInstance.interface->detectedSpeed(totSpeed/totTime); - } - lastProgressionTime.restart(); - } - } + int index_sub_loop=0; + const int &loop_size=copyList.size(); + while(index_sub_loop<loop_size) + { + if(copyList.at(index_sub_loop).action==Ultracopier::Copying || copyList.at(index_sub_loop).action==Ultracopier::CopyingAndListing) + periodicSynchronizationWithIndex(index_sub_loop); + index_sub_loop++; + } +} + +void Core::periodicSynchronizationWithIndex(const int &index) +{ + CopyInstance& currentCopyInstance=copyList[index]; + if(currentCopyInstance.engine==NULL || currentCopyInstance.interface==NULL) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,"some thread is null"); + return; + } + + /** ***************** Do time calcul ******************* **/ + if(!currentCopyInstance.isPaused) + { + //calcul the last difference of the transfere + realByteTransfered=currentCopyInstance.engine->realByteTransfered(); + quint64 diffCopiedSize=0; + if(realByteTransfered>=currentCopyInstance.lastProgression) + diffCopiedSize=realByteTransfered-currentCopyInstance.lastProgression; + currentCopyInstance.lastProgression=realByteTransfered; + + // algo 1: + // ((double)currentProgression)/totalProgression -> example: done 80% -> 0.8 + // baseTime+runningTime -> example: done into 80s, remaining time: 80/0.8-80=80*(1/0.8-1)=20s + // algo 2 (not used): + // remaining byte/current speed + + //remaining time: (total byte - lastProgression)/byte per ms since the start + /*if(currentCopyInstance.totalProgression==0 || currentCopyInstance.currentProgression==0) + currentCopyInstance.interface->remainingTime(-1); + else if((currentCopyInstance.totalProgression-currentCopyInstance.currentProgression)>1024) + currentCopyInstance.interface->remainingTime(transferAddedTime*((double)currentCopyInstance.totalProgression/(double)currentCopyInstance.currentProgression-1)/1000);*/ + + //do the speed calculation + if(lastProgressionTime.isNull()) + lastProgressionTime.start(); + else + { + if((currentCopyInstance.action==Ultracopier::Copying || currentCopyInstance.action==Ultracopier::CopyingAndListing)) + { + currentCopyInstance.lastSpeedTime << lastProgressionTime.elapsed(); + currentCopyInstance.lastSpeedDetected << diffCopiedSize; + currentCopyInstance.lastAverageSpeedTime << lastProgressionTime.elapsed(); + currentCopyInstance.lastAverageSpeedDetected << diffCopiedSize; + while(currentCopyInstance.lastSpeedTime.size()>ULTRACOPIER_MAXVALUESPEEDSTORED) + currentCopyInstance.lastSpeedTime.removeFirst(); + while(currentCopyInstance.lastSpeedDetected.size()>ULTRACOPIER_MAXVALUESPEEDSTORED) + currentCopyInstance.lastSpeedDetected.removeFirst(); + while(currentCopyInstance.lastAverageSpeedTime.size()>ULTRACOPIER_MAXVALUESPEEDSTOREDTOREMAININGTIME) + currentCopyInstance.lastAverageSpeedTime.removeFirst(); + while(currentCopyInstance.lastAverageSpeedDetected.size()>ULTRACOPIER_MAXVALUESPEEDSTOREDTOREMAININGTIME) + currentCopyInstance.lastAverageSpeedDetected.removeFirst(); + double totTime=0,totAverageTime=0; + double totSpeed=0,totAverageSpeed=0; + + //current speed + int index_sub_loop=0; + int loop_size=currentCopyInstance.lastSpeedDetected.size(); + while(index_sub_loop<loop_size) + { + totTime+=currentCopyInstance.lastSpeedTime.at(index_sub_loop); + totSpeed+=currentCopyInstance.lastSpeedDetected.at(index_sub_loop); + index_sub_loop++; + } + totTime/=1000; + + //speed to calculate the remaining time + index_sub_loop=0; + loop_size=currentCopyInstance.lastAverageSpeedDetected.size(); + while(index_sub_loop<loop_size) + { + totAverageTime+=currentCopyInstance.lastAverageSpeedTime.at(index_sub_loop); + totAverageSpeed+=currentCopyInstance.lastAverageSpeedDetected.at(index_sub_loop); + index_sub_loop++; + } + totAverageTime/=1000; + + if(totTime>0) + if(loop_size>=ULTRACOPIER_MINVALUESPEED) + currentCopyInstance.interface->detectedSpeed(totSpeed/totTime); + + if(totAverageTime>0) + if(loop_size>=ULTRACOPIER_MINVALUESPEEDTOREMAININGTIME) + { + if(currentCopyInstance.remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Traditional) + { + if(totSpeed>0) + { + //remaining time: (total byte - lastProgression)/byte per ms since the start + if(currentCopyInstance.totalProgression==0 || currentCopyInstance.currentProgression==0) + currentCopyInstance.interface->remainingTime(-1); + else if((currentCopyInstance.totalProgression-currentCopyInstance.currentProgression)>1024) + currentCopyInstance.interface->remainingTime((currentCopyInstance.totalProgression-currentCopyInstance.currentProgression)/(totAverageSpeed/totAverageTime)); + } + else + currentCopyInstance.interface->remainingTime(-1); + } + else if(currentCopyInstance.remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + int remainingTimeValue=0; + //calculate for each file class + index_sub_loop=0; + loop_size=currentCopyInstance.remainingTimeLogarithmicValue.size(); + while(index_sub_loop<loop_size) + { + const RemainingTimeLogarithmicColumn &remainingTimeLogarithmicColumn=currentCopyInstance.remainingTimeLogarithmicValue.at(index_sub_loop); + //normal detect + const quint64 &remainingSize=remainingTimeLogarithmicColumn.totalSize-remainingTimeLogarithmicColumn.transferedSize; + if(remainingTimeLogarithmicColumn.lastProgressionSpeed.size()>=ULTRACOPIER_MINVALUESPEED) + { + int average_speed=0; + int temp_loop_index=0; + while(temp_loop_index<remainingTimeLogarithmicColumn.lastProgressionSpeed.size()) + { + average_speed+=remainingTimeLogarithmicColumn.lastProgressionSpeed.at(temp_loop_index); + temp_loop_index++; + } + average_speed/=remainingTimeLogarithmicColumn.lastProgressionSpeed.size(); + remainingTimeValue+=remainingSize/average_speed; + } + //fallback + else + { + if(totSpeed>0) + { + //remaining time: (total byte - lastProgression)/byte per ms since the start + if(currentCopyInstance.totalProgression==0 || currentCopyInstance.currentProgression==0) + remainingTimeValue+=1; + else if((currentCopyInstance.totalProgression-currentCopyInstance.currentProgression)>1024) + remainingTimeValue+=remainingSize/totAverageSpeed; + } + else + remainingTimeValue+=1; + } + index_sub_loop++; + } + currentCopyInstance.interface->remainingTime(remainingTimeValue); + } + else + {}//error case + } + } + lastProgressionTime.restart(); + } + } +} + +quint8 Core::fileCatNumber(quint64 size) +{ + //all is in base 10 to understand more easily + //drop the big value + if(size>ULTRACOPIER_REMAININGTIME_BIGFILEMEGABYTEBASE10*1000*1000) + size=ULTRACOPIER_REMAININGTIME_BIGFILEMEGABYTEBASE10*1000*1000; + size=size/100;//to group all the too small file into the value 0 + return log10(size); } /// \brief the copy engine have canceled the transfer void Core::copyInstanceCanceledByEngine() { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - int index=indexCopySenderCopyEngine(); - if(index!=-1) - copyInstanceCanceledByIndex(index); - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the copy engine sender"); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + int index=indexCopySenderCopyEngine(); + if(index!=-1) + copyInstanceCanceledByIndex(index); + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the copy engine sender"); } /// \brief the interface have canceled the transfer void Core::copyInstanceCanceledByInterface() { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - int index=indexCopySenderInterface(); - if(index!=-1) - copyInstanceCanceledByIndex(index); - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the copy engine sender"); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + int index=indexCopySenderInterface(); + if(index!=-1) + copyInstanceCanceledByIndex(index); + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the copy engine sender"); } /// \brief the transfer have been canceled void Core::copyInstanceCanceledByIndex(const int &index) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start, remove with the index: "+QString::number(index)); - disconnectEngine(index); - disconnectInterface(index); - CopyInstance& currentCopyInstance=copyList[index]; - currentCopyInstance.engine->cancel(); - delete currentCopyInstance.nextConditionalSync; - currentCopyInstance.engine->cancel(); - delete currentCopyInstance.interface; - index_sub_loop=0; - loop_size=currentCopyInstance.orderId.size(); - while(index_sub_loop<loop_size) - { - emit copyCanceled(currentCopyInstance.orderId.at(index_sub_loop)); - index_sub_loop++; - } - currentCopyInstance.orderId.clear(); - copyList.removeAt(index); - if(copyList.size()==0) - forUpateInformation.stop(); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"copyList.size(): "+QString::number(copyList.size())); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,"start, remove with the index: "+QString::number(index)); + //disconnectEngine(index); + //disconnectInterface(index); + copyList[index].canceled=true; + CopyInstance& currentCopyInstance=copyList[index]; + currentCopyInstance.engine->cancel(); + delete currentCopyInstance.nextConditionalSync; + delete currentCopyInstance.interface; + int index_sub_loop=0; + const int &loop_size=currentCopyInstance.orderId.size(); + while(index_sub_loop<loop_size) + { + emit copyCanceled(currentCopyInstance.orderId.at(index_sub_loop)); + index_sub_loop++; + } + currentCopyInstance.orderId.clear(); + copyList.removeAt(index); + if(copyList.size()==0) + forUpateInformation.stop(); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,"copyList.size(): "+QString::number(copyList.size())); } /// \brief only when the copy engine say it's ready to delete them self, it call this void Core::deleteCopyEngine() { - QObject * senderObject=sender(); - if(senderObject==NULL) - { - //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Qt sender() NULL"); - return; - } - PluginInterface_CopyEngine * copyEngine = static_cast<PluginInterface_CopyEngine *>(senderObject); - if(copyEngine==NULL) - { - //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"Qt sender() NULL"); - return; - } - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start, delete the copy engine"); - delete copyEngine; - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"stop, delete the copy engine"); + QObject * senderObject=sender(); + if(senderObject==NULL) + { + //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Qt sender() NULL"); + return; + } + PluginInterface_CopyEngine * copyEngine = static_cast<PluginInterface_CopyEngine *>(senderObject); + if(copyEngine==NULL) + { + //QMessageBox::critical(NULL,tr("Internal error"),tr("A communication error occured between the interface and the copy plugin. Please report this bug.")); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Qt sender() NULL"); + return; + } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,"start, delete the copy engine"); + delete copyEngine; + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,"stop, delete the copy engine"); } //error occurred void Core::error(const QString &path,const quint64 &size,const QDateTime &mtime,const QString &error) { - log.error(path,size,mtime,error); - int index=indexCopySenderCopyEngine(); - if(index!=-1) - { - copyList[index].haveError=true; - copyList.at(index).interface->errorDetected(); - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the copy engine sender"); + log.error(path,size,mtime,error); + int index=indexCopySenderCopyEngine(); + if(index!=-1) + { + copyList[index].haveError=true; + copyList.at(index).interface->errorDetected(); + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the copy engine sender"); } //for the extra logging void Core::rmPath(const QString &path) { - log.rmPath(path); + log.rmPath(path); } void Core::mkPath(const QString &path) { - log.mkPath(path); + log.mkPath(path); } /// \brief to rsync after a new interface connection void Core::syncReady() { - int index=indexCopySenderCopyEngine(); - if(index!=-1) - copyList[index].copyEngineIsSync=true; - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the copy engine sender"); + int index=indexCopySenderCopyEngine(); + if(index!=-1) + copyList[index].copyEngineIsSync=true; + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the copy engine sender"); } -void Core::getActionOnList(const QList<returnActionOnCopyList> & actionList) +void Core::getActionOnList(const QList<Ultracopier::ReturnActionOnCopyList> &actionList) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - int index=indexCopySenderCopyEngine(); - if(index!=-1) - { - if(copyList[index].copyEngineIsSync) - copyList[index].interface->getActionOnList(actionList); - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the copy engine sender"); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + //send the the interface + const int &index=indexCopySenderCopyEngine(); + if(index!=-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start2")); + if(copyList.at(index).copyEngineIsSync) + copyList.at(index).interface->getActionOnList(actionList); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start3")); + //log to the file and compute the remaining time + if(log.logTransfer() || copyList.at(index).remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start4")); + int sub_index=0; + const int &size=actionList.size(); + if(log.logTransfer() && copyList.at(index).remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start5")); + while(sub_index<size) + { + const Ultracopier::ReturnActionOnCopyList &returnAction=actionList.at(sub_index); + switch(returnAction.type) + { + case Ultracopier::PreOperation: + log.newTransferStart(returnAction.addAction); + break; + case Ultracopier::RemoveItem: + if(returnAction.userAction.moveAt==0) + log.newTransferStop(returnAction.addAction); + else + log.transferSkip(returnAction.addAction); + if(copyList.at(index).remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + const quint8 &col=fileCatNumber(returnAction.addAction.size); + copyList[index].remainingTimeLogarithmicValue[col].transferedSize+=returnAction.addAction.size; + } + break; + case Ultracopier::AddingItem: + if(copyList.at(index).remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + const quint8 &col=fileCatNumber(returnAction.addAction.size); + copyList[index].remainingTimeLogarithmicValue[col].totalSize+=returnAction.addAction.size; + } + break; + default: + break; + } + sub_index++; + } + } + else if(log.logTransfer()) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start6")); + while(sub_index<size) + { + const Ultracopier::ReturnActionOnCopyList &returnAction=actionList.at(sub_index); + switch(returnAction.type) + { + case Ultracopier::PreOperation: + log.newTransferStart(returnAction.addAction); + break; + case Ultracopier::RemoveItem: + if(returnAction.userAction.moveAt==0) + log.newTransferStop(returnAction.addAction); + else + log.transferSkip(returnAction.addAction); + if(copyList.at(index).remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + const quint8 &col=fileCatNumber(returnAction.addAction.size); + copyList[index].remainingTimeLogarithmicValue[col].transferedSize+=returnAction.addAction.size; + } + break; + default: + break; + } + sub_index++; + } + } + else + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start7")); + while(sub_index<size) + { + const Ultracopier::ReturnActionOnCopyList &returnAction=actionList.at(sub_index); + switch(returnAction.type) + { + case Ultracopier::RemoveItem: + if(copyList.at(index).remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + const quint8 &col=fileCatNumber(returnAction.addAction.size); + copyList[index].remainingTimeLogarithmicValue[col].transferedSize+=returnAction.addAction.size; + } + break; + case Ultracopier::AddingItem: + if(copyList.at(index).remainingTimeAlgo==Ultracopier::RemainingTimeAlgo_Logarithmic) + { + const quint8 &col=fileCatNumber(returnAction.addAction.size); + copyList[index].remainingTimeLogarithmicValue[col].totalSize+=returnAction.addAction.size; + } + break; + default: + break; + } + sub_index++; + } + } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start8")); + } + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start9")); + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the copy engine sender"); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start end")); } void Core::pushGeneralProgression(const quint64 ¤t,const quint64 &total) { - int index=indexCopySenderCopyEngine(); - if(index!=-1) - { - copyList[index].currentProgression=current; - copyList[index].totalProgression=total; - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the copy engine sender"); + int index=indexCopySenderCopyEngine(); + if(index!=-1) + { + copyList[index].currentProgression=current; + copyList[index].totalProgression=total; + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the copy engine sender"); } /// \brief used to drag and drop files void Core::urlDropped(const QList<QUrl> &urls) { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - int index=indexCopySenderInterface(); - if(index!=-1) - { - QStringList sources; - int index_loop=0; - while(index_loop<urls.size()) - { - if(!urls.at(index_loop).isEmpty()) - sources << urls.at(index_loop).toLocalFile(); - index_loop++; - } - if(sources.size()==0) - return; - else - { - if(copyList.at(index).ignoreMode) - { - QMessageBox::StandardButton reply=QMessageBox::question(copyList.at(index).interface,tr("Transfer mode"),tr("Do you want do as a copy? Else if you reply no, it will be moved."),QMessageBox::Yes|QMessageBox::No|QMessageBox::Cancel,QMessageBox::Cancel); - if(reply==QMessageBox::Yes) - copyList.at(index).engine->newCopy(sources); - if(reply==QMessageBox::No) - copyList.at(index).engine->newMove(sources); - } - else - { - if(copyList.at(index).mode==Copy) - copyList.at(index).engine->newCopy(sources); - else - copyList.at(index).engine->newMove(sources); - } - } - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,"unable to locate the copy engine sender"); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + int index=indexCopySenderInterface(); + if(index!=-1) + { + QStringList sources; + int index_loop=0; + while(index_loop<urls.size()) + { + if(!urls.at(index_loop).isEmpty()) + sources << urls.at(index_loop).toLocalFile(); + index_loop++; + } + if(sources.size()==0) + return; + else + { + if(copyList.at(index).ignoreMode) + { + QMessageBox::StandardButton reply=QMessageBox::question(copyList.at(index).interface,tr("Transfer mode"),tr("Do you want to copy? If no, it will be moved."),QMessageBox::Yes|QMessageBox::No|QMessageBox::Cancel,QMessageBox::Cancel); + if(reply==QMessageBox::Yes) + copyList.at(index).engine->newCopy(sources); + if(reply==QMessageBox::No) + copyList.at(index).engine->newMove(sources); + } + else + { + if(copyList.at(index).mode==Ultracopier::Copy) + copyList.at(index).engine->newCopy(sources); + else + copyList.at(index).engine->newMove(sources); + } + } + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"unable to locate the copy engine sender"); } |