[Sync] Erase sync DB when corrupted

sync/syncable/directory_backing_store_unittest.cc

 // Copyright 2012 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 "testing/gtest/include/gtest/gtest.h"
 
 #include <string>
 
 #include "base/files/file_path.h"
-#include "base/files/file_util.h"
-#include "base/files/scoped_file.h"
 #include "base/files/scoped_temp_dir.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
 #include "base/stl_util.h"
 #include "base/strings/string_number_conversions.h"
 #include "sql/connection.h"
 #include "sql/statement.h"
 #include "sql/test/scoped_error_ignorer.h"
 #include "sql/test/test_helpers.h"
 #include "sync/base/sync_export.h"
 #include "sync/internal_api/public/base/node_ordinal.h"
 #include "sync/protocol/bookmark_specifics.pb.h"
 #include "sync/protocol/sync.pb.h"
 #include "sync/syncable/directory.h"
 #include "sync/syncable/directory_backing_store.h"
 #include "sync/syncable/on_disk_directory_backing_store.h"
 #include "sync/syncable/syncable-inl.h"
+#include "sync/test/directory_backing_store_corruption_testing.h"
 #include "sync/test/test_directory_backing_store.h"
 #include "sync/util/time.h"
 #include "testing/gtest/include/gtest/gtest-param-test.h"
 
 namespace syncer {
 namespace syncable {
 namespace {
 
 // A handler that simply sets |catastrophic_error_handler_was_called| to true.
 void CatastrophicErrorHandler(bool* catastrophic_error_handler_was_called) {
@@ skipping 4048 matching lines @@
   ASSERT_TRUE(was_called);
 }
 
 // Verify that database corruption encountered during SaveChanges will trigger
 // the catastrohpic error handler.
 TEST_F(DirectoryBackingStoreTest,
        CatastrophicErrorHandler_InvocationDuringSaveChanges) {
   bool was_called = false;
   const base::Closure handler =
       base::Bind(&CatastrophicErrorHandler, &was_called);
-
   // Create a DB with many entries.
   scoped_ptr<OnDiskDirectoryBackingStoreForTest> dbs(
       new OnDiskDirectoryBackingStoreForTest(GetUsername(), GetDatabasePath()));
   dbs->SetCatastrophicErrorHandler(handler);
   ASSERT_TRUE(dbs->db_->has_error_callback());
   ASSERT_TRUE(LoadAndIgnoreReturnedData(dbs.get()));
   ASSERT_FALSE(dbs->DidFailFirstOpenAttempt());
   Directory::SaveChangesSnapshot snapshot;
-  const int num_entries = 4000;
-  for (int i = 0; i < num_entries; ++i) {
+  for (int i = 0; i < corruption_testing::kNumEntriesRequiredForCorruption;
+       ++i) {
     snapshot.dirty_metas.insert(CreateEntry(i).release());
   }
   ASSERT_TRUE(dbs->SaveChanges(snapshot));
-
-  // Corrupt the DB by write a bunch of zeros at the beginning.
-  {
-    // Because the file is already open for writing (see dbs above), it's
-    // important that we open it in a sharing compatible way for platforms that
-    // have the concept of shared/exclusive file access (e.g. Windows).
-    base::ScopedFILE db_file(base::OpenFile(GetDatabasePath(), "wb"));
-    ASSERT_TRUE(db_file.get());
-    const std::string zeros(4096, '\0');
-    ASSERT_EQ(1U, fwrite(zeros.data(), zeros.size(), 1, db_file.get()));
-  }
-
+  // Corrupt it.
+  ASSERT_TRUE(corruption_testing::CorruptDatabase(GetDatabasePath()));
   // Attempt to save all those entries again. See that it fails (because of the
   // corruption).
   //
-  // If this test fails because SaveChanges returned true, it may mean that you
-  // need to increase the number of entries written to the DB. Try increasing
-  // the value of num_entries above. The value needs to be large enough to force
-  // the underlying DB to be read from disk before writing. The value *may*
-  // depend on the underlying DB page size as well as the DB's cache_size
-  // PRAGMA.
+  // If this test fails because SaveChanges returned true, it may mean you need
+  // to increase the number of entries written to the DB. See also
+  // |kNumEntriesRequiredForCorruption|.
   ASSERT_FALSE(dbs->SaveChanges(snapshot));
   // At this point the handler has been posted but not executed.
   ASSERT_FALSE(was_called);
   // Pump the message loop and see that it is executed.
   base::RunLoop().RunUntilIdle();
   ASSERT_TRUE(was_called);
 }
 
 }  // namespace syncable
 }  // namespace syncer