Skip to content

Commit

Permalink
Revert "Remove behavior changes."
Browse files Browse the repository at this point in the history
This reverts commit 84d06ce.

Signed-off-by: allexzander <blackslayer4@gmail.com>
  • Loading branch information
allexzander authored and mgallien committed Sep 17, 2022
1 parent d425005 commit b40c2df
Show file tree
Hide file tree
Showing 10 changed files with 43 additions and 9 deletions.
20 changes: 11 additions & 9 deletions src/common/syncjournaldb.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1722,7 +1722,7 @@ void SyncJournalDb::deleteStaleFlagsEntries()

SqlQuery delQuery("DELETE FROM flags WHERE path != '' AND path NOT IN (SELECT path from metadata);", _db);
if (!delQuery.exec()) {
qCWarning(lcDb) << QStringLiteral("deleteStaleFlagsEntries") << delQuery.error();
sqlFail(QStringLiteral("deleteStaleFlagsEntries"), delQuery);
}
}

Expand Down Expand Up @@ -1865,7 +1865,7 @@ void SyncJournalDb::setPollInfo(const SyncJournalDb::PollInfo &info)
SqlQuery query("DELETE FROM async_poll WHERE path=?", _db);
query.bindValue(1, info._file);
if (!query.exec()) {
qCWarning(lcDb) << QStringLiteral("setPollInfo DELETE FROM async_poll") << query.error();
sqlFail(QStringLiteral("setPollInfo DELETE FROM async_poll"), query);
}
} else {
SqlQuery query("INSERT OR REPLACE INTO async_poll (path, modtime, filesize, pollpath) VALUES( ? , ? , ? , ? )", _db);
Expand All @@ -1874,7 +1874,7 @@ void SyncJournalDb::setPollInfo(const SyncJournalDb::PollInfo &info)
query.bindValue(3, info._fileSize);
query.bindValue(4, info._url);
if (!query.exec()) {
qCWarning(lcDb) << QStringLiteral("setPollInfo INSERT OR REPLACE INTO async_poll") << query.error();
sqlFail(QStringLiteral("setPollInfo INSERT OR REPLACE INTO async_poll"), query);
}
}
}
Expand Down Expand Up @@ -1963,7 +1963,7 @@ void SyncJournalDb::avoidRenamesOnNextSync(const QByteArray &path)
query.bindValue(1, path);

if (!query.exec()) {
qCWarning(lcDb) << QStringLiteral("avoidRenamesOnNextSync path: %1").arg(QString::fromUtf8(path)) << query.error();
sqlFail(QStringLiteral("avoidRenamesOnNextSync path: %1").arg(QString::fromUtf8(path)), query);
}

// We also need to remove the ETags so the update phase refreshes the directory paths
Expand Down Expand Up @@ -1991,7 +1991,7 @@ void SyncJournalDb::schedulePathForRemoteDiscovery(const QByteArray &fileName)
query.bindValue(1, argument);

if (!query.exec()) {
qCWarning(lcDb) << QStringLiteral("schedulePathForRemoteDiscovery path: %11").arg(QString::fromUtf8(fileName)) << query.error();
sqlFail(QStringLiteral("schedulePathForRemoteDiscovery path: %1").arg(QString::fromUtf8(fileName)), query);
}

// Prevent future overwrite of the etags of this folder and all
Expand Down Expand Up @@ -2023,7 +2023,7 @@ void SyncJournalDb::forceRemoteDiscoveryNextSyncLocked()
deleteRemoteFolderEtagsQuery.prepare("UPDATE metadata SET md5='_invalid_' WHERE type=2;");

if (!deleteRemoteFolderEtagsQuery.exec()) {
qCWarning(lcDb) << QStringLiteral("forceRemoteDiscoveryNextSyncLocked") << deleteRemoteFolderEtagsQuery.error();
sqlFail(QStringLiteral("forceRemoteDiscoveryNextSyncLocked"), deleteRemoteFolderEtagsQuery);
}
}

Expand Down Expand Up @@ -2233,7 +2233,7 @@ void SyncJournalDb::clearFileTable()
query.prepare("DELETE FROM metadata;");

if (!query.exec()) {
qCWarning(lcDb) << QStringLiteral("clearFileTable") << query.error();
sqlFail(QStringLiteral("clearFileTable"), query);
}
}

