Log operator code histogram on new metric log

chrome/browser/metrics/metrics_service_unittest.cc

 // Copyright (c) 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 "chrome/browser/metrics/metrics_service.h"
 
 #include <string>
 
 #include "base/command_line.h"
 #include "base/threading/platform_thread.h"
@@ skipping 117 matching lines @@
     return false;
   }
 
  private:
   content::TestBrowserThreadBundle thread_bundle_;
   ScopedTestingLocalState testing_local_state_;
 
   DISALLOW_COPY_AND_ASSIGN(MetricsServiceTest);
 };
 
+class TestMetricsServiceObserver : public MetricsServiceObserver {
+ public:
+  TestMetricsServiceObserver(): observed_(0) {}
+  virtual ~TestMetricsServiceObserver() {}
+
+  virtual void OnDidCreateMetricsLog() OVERRIDE {
+    ++observed_;
+  }
+  int observed() const { return observed_; }
+
+ private:
+  int observed_;
+
+  DISALLOW_COPY_AND_ASSIGN(TestMetricsServiceObserver);
+};
+
 }  // namespace
 
 TEST_F(MetricsServiceTest, IsPluginProcess) {
   EXPECT_TRUE(
       MetricsService::IsPluginProcess(content::PROCESS_TYPE_PLUGIN));
   EXPECT_TRUE(
       MetricsService::IsPluginProcess(content::PROCESS_TYPE_PPAPI_PLUGIN));
   EXPECT_FALSE(
       MetricsService::IsPluginProcess(content::PROCESS_TYPE_GPU));
 }
@@ skipping 149 matching lines @@
   GetLocalState()->SetBoolean(crash_pref, true);
   EXPECT_TRUE(MetricsServiceHelper::IsCrashReportingEnabled());
   GetLocalState()->ClearPref(crash_pref);
   EXPECT_FALSE(MetricsServiceHelper::IsCrashReportingEnabled());
 #endif  // !defined(OS_CHROMEOS)
 #else  // defined(GOOGLE_CHROME_BUILD)
   // Chromium branded browsers never have crash reporting enabled.
   EXPECT_FALSE(MetricsServiceHelper::IsCrashReportingEnabled());
 #endif  // defined(GOOGLE_CHROME_BUILD)
 }
+
+TEST_F(MetricsServiceTest, MetricsServiceObserver) {
+  MetricsService service;
+  TestMetricsServiceObserver observer1;
+  TestMetricsServiceObserver observer2;
+
+  service.AddObserver(&observer1);
+  EXPECT_EQ(0, observer1.observed());
+  EXPECT_EQ(0, observer2.observed());
+
+  service.OpenNewLog();
+  EXPECT_EQ(1, observer1.observed());
+  EXPECT_EQ(0, observer2.observed());
+  service.log_manager_.FinishCurrentLog();
+
+  service.AddObserver(&observer2);
+
+  service.OpenNewLog();
+  EXPECT_EQ(2, observer1.observed());
+  EXPECT_EQ(1, observer2.observed());
+  service.log_manager_.FinishCurrentLog();
+
+  service.RemoveObserver(&observer1);
+
+  service.OpenNewLog();
+  EXPECT_EQ(2, observer1.observed());
+  EXPECT_EQ(2, observer2.observed());
+  service.log_manager_.FinishCurrentLog();
+
+  service.RemoveObserver(&observer2);
+}