mirrors/nextcloud-desktop
1
0
Fork 0
mirror of https://github.com/nextcloud/desktop.git synced 2024-10-24 21:35:47 +03:00
Code Issues Projects Releases Packages Wiki Activity

Detect the error that may happen when downloading a file

Browse source
This commit is contained in:
Olivier Goffart 2014-03-19 15:19:09 +01:00
parent 39924d79cb
commit 05d3273591
2 changed files with 27 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/mirall/propagator_qnam.cpp
View file

@ -296,8 +296,26 @@ void GETFileJob::start() {
void GETFileJob::slotReadyRead()
{
// FIXME: error handling (hard drive full, ....)
_device->write(reply()->readAll());
int bufferSize = qMax(1024*8ll , reply()->bytesAvailable());
QByteArray buffer(bufferSize, Qt::Uninitialized);
while(reply()->bytesAvailable() > 0) {
qint64 r = reply()->read(buffer.data(), bufferSize);
if (r < 0) {
_errorString = reply()->errorString();
qDebug() << "Error while reading from device: " << _errorString;
reply()->abort();
return;
}
qint64 w = _device->write(buffer.constData(), r);
if (w != r) {
_errorString = _device->errorString();
qDebug() << "Error while writing to file" << w << r << _errorString;
reply()->abort();
return;
}
}
}
@ -395,7 +413,7 @@ void PropagateDownloadFileQNAM::slotGetFinished()
}
_item._httpErrorCode = job->reply()->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
_propagator->_activeJobs--;
done(classifyError(err, _item._httpErrorCode), job->reply()->errorString());
done(classifyError(err, _item._httpErrorCode), job->errorString());
return;
}

6
src/mirall/propagator_qnam.h
View file

@ -97,7 +97,9 @@ class GETFileJob : public AbstractNetworkJob {
Q_OBJECT
QIODevice* _device;
QMap<QByteArray, QByteArray> _headers;
QString _errorString;
public:
// DOES NOT take owncership of the device.
explicit GETFileJob(Account* account, const QString& path, QIODevice *device,
const QMap<QByteArray, QByteArray> &headers, QObject* parent = 0)
@ -108,6 +110,10 @@ public:
emit finishedSignal();
}
QString errorString() {
return _errorString.isEmpty() ? reply()->errorString() : _errorString;
};
signals:
void finishedSignal();
void downloadProgress(qint64,qint64);