[core] recreate offline database when it is deleted out from under our feet
This commit is contained in:
@@ -79,8 +79,11 @@ void OfflineDatabase::initialize() {
|
||||
|
||||
void OfflineDatabase::handleError(const mapbox::sqlite::Exception& ex, const char* action) {
|
||||
if (ex.code == mapbox::sqlite::ResultCode::NotADB ||
|
||||
ex.code == mapbox::sqlite::ResultCode::Corrupt) {
|
||||
// Corrupted; delete database so that we have a clean slate for the next operation.
|
||||
ex.code == mapbox::sqlite::ResultCode::Corrupt ||
|
||||
(ex.code == mapbox::sqlite::ResultCode::ReadOnly &&
|
||||
ex.extendedCode == mapbox::sqlite::ExtendedResultCode::ReadOnlyDBMoved)) {
|
||||
// The database was corruped, moved away, or deleted. We're going to start fresh with a
|
||||
// clean slate for the next operation.
|
||||
Log::Error(Event::Database, static_cast<int>(ex.code), "Can't %s: %s", action, ex.what());
|
||||
try {
|
||||
removeExisting();
|
||||
|
||||
@@ -45,6 +45,10 @@ public:
|
||||
DatabaseImpl(sqlite3* db_)
|
||||
: db(db_)
|
||||
{
|
||||
const int error = sqlite3_extended_result_codes(db, true);
|
||||
if (error != SQLITE_OK) {
|
||||
mbgl::Log::Warning(mbgl::Event::Database, error, "Failed to enable extended result codes: %s", sqlite3_errmsg(db));
|
||||
}
|
||||
}
|
||||
|
||||
~DatabaseImpl()
|
||||
|
||||
@@ -15,7 +15,7 @@ enum OpenFlag : int {
|
||||
ReadWriteCreate = 0b110,
|
||||
};
|
||||
|
||||
enum class ResultCode : int {
|
||||
enum class ResultCode : uint8_t {
|
||||
OK = 0,
|
||||
Error = 1,
|
||||
Internal = 2,
|
||||
@@ -40,24 +40,25 @@ enum class ResultCode : int {
|
||||
NoLFS = 22,
|
||||
Auth = 23,
|
||||
Range = 25,
|
||||
NotADB = 26
|
||||
NotADB = 26,
|
||||
};
|
||||
|
||||
enum class ExtendedResultCode : uint8_t {
|
||||
Unknown = 0,
|
||||
ReadOnlyDBMoved = 4,
|
||||
};
|
||||
|
||||
class Exception : public std::runtime_error {
|
||||
public:
|
||||
Exception(int err, const char* msg)
|
||||
: std::runtime_error(msg), code(static_cast<ResultCode>(err)) {
|
||||
}
|
||||
Exception(ResultCode err, const char* msg)
|
||||
: std::runtime_error(msg), code(err) {
|
||||
}
|
||||
Exception(ResultCode err, const char* msg) : Exception(static_cast<int>(err), msg) {}
|
||||
Exception(int err, const char* msg) : Exception(err, std::string{ msg }) {}
|
||||
Exception(int err, const std::string& msg)
|
||||
: std::runtime_error(msg), code(static_cast<ResultCode>(err)) {
|
||||
}
|
||||
Exception(ResultCode err, const std::string& msg)
|
||||
: std::runtime_error(msg), code(err) {
|
||||
: std::runtime_error(msg),
|
||||
code(static_cast<ResultCode>(err)),
|
||||
extendedCode(static_cast<ExtendedResultCode>(err >> 8)) {
|
||||
}
|
||||
const ResultCode code = ResultCode::OK;
|
||||
const ExtendedResultCode extendedCode = ExtendedResultCode::Unknown;
|
||||
};
|
||||
|
||||
class DatabaseImpl;
|
||||
|
||||
@@ -32,7 +32,7 @@ static FixtureLog::Message error(ResultCode code, const char* message) {
|
||||
return { EventSeverity::Error, Event::Database, static_cast<int64_t>(code), message };
|
||||
}
|
||||
|
||||
static FixtureLog::Message warning(ResultCode code, const char* message) {
|
||||
static __attribute__((unused)) FixtureLog::Message warning(ResultCode code, const char* message) {
|
||||
return { EventSeverity::Warning, Event::Database, static_cast<int64_t>(code), message };
|
||||
}
|
||||
|
||||
@@ -232,7 +232,7 @@ TEST(OfflineDatabase, TEST_REQUIRES_WRITE(Invalid)) {
|
||||
// Checking two possibilities for the error string because it apparently changes between SQLite versions.
|
||||
EXPECT_EQ(1u, log.count(error(ResultCode::NotADB, "Can't open database: file is encrypted or is not a database"), true) +
|
||||
log.count(error(ResultCode::NotADB, "Can't open database: file is not a database"), true));
|
||||
EXPECT_EQ(1u, log.count(warning(static_cast<ResultCode>(-1), "Removing existing incompatible offline database")));
|
||||
EXPECT_EQ(1u, log.count({ EventSeverity::Warning, Event::Database, -1, "Removing existing incompatible offline database" }));
|
||||
|
||||
// Now try inserting and reading back to make sure we have a valid database.
|
||||
for (const auto& res : { fixture::resource, fixture::tile }) {
|
||||
@@ -977,7 +977,7 @@ TEST(OfflineDatabase, CorruptDatabaseOnOpen) {
|
||||
// This database is corrupt in a way that will prevent opening the database.
|
||||
OfflineDatabase db(filename);
|
||||
EXPECT_EQ(1u, log.count(error(ResultCode::Corrupt, "Can't open database: database disk image is malformed"), true));
|
||||
EXPECT_EQ(1u, log.count(warning(static_cast<ResultCode>(-1), "Removing existing incompatible offline database")));
|
||||
EXPECT_EQ(1u, log.count({ EventSeverity::Warning, Event::Database, -1, "Removing existing incompatible offline database" }));
|
||||
EXPECT_EQ(0u, log.uncheckedCount());
|
||||
|
||||
// Now try inserting and reading back to make sure we have a valid database.
|
||||
@@ -1007,7 +1007,7 @@ TEST(OfflineDatabase, CorruptDatabaseOnQuery) {
|
||||
// The first request fails because the database is corrupt and has to be recreated.
|
||||
EXPECT_EQ(nullopt, db.get(fixture::tile));
|
||||
EXPECT_EQ(1u, log.count(error(ResultCode::Corrupt, "Can't read resource: database disk image is malformed"), true));
|
||||
EXPECT_EQ(1u, log.count(warning(static_cast<ResultCode>(-1), "Removing existing incompatible offline database")));
|
||||
EXPECT_EQ(1u, log.count({ EventSeverity::Warning, Event::Database, -1, "Removing existing incompatible offline database" }));
|
||||
EXPECT_EQ(0u, log.uncheckedCount());
|
||||
|
||||
// Now try inserting and reading back to make sure we have a valid database.
|
||||
|
||||
Reference in New Issue
Block a user