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
|
/***************************************************************************
synchronizertask.h - description
-------------------
copyright : (C) 2006 + 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_TASK_H__
#define __SYNCHRONIZER_TASK_H__
#include <tqobject.h>
#include <tdeio/job.h>
class Synchronizer;
class SynchronizerDirList;
class SynchronizerFileItem;
class TQProgressDialog;
class TQTimer;
class TQFile;
#define ST_STATE_NEW 0
#define ST_STATE_PENDING 1
#define ST_STATE_STATUS 2
#define ST_STATE_READY 3
#define ST_STATE_ERROR 4
class SynchronizerTask : public TQObject {
TQ_OBJECT
public:
SynchronizerTask() : TQObject(), m_state( ST_STATE_NEW ), m_statusMessage( TQString() ) {}
virtual ~SynchronizerTask() {};
inline int start( TQWidget *parentWidget ) { this->parentWidget = parentWidget; start(); return state(); }
inline int state() { return m_state; }
void setStatusMessage( const TQString & statMsg ) {
if( m_state == ST_STATE_PENDING || m_state == ST_STATE_STATUS )
m_state = ST_STATE_STATUS;
m_statusMessage = statMsg;
}
TQString status() {
if( m_state == ST_STATE_STATUS ) {
m_state = ST_STATE_PENDING;
return m_statusMessage;
}
return TQString();
}
protected:
virtual void start() {};
int m_state;
TQString m_statusMessage;
TQWidget *parentWidget;
};
class CompareTask : public SynchronizerTask {
TQ_OBJECT
public:
CompareTask( SynchronizerFileItem *parentIn, const TQString &leftURL,
const TQString &rightURL, const TQString &leftDir,
const TQString &rightDir, bool ignoreHidden );
CompareTask( SynchronizerFileItem *parentIn, const TQString &urlIn,
const TQString &dirIn, bool isLeftIn, bool ignoreHidden );
virtual ~CompareTask();
inline bool isDuplicate() { return m_duplicate; }
inline bool isLeft() { return !m_duplicate && m_isLeft; }
inline const TQString & leftURL() { return m_url; }
inline const TQString & rightURL() { return m_otherUrl; }
inline const TQString & leftDir() { return m_dir; }
inline const TQString & rightDir() { return m_otherDir; }
inline const TQString & url() { return m_url; }
inline const TQString & dir() { return m_dir; }
inline SynchronizerFileItem * parent() { return m_parent; }
inline SynchronizerDirList * leftDirList() { return m_dirList; }
inline SynchronizerDirList * rightDirList() { return m_otherDirList; }
inline SynchronizerDirList * dirList() { return m_dirList; }
protected slots:
virtual void start();
void slotFinished( bool result );
void slotOtherFinished( bool result );
private:
SynchronizerFileItem * m_parent;
TQString m_url;
TQString m_dir;
TQString m_otherUrl;
TQString m_otherDir;
bool m_isLeft;
bool m_duplicate;
SynchronizerDirList * m_dirList;
SynchronizerDirList * m_otherDirList;
bool m_loadFinished;
bool m_otherLoadFinished;
bool ignoreHidden;
};
class CompareContentTask : public SynchronizerTask {
TQ_OBJECT
public:
CompareContentTask( Synchronizer *, SynchronizerFileItem *, const KURL &, const KURL &, TDEIO::filesize_t );
virtual ~CompareContentTask();
public slots:
void slotDataReceived(TDEIO::Job *job, const TQByteArray &data);
void slotFinished(TDEIO::Job *job);
void sendStatusMessage();
protected:
virtual void start();
protected slots:
void localFileCompareCycle();
private:
void abortContentComparing();
KURL leftURL; // the currently processed URL (left)
KURL rightURL; // the currently processed URL (right)
TDEIO::filesize_t size; // the size of the compared files
bool errorPrinted; // flag indicates error
TDEIO::TransferJob *leftReadJob; // compare left read job
TDEIO::TransferJob *rightReadJob; // compare right read job
TQByteArray compareArray; // the array for comparing
SynchronizerFileItem *item; // the item for content compare
TQTimer *timer; // timer to show the process dialog at compare by content
TQFile *leftFile; // the left side local file
TQFile *rightFile; // the right side local file
TDEIO::filesize_t received; // the received size
Synchronizer *sync;
};
#endif /* __SYNCHRONIZER_TASK_H__ */
|