Expand All @@ -2250,7 +2250,7 @@ void SyncJournalDb::markVirtualFileForDownloadRecursively(const QByteArray &path
query.bindValue(1, path);

if (!query.exec()) {
qCWarning(lcDb) << QStringLiteral("markVirtualFileForDownloadRecursively UPDATE metadata SET type=5 path: %1").arg(QString::fromUtf8(path)) << query.error();
sqlFail(QStringLiteral("markVirtualFileForDownloadRecursively UPDATE metadata SET type=5 path: %1").arg(QString::fromUtf8(path)), query);
}

// We also must make sure we do not read the files from the database (same logic as in schedulePathForRemoteDiscovery)
Expand All @@ -2261,7 +2261,7 @@ void SyncJournalDb::markVirtualFileForDownloadRecursively(const QByteArray &path
query.bindValue(1, path);

if (!query.exec()) {
qCWarning(lcDb) << QStringLiteral("markVirtualFileForDownloadRecursively UPDATE metadata SET md5='_invalid_' path: %1").arg(QString::fromUtf8(path)) << query.error();
sqlFail(QStringLiteral("markVirtualFileForDownloadRecursively UPDATE metadata SET md5='_invalid_' path: %1").arg(QString::fromUtf8(path)), query);
}
}

Expand Down Expand Up @@ -2395,6 +2395,8 @@ SyncJournalDb::PinStateInterface::rawList()

if (!query.exec()) {
qCWarning(lcDb) << "SQL Error" << "PinStateInterface::rawList" << query.error();
_db->close();
ASSERT(false);
}

QVector<QPair<QByteArray, PinState>> result;
Expand Down
2 changes: 2 additions & 0 deletions src/gui/folder.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -618,6 +618,7 @@ void Folder::implicitlyHydrateFile(const QString &relativepath)
;
if (!_journal.getFileRecord(relativepath.toUtf8(), &record)) {
qCWarning(lcFolder) << "could not get file from local DB" << relativepath;
return;
}
if (!record.isValid()) {
qCInfo(lcFolder) << "Did not find file in db";
Expand All @@ -633,6 +634,7 @@ void Folder::implicitlyHydrateFile(const QString &relativepath)
const auto result = _journal.setFileRecord(record);
if (!result) {
qCWarning(lcFolder) << "Error when setting the file record to the database" << record._path << result.error();
return;
}

// Change the file's pin state if it's contradictory to being hydrated
Expand Down
1 change: 1 addition & 0 deletions src/libsync/discovery.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -915,6 +915,7 @@ void ProcessDirectoryJob::processFileAnalyzeLocalInfo(
// Not locally, not on the server. The entry is stale!
qCInfo(lcDisco) << "Stale DB entry";
if (!_discoveryData->_statedb->deleteFileRecord(path._original, true)) {
_discoveryData->fatalError(tr("Error while deleting file record %1 from the database").arg(path._original));
qCWarning(lcDisco) << "Failed to delete a file record from the local DB" << path._original;
}
return;
Expand Down
7 changes: 7 additions & 0 deletions src/libsync/owncloudpropagator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1199,6 +1199,13 @@ void PropagateDirectory::slotSubJobsFinished(SyncFileItem::Status status)
if (_item->_instruction == CSYNC_INSTRUCTION_RENAME && _item->_originalFile != _item->_renameTarget) {
if (!propagator()->_journal->deleteFileRecord(_item->_originalFile, true)) {
qCWarning(lcDirectory) << "could not delete file from local DB" << _item->_originalFile;
_state = Finished;
status = _item->_status = SyncFileItem::FatalError;
_item->_errorString = tr("could not delete file %1 from local DB").arg(_item->_originalFile);
qCInfo(lcPropagator) << "PropagateDirectory::slotSubJobsFinished"
<< "emit finished" << status;
emit finished(status);
return;
}
}

Expand Down
6 changes: 6 additions & 0 deletions src/libsync/propagatedownload.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -461,6 +461,8 @@ void PropagateDownloadFile::start()
SyncJournalFileRecord parentRec;
if (!propagator()->_journal->getFileRecord(parentPath, &parentRec)) {
qCWarning(lcPropagateDownload) << "could not get file from local DB" << parentPath;
done(SyncFileItem::NormalError, tr("could not get file %1 from local DB").arg(parentPath));
return;
}

const auto account = propagator()->account();
Expand Down Expand Up @@ -507,6 +509,8 @@ void PropagateDownloadFile::startAfterIsEncryptedIsChecked()

if (!propagator()->_journal->deleteFileRecord(_item->_originalFile)) {
qCWarning(lcPropagateDownload) << "could not delete file from local DB" << _item->_originalFile;
done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(_item->_originalFile));
return;
}

updateMetadata(false);
Expand Down Expand Up @@ -1245,6 +1249,8 @@ void PropagateDownloadFile::downloadFinished()

if (!propagator()->_journal->deleteFileRecord(virtualFile)) {
qCWarning(lcPropagateDownload) << "could not delete file from local DB" << virtualFile;
done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(virtualFile));
return;
}

// Move the pin state to the new location
Expand Down
2 changes: 2 additions & 0 deletions src/libsync/propagateremotedelete.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,8 @@ void PropagateRemoteDelete::slotDeleteJobFinished()

if (!propagator()->_journal->deleteFileRecord(_item->_originalFile, _item->isDirectory())) {
qCWarning(lcPropagateRemoteDelete) << "could not delete file from local DB" << _item->_originalFile;
done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(_item->_originalFile));
return;
}

