Add a couple of missing progress signals.

This commit is contained in:
Klaas Freitag 2013-11-26 11:31:40 +01:00
parent 4f7546768b
commit 090e474d70

View file

@ -177,9 +177,11 @@ void PropagateLocalRemove::start()
return; return;
} }
} }
emit progress(Progress::StartDelete, _item, 0, _item._size);
_propagator->_journal->deleteFileRecord(_item._originalFile); _propagator->_journal->deleteFileRecord(_item._originalFile);
_propagator->_journal->commit("Local remove"); _propagator->_journal->commit("Local remove");
done(SyncFileItem::Success); done(SyncFileItem::Success);
emit progress(Progress::EndDelete, _item, 0, _item._size);
} }
DECLARE_JOB(PropagateLocalMkdir) DECLARE_JOB(PropagateLocalMkdir)
@ -200,6 +202,7 @@ void PropagateRemoteRemove::start()
{ {
QScopedPointer<char, QScopedPointerPodDeleter> uri( QScopedPointer<char, QScopedPointerPodDeleter> uri(
ne_path_escape((_propagator->_remoteDir + _item._file).toUtf8())); ne_path_escape((_propagator->_remoteDir + _item._file).toUtf8()));
emit progress(Progress::StartDelete, _item, 0, _item._size);
qDebug() << "** DELETE " << uri.data(); qDebug() << "** DELETE " << uri.data();
int rc = ne_delete(_propagator->_session, uri.data()); int rc = ne_delete(_propagator->_session, uri.data());
/* Ignore the error 404, it means it is already deleted */ /* Ignore the error 404, it means it is already deleted */
@ -209,6 +212,7 @@ void PropagateRemoteRemove::start()
_propagator->_journal->deleteFileRecord(_item._originalFile, _item._isDirectory); _propagator->_journal->deleteFileRecord(_item._originalFile, _item._isDirectory);
_propagator->_journal->commit("Remote Remove"); _propagator->_journal->commit("Remote Remove");
done(SyncFileItem::Success); done(SyncFileItem::Success);
emit progress(Progress::EndDelete, _item, 0, _item._size);
} }
DECLARE_JOB(PropagateRemoteMkdir) DECLARE_JOB(PropagateRemoteMkdir)
@ -855,6 +859,9 @@ DECLARE_JOB(PropagateRemoteRename)
void PropagateRemoteRename::start() void PropagateRemoteRename::start()
{ {
emit progress(Progress::StartRename, _item, 0, _item._size);
if (_item._file == _item._renameTarget) { if (_item._file == _item._renameTarget) {
if (!_item._isDirectory) { if (!_item._isDirectory) {
// The parents has been renamed already so there is nothing more to do. // The parents has been renamed already so there is nothing more to do.
@ -897,6 +904,8 @@ void PropagateRemoteRename::start()
_propagator->_journal->setFileRecord(record); _propagator->_journal->setFileRecord(record);
_propagator->_journal->commit("Remote Rename"); _propagator->_journal->commit("Remote Rename");
done(SyncFileItem::Success); done(SyncFileItem::Success);
emit progress(Progress::EndRename, _item, 0, _item._size);
} }
bool PropagateItemJob::updateErrorFromSession(int neon_code, ne_request* req, int ignoreHttpCode) bool PropagateItemJob::updateErrorFromSession(int neon_code, ne_request* req, int ignoreHttpCode)