sync: Refactor per-datatype throttling

sync/engine/sync_scheduler_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 "base/bind.h"
 #include "base/callback.h"
 #include "base/compiler_specific.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop.h"
 #include "base/test/test_timeouts.h"
+#include "sync/engine/throttled_data_type_tracker.h"
 #include "sync/engine/sync_scheduler.h"
 #include "sync/engine/syncer.h"
 #include "sync/sessions/test_util.h"
 #include "sync/test/engine/fake_model_safe_worker_registrar.h"
 #include "sync/test/engine/mock_connection_manager.h"
 #include "sync/test/engine/test_directory_setter_upper.h"
 #include "sync/test/fake_extensions_activity_monitor.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
@@ skipping 70 matching lines @@
     routing_info[syncable::BOOKMARKS] = GROUP_UI;
     routing_info[syncable::AUTOFILL] = GROUP_DB;
     routing_info[syncable::THEMES] = GROUP_UI;
     routing_info[syncable::NIGORI] = GROUP_PASSIVE;
     registrar_.reset(new FakeModelSafeWorkerRegistrar(routing_info));
     connection_.reset(new MockConnectionManager(directory()));
     connection_->SetServerReachable();
     context_ = new SyncSessionContext(
         connection_.get(), directory(), registrar_.get(),
         &extensions_activity_monitor_,
+        &throttled_data_type_tracker_,
         std::vector<SyncEngineEventListener*>(), NULL, NULL);
     context_->set_notifications_enabled(true);
     context_->set_account_name("Test");
     scheduler_.reset(
         new SyncScheduler("TestSyncScheduler", context_, syncer_));
   }
 
   SyncScheduler* scheduler() { return scheduler_.get(); }
   MockSyncer* syncer() { return syncer_; }
   MockDelayProvider* delay() { return delay_; }
@@ skipping 84 matching lines @@
   base::WeakPtrFactory<SyncSchedulerTest> weak_ptr_factory_;
   MessageLoop message_loop_;
   TestDirectorySetterUpper dir_maker_;
   scoped_ptr<SyncScheduler> scheduler_;
   scoped_ptr<MockConnectionManager> connection_;
   SyncSessionContext* context_;
   MockSyncer* syncer_;
   MockDelayProvider* delay_;
   scoped_ptr<FakeModelSafeWorkerRegistrar> registrar_;
   FakeExtensionsActivityMonitor extensions_activity_monitor_;
+  ThrottledDataTypeTracker throttled_data_type_tracker_;
 };
 
 class BackoffTriggersSyncSchedulerTest : public SyncSchedulerTest {
   void SetUp() {
     SyncSchedulerTest::SetUp();
     UseMockDelayProvider();
     EXPECT_CALL(*delay(), GetDelay(_))
         .WillRepeatedly(Return(TimeDelta::FromMilliseconds(1)));
   }
 
@@ skipping 940 matching lines @@
   PumpLoop();
   // Pump again to run job.
   PumpLoop();
 
   StopSyncScheduler();
 
   EXPECT_TRUE(expected == context()->previous_session_routing_info());
 }
 
 }  // namespace browser_sync