propagator()->_journal->commit("Remote Remove");
Expand Down
4 changes: 4 additions & 0 deletions src/libsync/propagateremotemove.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -247,6 +247,8 @@ void PropagateRemoteMove::finalize()
SyncJournalFileRecord oldRecord;
if (!propagator()->_journal->getFileRecord(_item->_originalFile, &oldRecord)) {
qCWarning(lcPropagateRemoteMove) << "could not get file from local DB" << _item->_originalFile;
done(SyncFileItem::NormalError, tr("could not get file %1 from local DB").arg(_item->_originalFile));
return;
}
auto &vfs = propagator()->syncOptions()._vfs;
auto pinState = vfs->pinState(_item->_originalFile);
Expand All @@ -257,6 +259,8 @@ void PropagateRemoteMove::finalize()
// Delete old db data.
if (!propagator()->_journal->deleteFileRecord(_item->_originalFile)) {
qCWarning(lcPropagateRemoteMove) << "could not delete file from local DB" << _item->_originalFile;
done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(_item->_originalFile));
return;
}
if (!vfs->setPinState(_item->_originalFile, PinState::Inherited)) {
qCWarning(lcPropagateRemoteMove) << "Could not set pin state of" << _item->_originalFile << "to inherited";
Expand Down
6 changes: 6 additions & 0 deletions src/libsync/propagatorjobs.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -130,6 +130,8 @@ void PropagateLocalRemove::start()
propagator()->reportProgress(*_item, 0);
if (!propagator()->_journal->deleteFileRecord(_item->_originalFile, _item->isDirectory())) {
qCWarning(lcPropagateLocalRename) << "could not delete file from local DB" << _item->_originalFile;
done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(_item->_originalFile));
return;
}
propagator()->_journal->commit("Local remove");
done(SyncFileItem::Success);
Expand Down Expand Up @@ -249,9 +251,13 @@ void PropagateLocalRename::start()
SyncJournalFileRecord oldRecord;
if (!propagator()->_journal->getFileRecord(_item->_originalFile, &oldRecord)) {
qCWarning(lcPropagateLocalRename) << "could not get file from local DB" << _item->_originalFile;
done(SyncFileItem::NormalError, tr("could not get file %1 from local DB").arg(_item->_originalFile));
return;
}
if (!propagator()->_journal->deleteFileRecord(_item->_originalFile)) {
qCWarning(lcPropagateLocalRename) << "could not delete file from local DB" << _item->_originalFile;
done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(_item->_originalFile));
return;
}

auto &vfs = propagator()->syncOptions()._vfs;
Expand Down
3 changes: 3 additions & 0 deletions src/libsync/syncengine.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -381,6 +381,9 @@ void OCC::SyncEngine::slotItemDiscovered(const OCC::SyncFileItemPtr &item)

// Updating the db happens on success
if (!_journal->setFileRecord(rec)) {
item->_status = SyncFileItem::Status::NormalError;
item->_instruction = CSYNC_INSTRUCTION_ERROR;
item->_errorString = tr("Could not set file record to local DB: %1").arg(rec.path());
qCWarning(lcEngine) << "Could not set file record to local DB" << rec.path();
}

Expand Down
1 change: 1 addition & 0 deletions src/libsync/vfs/cfapi/hydrationjob.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -291,6 +291,7 @@ void OCC::HydrationJob::finalize(OCC::VfsCfApi *vfs)
SyncJournalFileRecord record;
if (!_journal->getFileRecord(_folderPath, &record)) {
qCWarning(lcHydration) << "could not get file from local DB" << _folderPath;
return;
}
Q_ASSERT(record.isValid());
if (!record.isValid()) {
Expand Down

0 comments on commit b40c2df

Please sign in to comment.