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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
|
/***************************************************************************
synchronizer.h - description
-------------------
copyright : (C) 2003 + by Csaba Karai
e-mail : krusader@users.sourceforge.net
web site : http://krusader.sourceforge.net
---------------------------------------------------------------------------
Description
***************************************************************************
A
db dD d8888b. db db .d8888. .d8b. d8888b. d88888b d8888b.
88 ,8P' 88 `8D 88 88 88' YP d8' `8b 88 `8D 88' 88 `8D
88,8P 88oobY' 88 88 `8bo. 88ooo88 88 88 88ooooo 88oobY'
88`8b 88`8b 88 88 `Y8b. 88~~~88 88 88 88~~~~~ 88`8b
88 `88. 88 `88. 88b d88 db 8D 88 88 88 .8D 88. 88 `88.
YP YD 88 YD ~Y8888P' `8888Y' YP YP Y8888D' Y88888P 88 YD
H e a d e r F i l e
***************************************************************************
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation; either version 2 of the License, or *
* (at your option) any later version. *
* *
***************************************************************************/
#ifndef __SYNCHRONIZER_H__
#define __SYNCHRONIZER_H__
#include "synchronizertask.h"
#include "synchronizerfileitem.h"
#include <tqobject.h>
#include <tqptrvector.h>
#include <tqmap.h>
#include <tqcolor.h>
#include <tdeio/job.h>
class KRQuery;
class vfile;
#define DECLARE_COLOR_NAME_ARRAY TQString COLOR_NAMES[] = { "Equals", "Differs", "LeftCopy", "RightCopy", "Delete", \
"Equals", "Equals", "Equals", "Equals", "Equals" }
#define DECLARE_BACKGROUND_DFLTS TQColor BCKG_DFLTS[] = { TQColor(), TQColor(), TQColor(), TQColor(), TQt::red, \
TQColor(), TQColor(), TQColor(), TQColor(), TQColor() }
#define DECLARE_FOREGROUND_DFLTS TQColor FORE_DFLTS[] = { TQt::black, TQt::red, TQt::blue, TQt::darkGreen, TQt::white, \
TQt::black, TQt::black, TQt::black, TQt::black, TQt::black }
class Synchronizer : public TQObject
{
TQ_OBJECT
private:
int displayUpdateCount; // the display is refreshed after every x-th change
public:
Synchronizer();
int compare( TQString leftURL, TQString rightURL, KRQuery *query, bool subDirs, bool symLinks,
bool igDate, bool asymm, bool cmpByCnt, bool igCase, bool autoSc, TQStringList &selFiles,
int equThres, int timeOffs, int parThreads, bool hiddenFiles );
void stop() {stopped = true;}
void setMarkFlags( bool left, bool equal, bool differs, bool right, bool dup, bool sing, bool del );
int refresh( bool nostatus=false );
bool totalSizes( int *, TDEIO::filesize_t *, int *, TDEIO::filesize_t *, int *, TDEIO::filesize_t * );
void synchronize( TQWidget *,bool leftCopyEnabled, bool rightCopyEnabled, bool deleteEnabled,
bool overWrite, int parThreads );
void synchronizeWithKGet();
void setScrolling( bool scroll );
void pause();
void resume();
void swapSides();
void reset();
void exclude( SynchronizerFileItem * );
void restore( SynchronizerFileItem * );
void reverseDirection( SynchronizerFileItem * );
void copyToLeft( SynchronizerFileItem * );
void copyToRight( SynchronizerFileItem * );
void deleteLeft( SynchronizerFileItem * );
TQString leftBaseDirectory();
TQString rightBaseDirectory();
static TQString getTaskTypeName( TaskType taskType );
SynchronizerFileItem *getItemAt( unsigned ndx ) {return resultList.at(ndx);}
void setParentWidget( TQWidget * widget ) {parentWidget = widget;}
void compareContentResult( SynchronizerFileItem * item, bool result );
signals:
void comparedFileData( SynchronizerFileItem * );
void markChanged( SynchronizerFileItem *, bool );
void synchronizationFinished();
void processedSizes( int, TDEIO::filesize_t, int, TDEIO::filesize_t, int, TDEIO::filesize_t );
void pauseAccepted();
void statusInfo( TQString );
public slots:
void slotTaskFinished(TDEIO::Job*);
void slotProcessedSize( TDEIO::Job * , TDEIO::filesize_t );
private:
bool isDir( const vfile * file );
TQString readLink( const vfile * file );
void compareDirectory( SynchronizerFileItem *,SynchronizerDirList *, SynchronizerDirList *,
const TQString &leftDir, const TQString &rightDir );
void addSingleDirectory( SynchronizerFileItem *, SynchronizerDirList *, const TQString &, bool );
SynchronizerFileItem * addItem( SynchronizerFileItem *, const TQString &, const TQString &,
const TQString &, const TQString &, bool, bool, TDEIO::filesize_t,
TDEIO::filesize_t, time_t, time_t, const TQString &, const TQString &,
const TQString &, const TQString &, const TQString &, const TQString &,
mode_t, mode_t, const TQString &, const TQString &, TaskType, bool, bool);
SynchronizerFileItem * addLeftOnlyItem( SynchronizerFileItem *, const TQString &, const TQString &,
TDEIO::filesize_t, time_t, const TQString &, const TQString &,
const TQString &, mode_t, const TQString &, bool isDir = false, bool isTemp = false );
SynchronizerFileItem * addRightOnlyItem( SynchronizerFileItem *, const TQString &, const TQString &,
TDEIO::filesize_t, time_t, const TQString &, const TQString &,
const TQString &, mode_t, const TQString &, bool isDir = false, bool isTemp = false );
SynchronizerFileItem * addDuplicateItem( SynchronizerFileItem *, const TQString &, const TQString &,
const TQString &, const TQString &, TDEIO::filesize_t,
TDEIO::filesize_t, time_t, time_t, const TQString &,
const TQString &, const TQString &, const TQString &,
const TQString &, const TQString &, mode_t, mode_t, const TQString &,
const TQString &, bool isDir = false, bool isTemp = false );
bool isMarked( TaskType task, bool dupl );
bool markParentDirectories( SynchronizerFileItem * );
void synchronizeLoop();
SynchronizerFileItem * getNextTask();
void executeTask( SynchronizerFileItem * task );
void setPermanent( SynchronizerFileItem * );
void operate( SynchronizerFileItem *item, void (*)(SynchronizerFileItem *) );
void compareLoop();
static void excludeOperation( SynchronizerFileItem *item );
static void restoreOperation( SynchronizerFileItem *item );
static void reverseDirectionOperation( SynchronizerFileItem *item );
static void copyToLeftOperation( SynchronizerFileItem *item );
static void copyToRightOperation( SynchronizerFileItem *item );
static void deleteLeftOperation( SynchronizerFileItem *item );
protected:
bool recurseSubDirs; // walk through subdirectories also
bool followSymLinks; // follow the symbolic links
bool ignoreDate; // don't use date info at comparing
bool asymmetric; // asymmetric directory update
bool cmpByContent; // compare the files by content
bool ignoreCase; // case insensitive synchronization for Windows fs
bool autoScroll; // automatic update of the directory
TQPtrList<SynchronizerFileItem> resultList; // the found files
TQPtrList<SynchronizerFileItem> temporaryList; // temporary files
TQString leftBaseDir; // the left-side base directory
TQString rightBaseDir; // the right-side base directory
TQStringList excludedPaths; // list of the excluded paths
KRQuery *query; // the filter used for the query
bool stopped; // 'Stop' button was pressed
int equalsThreshold;// threshold to treat files equal
int timeOffset; // time offset between the left and right sides
bool ignoreHidden; // ignores the hidden files
bool markEquals; // show the equal files
bool markDiffers; // show the different files
bool markCopyToLeft; // show the files to copy from right to left
bool markCopyToRight;// show the files to copy from left to right
bool markDeletable; // show the files to be deleted
bool markDuplicates; // show the duplicated items
bool markSingles; // show the single items
bool leftCopyEnabled;// copy to left is enabled at synchronize
bool rightCopyEnabled;// copy to right is enabled at synchronize
bool deleteEnabled; // delete is enabled at synchronize
bool overWrite; // overwrite or query each modification
bool autoSkip; // automatic skipping
bool paused; // pause flag
bool disableNewTasks;// at mkdir the further task creation is disabled
int leftCopyNr; // the file number copied to left
int rightCopyNr; // the file number copied to right
int deleteNr; // the number of the deleted files
int parallelThreads;// the number of the parallel procesing threads
TDEIO::filesize_t leftCopySize; // the total size copied to left
TDEIO::filesize_t rightCopySize; // the total size copied to right
TDEIO::filesize_t deleteSize; // the size of the deleted files
int comparedDirs; // the number of the compared directories
int fileCount; // the number of counted files
private:
TQPtrList<SynchronizerTask> stack; // stack for comparing
TQMap<TDEIO::Job *,SynchronizerFileItem *> jobMap; // job maps
TQMap<TDEIO::Job *,TDEIO::filesize_t> receivedMap; // the received file size
SynchronizerFileItem *lastTask; // reference to the last stack
int inTaskFinished; // counter of quasy 'threads' in slotTaskFinished
TQStringList selectedFiles; // the selected files to compare
TQWidget *parentWidget; // the parent widget
TQWidget *syncDlgWidget; // the synchronizer dialog widget
};
#endif /* __SYNCHRONIZER_H__ */
|
