Worker changes to prepare for lock-free shutdown.

chrome/browser/sync/glue/sync_backend_registrar.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/sync/glue/sync_backend_registrar.h"
 
 #include <cstddef>
 
 #include "base/compiler_specific.h"
 #include "base/logging.h"
@@ skipping 41 matching lines @@
 }
 
 }  // namespace
 
 SyncBackendRegistrar::SyncBackendRegistrar(
     const std::string& name, Profile* profile,
     MessageLoop* sync_loop) :
     name_(name),
     profile_(profile),
     sync_loop_(sync_loop),
-    ui_worker_(new UIModelWorker()),
+    ui_worker_(new UIModelWorker(this)),
     stopped_on_ui_thread_(false) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   CHECK(profile_);
   DCHECK(sync_loop_);
-  workers_[syncer::GROUP_DB] = new DatabaseModelWorker();
-  workers_[syncer::GROUP_FILE] = new FileModelWorker();
+  workers_[syncer::GROUP_DB] = new DatabaseModelWorker(this);
+  workers_[syncer::GROUP_FILE] = new FileModelWorker(this);
   workers_[syncer::GROUP_UI] = ui_worker_;
-  workers_[syncer::GROUP_PASSIVE] = new syncer::PassiveModelWorker(sync_loop_);
+  workers_[syncer::GROUP_PASSIVE] = new syncer::PassiveModelWorker(sync_loop_,
+                                                                   this);
 
   HistoryService* history_service =
       HistoryServiceFactory::GetForProfile(profile, Profile::IMPLICIT_ACCESS);
   if (history_service) {
     workers_[syncer::GROUP_HISTORY] =
-        new HistoryModelWorker(history_service->AsWeakPtr());
+        new HistoryModelWorker(history_service->AsWeakPtr(), this);
   }
 
   scoped_refptr<PasswordStore> password_store =
       PasswordStoreFactory::GetForProfile(profile, Profile::IMPLICIT_ACCESS);
   if (password_store) {
-    workers_[syncer::GROUP_PASSWORD] = new PasswordModelWorker(password_store);
+    workers_[syncer::GROUP_PASSWORD] = new PasswordModelWorker(password_store,
+                                                               this);
   }
 }
 
 void SyncBackendRegistrar::SetInitialTypes(syncer::ModelTypeSet initial_types) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   base::AutoLock lock(lock_);
 
   // This function should be called only once, shortly after construction.  The
   // routing info at that point is expected to be emtpy.
   DCHECK(routing_info_.empty());
@@ skipping 195 matching lines @@
   return it->second;
 }
 
 bool SyncBackendRegistrar::IsCurrentThreadSafeForModel(
     syncer::ModelType model_type) const {
   lock_.AssertAcquired();
   return IsOnThreadForGroup(model_type,
                             GetGroupForModelType(model_type, routing_info_));
 }
 
+void SyncBackendRegistrar::OnWorkerLoopDestroyed(syncer::ModelSafeGroup group) {
+  // Do nothing for now.
+}
+
 }  // namespace browser_sync