Control the frequency of fileBrowserPrivate.onFileTransfersUpdated events.

chrome/browser/chromeos/gdata/gdata_operation_registry_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/chromeos/gdata/gdata_operation_registry.h"
 
 #include "base/compiler_specific.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop.h"
 #include "content/public/test/test_browser_thread.h"
@@ skipping 110 matching lines @@
   GDataOperationRegistryTest()
       : ui_thread_(content::BrowserThread::UI, &message_loop_) {
   }
   MessageLoopForUI message_loop_;
   content::TestBrowserThread ui_thread_;
 };
 
 TEST_F(GDataOperationRegistryTest, OneSuccess) {
   TestObserver observer;
   GDataOperationRegistry registry;
+  registry.DisableNotificationFrequencyControlForTest();
   registry.AddObserver(&observer);
 
   base::WeakPtr<MockOperation> op1 =
       (new MockUploadOperation(&registry))->AsWeakPtr();
   EXPECT_CALL(*op1, DoCancel()).Times(0);
 
   EXPECT_EQ(0U, observer.status().size());
   op1->NotifyStart();
   EXPECT_THAT(observer.status(), ElementsAre(Progress(0, -1)));
   op1->NotifyProgress(0, 100);
   EXPECT_THAT(observer.status(), ElementsAre(Progress(0, 100)));
   op1->NotifyProgress(100, 100);
   EXPECT_THAT(observer.status(), ElementsAre(Progress(100, 100)));
   op1->NotifyFinish(GDataOperationRegistry::OPERATION_COMPLETED);
   // Contains one "COMPLETED" notification.
   EXPECT_THAT(observer.status(), ElementsAre(Progress(100, 100)));
   // Then it is removed.
   EXPECT_EQ(0U, registry.GetProgressStatusList().size());
   EXPECT_EQ(NULL, op1.get()); // deleted
 }
 
 TEST_F(GDataOperationRegistryTest, OneCancel) {
   TestObserver observer;
   GDataOperationRegistry registry;
+  registry.DisableNotificationFrequencyControlForTest();
   registry.AddObserver(&observer);
 
   base::WeakPtr<MockOperation> op1 =
       (new MockUploadOperation(&registry))->AsWeakPtr();
   EXPECT_CALL(*op1, DoCancel());
 
   EXPECT_EQ(0U, observer.status().size());
   op1->NotifyStart();
   EXPECT_THAT(observer.status(), ElementsAre(Progress(0, -1)));
   op1->NotifyProgress(0, 100);
   EXPECT_THAT(observer.status(), ElementsAre(Progress(0, 100)));
   registry.CancelAll();
   EXPECT_THAT(observer.status(), ElementsAre(Progress(0, 100)));
   EXPECT_EQ(0U, registry.GetProgressStatusList().size());
   EXPECT_EQ(NULL, op1.get()); // deleted
 }
 
 TEST_F(GDataOperationRegistryTest, TwoSuccess) {
   TestObserver observer;
   GDataOperationRegistry registry;
+  registry.DisableNotificationFrequencyControlForTest();
   registry.AddObserver(&observer);
 
   base::WeakPtr<MockOperation> op1 =
       (new MockUploadOperation(&registry))->AsWeakPtr();
   base::WeakPtr<MockOperation> op2 =
       (new MockDownloadOperation(&registry))->AsWeakPtr();
   EXPECT_CALL(*op1, DoCancel()).Times(0);
   EXPECT_CALL(*op2, DoCancel()).Times(0);
 
   EXPECT_EQ(0U, observer.status().size());
@@ skipping 12 matching lines @@
   op2->NotifyFinish(GDataOperationRegistry::OPERATION_COMPLETED);
   EXPECT_THAT(observer.status(), ElementsAre(Progress(0, 200)));
   EXPECT_EQ(0U, registry.GetProgressStatusList().size());
   EXPECT_EQ(NULL, op1.get()); // deleted
   EXPECT_EQ(NULL, op2.get()); // deleted
 }
 
 TEST_F(GDataOperationRegistryTest, ThreeCancel) {
   TestObserver observer;
   GDataOperationRegistry registry;
+  registry.DisableNotificationFrequencyControlForTest();
   registry.AddObserver(&observer);
 
   base::WeakPtr<MockOperation> op1 =
       (new MockUploadOperation(&registry))->AsWeakPtr();
   base::WeakPtr<MockOperation> op2 =
       (new MockDownloadOperation(&registry))->AsWeakPtr();
   base::WeakPtr<MockOperation> op3 =
       (new MockOtherOperation(&registry))->AsWeakPtr();
   EXPECT_CALL(*op1, DoCancel());
   EXPECT_CALL(*op2, DoCancel());
@@ skipping 10 matching lines @@
   EXPECT_EQ(1U, observer.status().size()); // holds the last one "COMPLETED"
   EXPECT_EQ(0U, registry.GetProgressStatusList().size());
   EXPECT_EQ(NULL, op1.get()); // deleted
   EXPECT_EQ(NULL, op2.get()); // deleted
   EXPECT_EQ(NULL, op3.get()); // deleted. CancelAll cares all operations.
 }
 
 TEST_F(GDataOperationRegistryTest, RestartOperation) {
   TestObserver observer;
   GDataOperationRegistry registry;
+  registry.DisableNotificationFrequencyControlForTest();
   registry.AddObserver(&observer);
 
   base::WeakPtr<MockOperation> op1 =
       (new MockUploadOperation(&registry))->AsWeakPtr();
   EXPECT_CALL(*op1, DoCancel()).Times(0);
 
   op1->NotifyStart();
   EXPECT_EQ(1U, registry.GetProgressStatusList().size());
   op1->NotifyStart(); // restart
   EXPECT_EQ(1U, registry.GetProgressStatusList().size());
   op1->NotifyProgress(0, 200);
   op1->NotifyFinish(GDataOperationRegistry::OPERATION_COMPLETED);
   EXPECT_EQ(0U, registry.GetProgressStatusList().size());
   EXPECT_EQ(NULL, op1.get()); // deleted
 }
 
 }  // namespace gdata