blob: c495f608a08b6e90b75e719d6495a26dfed5fa11 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
/** \file ListThread_InodeAction.cpp
\brief To be included into ListThread.cpp, to optimize and prevent code duplication
\see ListThread.cpp
\author alpha_one_x86
\version 0.3
\date 2011 */
#ifdef LISTTHREAD_H
//do the inode action
actionToDoInode& currentActionToDoInode=actionToDoListInode[int_for_internal_loop];
switch(currentActionToDoInode.type)
{
case ActionType_MkPath:
ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("launch mkpath: %1").arg(currentActionToDoInode.folder.absoluteFilePath()));
mkPathQueue.addPath(currentActionToDoInode.folder.absoluteFilePath());
currentActionToDoInode.isRunning=true;
numberOfInodeOperation++;
if(numberOfInodeOperation>=ULTRACOPIER_PLUGIN_MAXPARALLELINODEOPT)
return;
break;
case ActionType_RmSync:
ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("launch rm to sync: %1").arg(currentActionToDoInode.folder.absoluteFilePath()));
rmPathQueue.addPath(currentActionToDoInode.folder.absoluteFilePath(),true);
currentActionToDoInode.isRunning=true;
numberOfInodeOperation++;
if(numberOfInodeOperation>=ULTRACOPIER_PLUGIN_MAXPARALLELINODEOPT)
return;
break;
case ActionType_RmPath:
/* What is this code?
if((int_for_loop+number_rm_path_moved)>=(loop_size-1))
{
if(numberOfTranferRuning)
break;
else
currentActionToDoInode.size=0;
}*/
//then empty (no file), can try remove it
if(true)//currentActionToDoInode.size==0
{
if(numberOfTranferRuning>0)
ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("skipped because already inode = 0 and transfer is running: %1").arg(currentActionToDoInode.folder.absoluteFilePath()));
ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("launch rmpath: %1").arg(currentActionToDoInode.folder.absoluteFilePath()));
rmPathQueue.addPath(currentActionToDoInode.folder.absoluteFilePath(),false);
currentActionToDoInode.isRunning=true;
numberOfInodeOperation++;
if(numberOfInodeOperation>=ULTRACOPIER_PLUGIN_MAXPARALLELINODEOPT)
return;
}
else //have not finish all the transfer into it, do it later
{
ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,"should never pass here");
/*actionToDoListInode.move(int_for_internal_loop,actionToDoListInode_count-1);
currentActionToDoInode.id=generateIdNumber();
number_rm_path_moved++;
currentActionToDoInode.size=0;
continue;*/
}
break;
default:
ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("Wrong type at inode action"));
return;
}
#endif
|
