components/password_manager/sync/browser/password_model_worker.cc

   1 // Copyright (c) 2015 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 "components/password_manager/sync/browser/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(base::Bind(
  26       &PasswordModelWorker::RegisterForPasswordLoopDestruction, this));
  27 }
  28
  29 syncer::SyncerError PasswordModelWorker::DoWorkAndWaitUntilDoneImpl(
  30     const syncer::WorkCallback& work) {
  31   syncer::SyncerError error = syncer::UNSET;
  32
  33   bool scheduled = false;
  34   {
  35     base::AutoLock lock(password_store_lock_);
  36     if (!password_store_.get())
  37       return syncer::CANNOT_DO_WORK;
  38
  39     scheduled = password_store_->ScheduleTask(
  40         base::Bind(&PasswordModelWorker::CallDoWorkAndSignalTask, this, work,
  41                    work_done_or_stopped(), &error));
  42   }
  43
  44   if (scheduled)
  45     work_done_or_stopped()->Wait();
  46   else
  47     error = syncer::CANNOT_DO_WORK;
  48   return error;
  49 }
  50
  51 syncer::ModelSafeGroup PasswordModelWorker::GetModelSafeGroup() {
  52   return syncer::GROUP_PASSWORD;
  53 }
  54
  55 PasswordModelWorker::~PasswordModelWorker() {}
  56
  57 void PasswordModelWorker::CallDoWorkAndSignalTask(
  58     const syncer::WorkCallback& work,
  59     WaitableEvent* done,
  60     syncer::SyncerError* error) {
  61   *error = work.Run();
  62   done->Signal();
  63 }
  64
  65 void PasswordModelWorker::RegisterForPasswordLoopDestruction() {
  66   SetWorkingLoopToCurrent();
  67 }
  68
  69 void PasswordModelWorker::RequestStop() {
  70   ModelSafeWorker::RequestStop();
  71
  72   base::AutoLock lock(password_store_lock_);
  73   password_store_ = NULL;
  74 }
  75
  76 }  // namespace browser_sync