src/chrome/browser/sync/glue/password_model_worker.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "chrome/browser/sync/glue/password_model_worker.h"
   6
   7 #include "base/bind.h"
   8 #include "base/memory/ref_counted.h"
   9 #include "base/synchronization/waitable_event.h"
  10 #include "components/password_manager/core/browser/password_store.h"
  11
  12 using base::WaitableEvent;
  13
  14 namespace browser_sync {
  15
  16 PasswordModelWorker::PasswordModelWorker(
  17     const scoped_refptr<password_manager::PasswordStore>& password_store,
  18     syncer::WorkerLoopDestructionObserver* observer)
  19     : syncer::ModelSafeWorker(observer), password_store_(password_store) {
  20   DCHECK(password_store.get());
  21 }
  22
  23 void PasswordModelWorker::RegisterForLoopDestruction() {
  24   base::AutoLock lock(password_store_lock_);
  25   password_store_->ScheduleTask(
  26       base::Bind(&PasswordModelWorker::RegisterForPasswordLoopDestruction,
  27                  this));
  28 }
  29
  30 syncer::SyncerError PasswordModelWorker::DoWorkAndWaitUntilDoneImpl(
  31     const syncer::WorkCallback& work) {
  32   syncer::SyncerError error = syncer::UNSET;
  33
  34   bool scheduled = false;
  35   {
  36     base::AutoLock lock(password_store_lock_);
  37     if (!password_store_.get())
  38       return syncer::CANNOT_DO_WORK;
  39
  40     scheduled = password_store_->ScheduleTask(
  41         base::Bind(&PasswordModelWorker::CallDoWorkAndSignalTask,
  42                    this, work, work_done_or_stopped(), &error));
  43   }
  44
  45   if (scheduled)
  46     work_done_or_stopped()->Wait();
  47   else
  48     error = syncer::CANNOT_DO_WORK;
  49   return error;
  50 }
  51
  52 syncer::ModelSafeGroup PasswordModelWorker::GetModelSafeGroup() {
  53   return syncer::GROUP_PASSWORD;
  54 }
  55
  56 PasswordModelWorker::~PasswordModelWorker() {}
  57
  58 void PasswordModelWorker::CallDoWorkAndSignalTask(
  59     const syncer::WorkCallback& work,
  60     WaitableEvent* done,
  61     syncer::SyncerError *error) {
  62   *error = work.Run();
  63   done->Signal();
  64 }
  65
  66 void PasswordModelWorker::RegisterForPasswordLoopDestruction() {
  67   base::MessageLoop::current()->AddDestructionObserver(this);
  68   SetWorkingLoopToCurrent();
  69 }
  70
  71 void PasswordModelWorker::RequestStop() {
  72   ModelSafeWorker::RequestStop();
  73
  74   base::AutoLock lock(password_store_lock_);
  75   password_store_ = NULL;
  76 }
  77
  78 }  // namespace browser_sync