1 files changed, 64 insertions, 0 deletions
diff --git a/plugins-unmaintained/CopyEngine/Ultracopier-Qt/ListThread_InodeAction.cpp b/plugins-unmaintained/CopyEngine/Ultracopier-Qt/ListThread_InodeAction.cpp
new file mode 100755
index 0000000..12421f2
--- /dev/null
+++ b/plugins-unmaintained/CopyEngine/Ultracopier-Qt/ListThread_InodeAction.cpp
@@ -0,0 +1,64 @@
+/** \file ListThread_InodeAction.cpp
+\brief To be included into ListThread.cpp, to optimize and prevent code duplication
+\see ListThread.cpp */
+
+#ifdef LISTTHREAD_H
+
+//do the inode action
+ActionToDoInode& currentActionToDoInode=actionToDoListInode[int_for_internal_loop];
+switch(currentActionToDoInode.type)
+{
+    case ActionType_RealMove:
+        ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("launch real move, source: %1, destination: %2").arg(currentActionToDoInode.source.absoluteFilePath()).arg(currentActionToDoInode.destination.absoluteFilePath()).toStdString());
+        mkPathQueue.addPath(currentActionToDoInode.source.absoluteFilePath(),currentActionToDoInode.destination.absoluteFilePath(),currentActionToDoInode.type);
+        currentActionToDoInode.isRunning=true;
+        numberOfInodeOperation++;
+        if(numberOfInodeOperation>=inodeThreads)
+            return;
+    break;
+    case ActionType_MkPath:
+        ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("launch mkpath, source: %1, destination: %2").arg(currentActionToDoInode.source.absoluteFilePath()).arg(currentActionToDoInode.destination.absoluteFilePath()).toStdString());
+        mkPathQueue.addPath(currentActionToDoInode.source.absoluteFilePath(),currentActionToDoInode.destination.absoluteFilePath(),currentActionToDoInode.type);
+        currentActionToDoInode.isRunning=true;
+        numberOfInodeOperation++;
+        if(numberOfInodeOperation>=inodeThreads)
+            return;
+    break;
+    #ifdef ULTRACOPIER_PLUGIN_RSYNC
+    case ActionType_RmSync:
+        ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QString("launch rmsync, destination: %1").arg(currentActionToDoInode.destination.absoluteFilePath()).toStdString());
+        mkPathQueue.addPath(currentActionToDoInode.destination.absoluteFilePath(),currentActionToDoInode.destination.absoluteFilePath(),currentActionToDoInode.type);
+        currentActionToDoInode.isRunning=true;
+        numberOfInodeOperation++;
+        if(numberOfInodeOperation>=inodeThreads)
+            return;
+    break;
+    #endif
+    case ActionType_MovePath:
+        //then empty (no file), can try remove it
+        if(currentActionToDoInode.size==0 || actionToDoListTransfer.empty())//don't put afterTheTransfer because actionToDoListInode_afterTheTransfer -> already afterTheTransfer
+        {
+            ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("launch rmpath: %1").arg(currentActionToDoInode.source.absoluteFilePath()).toStdString());
+            mkPathQueue.addPath(currentActionToDoInode.source.absoluteFilePath(),currentActionToDoInode.destination.absoluteFilePath(),currentActionToDoInode.type);
+            currentActionToDoInode.isRunning=true;
+            numberOfInodeOperation++;
+            if(numberOfInodeOperation>=inodeThreads)
+                return;
+        }
+        else //have do the destination, put the remove to after
+        {
+            currentActionToDoInode.size=0;
+            actionToDoListInode_afterTheTransfer.push_back(currentActionToDoInode);
+            actionToDoListInode.erase(actionToDoListInode.cbegin()+int_for_internal_loop);
+            int_for_internal_loop--;
+            actionToDoListInode_count--;
+            if(numberOfInodeOperation>=inodeThreads)
+                return;
+        }
+    break;
+    default:
+        ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,"Wrong type at inode action");
+    return;
+}
+
+#endif