Nuke from orbit corrupt websql databases.

content/common/web_database_observer_impl.cc

 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/common/web_database_observer_impl.h"
 
 #include "base/metrics/histogram.h"
 #include "base/string16.h"
 #include "content/common/database_messages.h"
+#include "third_party/sqlite/sqlite3.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebDatabase.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebString.h"
 
 using WebKit::WebDatabase;
 
 namespace {
 
 const int kResultHistogramSize = 50;
 const int kCallsiteHistogramSize = 10;
 
@@ skipping 71 matching lines @@
   sender_->Send(new DatabaseHostMsg_Closed(
       origin_identifier, database_name));
   open_connections_->RemoveOpenConnection(origin_identifier, database_name);
 }
 
 void WebDatabaseObserverImpl::reportOpenDatabaseResult(
     const WebDatabase& database, int callsite, int websql_error,
     int sqlite_error) {
   HISTOGRAM_WEBSQL_RESULT("OpenResult", database, callsite,
                           websql_error, sqlite_error);
+  HandleSqliteError(database, sqlite_error);
 }
 
 void WebDatabaseObserverImpl::reportChangeVersionResult(
     const WebDatabase& database, int callsite, int websql_error,
     int sqlite_error) {
   HISTOGRAM_WEBSQL_RESULT("ChangeVersionResult", database, callsite,
                           websql_error, sqlite_error);
+  HandleSqliteError(database, sqlite_error);
 }
 
 void WebDatabaseObserverImpl::reportStartTransactionResult(
     const WebDatabase& database, int callsite, int websql_error,
     int sqlite_error) {
   HISTOGRAM_WEBSQL_RESULT("BeginResult", database, callsite,
                           websql_error, sqlite_error);
+  HandleSqliteError(database, sqlite_error);
 }
 
 void WebDatabaseObserverImpl::reportCommitTransactionResult(
     const WebDatabase& database, int callsite, int websql_error,
     int sqlite_error) {
   HISTOGRAM_WEBSQL_RESULT("CommitResult", database, callsite,
                           websql_error, sqlite_error);
+  HandleSqliteError(database, sqlite_error);
 }
 
 void WebDatabaseObserverImpl::reportExecuteStatementResult(
     const WebDatabase& database, int callsite, int websql_error,
     int sqlite_error) {
   HISTOGRAM_WEBSQL_RESULT("StatementResult", database, callsite,
                           websql_error, sqlite_error);
+  HandleSqliteError(database, sqlite_error);
 }
 
 void WebDatabaseObserverImpl::reportVacuumDatabaseResult(
     const WebDatabase& database, int sqlite_error) {
   int result = DetermineHistogramResult(-1, sqlite_error);
   if (database.isSyncDatabase()) {
     UMA_HISTOGRAM_ENUMERATION("websql.Sync.VacuumResult",
                               result, kResultHistogramSize);
   } else {
     UMA_HISTOGRAM_ENUMERATION("websql.Async.VacuumResult",
                               result, kResultHistogramSize);
   }
+  HandleSqliteError(database, sqlite_error);
 }
 
 void WebDatabaseObserverImpl::WaitForAllDatabasesToClose() {
   open_connections_->WaitForAllDatabasesToClose();
 }
+
+void WebDatabaseObserverImpl::HandleSqliteError(
+    const WebDatabase& database, int error) {
+  // We filter out errors which the backend doesn't act on to avoid
+  // a unnecessary ipc traffic, this method can get called at a fairly
+  // high frequency (per-sqlstatement).
+  if (error == SQLITE_CORRUPT || error == SQLITE_NOTADB) {
+    sender_->Send(new DatabaseHostMsg_HandleSqliteError(
+        database.securityOrigin().databaseIdentifier(),
+        database.name(),
+        error));
+  }
+}