Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(165)

Unified Diff: sql/connection.cc

Issue 1432953002: Revert "[sql] Validate database files before enabling memory-mapping." (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « sql/connection.h ('k') | tools/metrics/histograms/histograms.xml » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sql/connection.cc
diff --git a/sql/connection.cc b/sql/connection.cc
index 185b95512bf5bd6d836765f6cbfa428ea036a7da..44cb5979884f5a4e8cd0b2a72f95651ca37d43e1 100644
--- a/sql/connection.cc
+++ b/sql/connection.cc
@@ -537,8 +537,6 @@ void Connection::Preload() {
scoped_ptr<char[]> buf(new char[page_size]);
for (sqlite3_int64 pos = 0; pos < preload_size; pos += page_size) {
rc = file->pMethods->xRead(file, buf.get(), page_size, pos);
-
- // TODO(shess): Consider calling OnSqliteError().
if (rc != SQLITE_OK)
return;
}
@@ -863,144 +861,6 @@ std::string Connection::CollectCorruptionInfo() {
return debug_info;
}
-size_t Connection::GetAppropriateMmapSize() {
- AssertIOAllowed();
-
- // TODO(shess): Using sql::MetaTable seems indicated, but mixing
- // sql::MetaTable and direct access seems error-prone. It might make sense to
- // simply integrate sql::MetaTable functionality into sql::Connection.
-
-#if defined(OS_IOS)
- // iOS SQLite does not support memory mapping.
- return 0;
-#endif
-
- // If the database doesn't have a place to track progress, assume the worst.
- // This will happen when new databases are created.
- if (!DoesTableExist("meta")) {
- RecordOneEvent(EVENT_MMAP_META_MISSING);
- return 0;
- }
-
- // Key into meta table to get status from a previous run. The value
- // represents how much data in bytes has successfully been read from the
- // database. |kMmapFailure| indicates that there was a read error and the
- // database should not be memory-mapped, while |kMmapSuccess| indicates that
- // the entire file was read at some point and can be memory-mapped without
- // constraint.
- const char* kMmapStatusKey = "mmap_status";
- static const sqlite3_int64 kMmapFailure = -2;
- static const sqlite3_int64 kMmapSuccess = -1;
-
- // Start reading from 0 unless status is found in meta table.
- sqlite3_int64 mmap_ofs = 0;
-
- // Retrieve the current status. It is fine for the status to be missing
- // entirely, but any error prevents memory-mapping.
- {
- const char* kMmapStatusSql = "SELECT value FROM meta WHERE key = ?";
- Statement s(GetUniqueStatement(kMmapStatusSql));
- s.BindString(0, kMmapStatusKey);
- if (s.Step()) {
- mmap_ofs = s.ColumnInt64(0);
- } else if (!s.Succeeded()) {
- RecordOneEvent(EVENT_MMAP_META_FAILURE_READ);
- return 0;
- }
- }
-
- // Database read failed in the past, don't memory map.
- if (mmap_ofs == kMmapFailure) {
- RecordOneEvent(EVENT_MMAP_FAILED);
- return 0;
- } else if (mmap_ofs != kMmapSuccess) {
- // Continue reading from previous offset.
- DCHECK_GE(mmap_ofs, 0);
-
- // TODO(shess): Could this reading code be shared with Preload()? It would
- // require locking twice (this code wouldn't be able to access |db_size| so
- // the helper would have to return amount read).
-
- // Read more of the database looking for errors. The VFS interface is used
- // to assure that the reads are valid for SQLite. |g_reads_allowed| is used
- // to limit checking to 20MB per run of Chromium.
- sqlite3_file* file = NULL;
- sqlite3_int64 db_size = 0;
- if (SQLITE_OK != GetSqlite3FileAndSize(db_, &file, &db_size)) {
- RecordOneEvent(EVENT_MMAP_VFS_FAILURE);
- return 0;
- }
-
- // Read the data left, or |g_reads_allowed|, whichever is smaller.
- // |g_reads_allowed| limits the total amount of I/O to spend verifying data
- // in a single Chromium run.
- sqlite3_int64 amount = db_size - mmap_ofs;
- if (amount < 0)
- amount = 0;
- if (amount > 0) {
- base::AutoLock lock(g_sqlite_init_lock.Get());
- static sqlite3_int64 g_reads_allowed = 20 * 1024 * 1024;
- if (g_reads_allowed < amount)
- amount = g_reads_allowed;
- g_reads_allowed -= amount;
- }
-
- // |amount| can be <= 0 if |g_reads_allowed| ran out of quota, or if the
- // database was truncated after a previous pass.
- if (amount <= 0 && mmap_ofs < db_size) {
- DCHECK_EQ(0, amount);
- RecordOneEvent(EVENT_MMAP_SUCCESS_NO_PROGRESS);
- } else {
- static const int kPageSize = 4096;
- char buf[kPageSize];
- while (amount > 0) {
- int rc = file->pMethods->xRead(file, buf, sizeof(buf), mmap_ofs);
- if (rc == SQLITE_OK) {
- mmap_ofs += sizeof(buf);
- amount -= sizeof(buf);
- } else if (rc == SQLITE_IOERR_SHORT_READ) {
- // Reached EOF for a database with page size < |kPageSize|.
- mmap_ofs = db_size;
- break;
- } else {
- // TODO(shess): Consider calling OnSqliteError().
- mmap_ofs = kMmapFailure;
- break;
- }
- }
-
- // Log these events after update to distinguish meta update failure.
- Events event;
- if (mmap_ofs >= db_size) {
- mmap_ofs = kMmapSuccess;
- event = EVENT_MMAP_SUCCESS_NEW;
- } else if (mmap_ofs > 0) {
- event = EVENT_MMAP_SUCCESS_PARTIAL;
- } else {
- DCHECK_EQ(kMmapFailure, mmap_ofs);
- event = EVENT_MMAP_FAILED_NEW;
- }
-
- const char* kMmapUpdateStatusSql = "REPLACE INTO meta VALUES (?, ?)";
- Statement s(GetUniqueStatement(kMmapUpdateStatusSql));
- s.BindString(0, kMmapStatusKey);
- s.BindInt64(1, mmap_ofs);
- if (!s.Run()) {
- RecordOneEvent(EVENT_MMAP_META_FAILURE_UPDATE);
- return 0;
- }
-
- RecordOneEvent(event);
- }
- }
-
- if (mmap_ofs == kMmapFailure)
- return 0;
- if (mmap_ofs == kMmapSuccess)
- return 256 * 1024 * 1024;
- return mmap_ofs;
-}
-
void Connection::TrimMemory(bool aggressively) {
if (!db_)
return;
@@ -1820,14 +1680,14 @@ bool Connection::OpenInternal(const std::string& file_name,
}
// Enable memory-mapped access. The explicit-disable case is because SQLite
- // can be built to default-enable mmap. GetAppropriateMmapSize() calculates a
- // safe range to memory-map based on past regular I/O. This value will be
- // capped by SQLITE_MAX_MMAP_SIZE, which could be different between 32-bit and
- // 64-bit platforms.
- size_t mmap_size = mmap_disabled_ ? 0 : GetAppropriateMmapSize();
- std::string mmap_sql =
- base::StringPrintf("PRAGMA mmap_size = %" PRIuS, mmap_size);
- ignore_result(Execute(mmap_sql.c_str()));
+ // can be built to default-enable mmap. This value will be capped by
+ // SQLITE_MAX_MMAP_SIZE, which could be different between 32-bit and 64-bit
+ // platforms.
+ if (mmap_disabled_) {
+ ignore_result(Execute("PRAGMA mmap_size = 0"));
+ } else {
+ ignore_result(Execute("PRAGMA mmap_size = 268435456")); // 256MB.
+ }
// Determine if memory-mapping has actually been enabled. The Execute() above
// can succeed without changing the amount mapped.
« no previous file with comments | « sql/connection.h ('k') | tools/metrics/histograms/histograms.xml » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698