d4708/qBittorrent
1
0
Fork 0
mirror of https://github.com/d47081/qBittorrent.git synced 2025-01-10 14:57:52 +00:00
Code Issues Projects Releases Wiki Activity

- URLStream is now constructed in downloadThread constructor

Browse Source
This commit is contained in:
Christophe Dumez 2007-07-22 15:13:11 +00:00
parent c019b0d72c
commit 4f17339820
1 changed files with 8 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/downloadThread.h
View File

@ -45,7 +45,7 @@ class downloadThread : public QThread {
QMutex mutex;
QWaitCondition condition;
bool abort;
URLStream *url_stream;
URLStream url_stream;
QList<downloadThread*> subThreads;
bool subThread;
@ -61,7 +61,6 @@ class downloadThread : public QThread {
qDebug("Creating downloadThread");
abort = false;
this->subThread = subThread;
url_stream = 0;
qDebug("downloadThread created");
}
@ -70,14 +69,10 @@ class downloadThread : public QThread {
abort = true;
condition.wakeOne();
mutex.unlock();
if(url_stream != 0)
delete url_stream;
wait();
}
void downloadUrl(QString url){
if(url_stream == 0)
url_stream = new URLStream();
QMutexLocker locker(&mutex);
url_list << url;
if(!isRunning()){
@ -144,31 +139,31 @@ class downloadThread : public QThread {
std::cerr << "Error: could't create temporary file: " << (const char*)filePath.toUtf8() << '\n';
continue;
}
URLStream::Error status = url_stream->get((const char*)url.toUtf8());
URLStream::Error status = url_stream.get((const char*)url.toUtf8());
if(status){
// Failure
QString error_msg = errorCodeToString(status);
qDebug("Download failed for %s, reason: %s", (const char*)url.toUtf8(), (const char*)error_msg.toUtf8());
url_stream->close();
url_stream.close();
emit downloadFailureST(this, url, error_msg);
continue;
}
qDebug("Downloading %s...", (const char*)url.toUtf8());
char cbuf[1024];
int len;
while(!url_stream->eof()) {
url_stream->read(cbuf, sizeof(cbuf));
len = url_stream->gcount();
while(!url_stream.eof()) {
url_stream.read(cbuf, sizeof(cbuf));
len = url_stream.gcount();
if(len > 0)
dest_file.write(cbuf, len);
if(abort){
dest_file.close();
url_stream->close();
url_stream.close();
return;
}
}
dest_file.close();
url_stream->close();
url_stream.close();
emit downloadFinishedST(this, url, filePath);
qDebug("download completed here: %s", (const char*)filePath.toUtf8());
}else{