blob: e65233924d5ff4bce8beb4a023310daf265a91a0 (
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
|
#include <QMutexLocker>
#include <QFile>
#include "filecopier.h"
FileCopier::FileCopier(QObject *parent) : QThread(parent), mCancel(false){}
void FileCopier::addJob(const QString &source, const QString &dest){
QMutexLocker l(&mAddJobMutex);
if(!mJobs.contains(source)){
mJobs[source] = dest;
}
}
QHash<QString, QString> FileCopier::jobs(){
QMutexLocker l(&mAddJobMutex);
return mJobs;
}
void FileCopier::run(){
int bufsize = 16 * 1024 * 1024;
char *buf = new char[bufsize];
mCancel = false;
while(!mJobs.isEmpty()){
mAddJobMutex.lock();
auto first = mJobs.constBegin();
auto source = first.key();
auto dest = first.value();
mJobs.remove(source);
mAddJobMutex.unlock();
QFile sFile(source);
QFile dFile(dest);
bool openSource = sFile.open(QIODevice::ReadOnly);
bool openDest = dFile.open(QIODevice::WriteOnly);
if(!openSource || !openDest){
emit success(false, source);
goto cleanup;
}
emit newFile(source, dest, sFile.size());
int read = 0;
qint64 total = 0;
while(!sFile.atEnd()){
mCancelMutex.lock();
bool cancel = mCancel;
mCancelMutex.unlock();
if(cancel){
QFile::remove(dest);
emit success(false, source);
goto cleanup;
}
read = sFile.read(buf, bufsize);
dFile.write(buf, read);
total += read;
emit bytesRead(total);
}
emit success(true, source);
}
cleanup:
delete buf;
}
void FileCopier::cancel(){
QMutexLocker l(&mCancelMutex);
mCancel = true;
}
|
