[SyncFS] Introduce counters in LevelDBWrapper

chrome/browser/sync_file_system/drive_backend/leveldb_wrapper_unittest.cc

 // Copyright 2014 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 "chrome/browser/sync_file_system/drive_backend/leveldb_wrapper.h"
 
 #include <string>
 
 #include "base/files/scoped_temp_dir.h"
 #include "base/logging.h"
@@ skipping 110 matching lines @@
 
   itr->Delete();
   EXPECT_TRUE(itr->Valid());
   EXPECT_EQ("ab", itr->key().ToString());
   EXPECT_EQ("0", itr->value().ToString());
 
   itr->SeekToFirst();
   EXPECT_TRUE(itr->Valid());
   EXPECT_EQ("ab", itr->key().ToString());
   EXPECT_EQ("0", itr->value().ToString());
+
+  EXPECT_EQ(0, GetDB()->num_puts());
+  EXPECT_EQ(1, GetDB()->num_deletes());
 }
 
 TEST_F(LevelDBWrapperTest, Iterator2Test) {
   GetDB()->Put("a", "1");
   GetDB()->Put("b", "2");
   GetDB()->Put("c", "3");
   // Keep pending transanctions on memory.
 
   scoped_ptr<LevelDBWrapper::Iterator> itr = GetDB()->NewIterator();
 
   std::string prev_key;
   std::string prev_value;
   int loop_counter = 0;
   for (itr->SeekToFirst(); itr->Valid(); itr->Next()) {
     ASSERT_NE(prev_key, itr->key().ToString());
     ASSERT_NE(prev_value, itr->value().ToString());
     prev_key = itr->key().ToString();
     prev_value = itr->value().ToString();
     ++loop_counter;
   }
   EXPECT_EQ(3, loop_counter);
   EXPECT_EQ("c", prev_key);
   EXPECT_EQ("3", prev_value);
+
+

[nhiroki, 2014/08/14 08:59:30]

nit: extra blank line

[peria, 2014/08/14 09:01:53]

Done.

+  EXPECT_EQ(3, GetDB()->num_puts());
+  EXPECT_EQ(0, GetDB()->num_deletes());
 }
 
 TEST_F(LevelDBWrapperTest, PutTest) {
   TestData merged_data[] = {{"a", "1"}, {"aa", "new0"}, {"ab", "0"},
                             {"bb", "new2"}, {"c", "new1"}, {"d", "4"}};
   TestData orig_data[] = {{"a", "1"}, {"ab", "0"}, {"bb", "3"}, {"d", "4"}};
 
   CreateDefaultDatabase();
 
   // Add pending transactions.
   GetDB()->Put("aa", "new0");
   GetDB()->Put("c", "new1");
   GetDB()->Put("bb", "new2");  // Overwrite an entry.
 
   SCOPED_TRACE("PutTest_Pending");
   CheckDBContents(merged_data, arraysize(merged_data));
 
+

[nhiroki, 2014/08/14 08:59:30]

nit: ditto.

[peria, 2014/08/14 09:01:53]

Done.

+  EXPECT_EQ(3, GetDB()->num_puts());
   // Remove all pending transactions.
   GetDB()->Clear();
+  EXPECT_EQ(0, GetDB()->num_puts());
 
   SCOPED_TRACE("PutTest_Clear");
   CheckDBContents(orig_data, arraysize(orig_data));
 
   // Add pending transactions again, with commiting.
   GetDB()->Put("aa", "new0");
   GetDB()->Put("c", "new1");
   GetDB()->Put("bb", "new2");
+  EXPECT_EQ(3, GetDB()->num_puts());
   GetDB()->Commit();
+  EXPECT_EQ(0, GetDB()->num_puts());
   GetDB()->Clear();  // Clear just in case.
 
   SCOPED_TRACE("PutTest_Commit");
   CheckDBContents(merged_data, arraysize(merged_data));
 }
 
 TEST_F(LevelDBWrapperTest, DeleteTest) {
   TestData merged_data[] = {{"a", "1"}, {"aa", "new0"}, {"bb", "new2"},
                             {"d", "4"}};
   TestData orig_data[] = {{"a", "1"}, {"ab", "0"}, {"bb", "3"}, {"d", "4"}};
 
   CreateDefaultDatabase();
 
   // Add pending transactions.
   GetDB()->Put("aa", "new0");
   GetDB()->Put("c", "new1");
   GetDB()->Put("bb", "new2");  // Overwrite an entry.
   GetDB()->Delete("c");        // Remove a pending entry.
   GetDB()->Delete("ab");       // Remove a committed entry.
 
+  EXPECT_EQ(3, GetDB()->num_puts());
+  EXPECT_EQ(2, GetDB()->num_deletes());
+
   SCOPED_TRACE("DeleteTest_Pending");
   CheckDBContents(merged_data, arraysize(merged_data));
 
   // Remove all pending transactions.
   GetDB()->Clear();
 
   SCOPED_TRACE("DeleteTest_Clear");
   CheckDBContents(orig_data, arraysize(orig_data));
 
   // Add pending transactions again, with commiting.
   GetDB()->Put("aa", "new0");
   GetDB()->Put("c", "new1");
   GetDB()->Put("bb", "new2");
   GetDB()->Delete("c");
   GetDB()->Delete("ab");
   GetDB()->Commit();
   GetDB()->Clear();
 
+  EXPECT_EQ(0, GetDB()->num_puts());
+  EXPECT_EQ(0, GetDB()->num_deletes());
+
   SCOPED_TRACE("DeleteTest_Commit");
   CheckDBContents(merged_data, arraysize(merged_data));
 }
 
 }  // namespace drive_backend
 }  // namespace sync_file_system