Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(449)

Side by Side Diff: chrome/browser/sync/glue/browser_thread_model_worker.cc

Issue 8366030: Introduce the plumbing necessary to report Unrecoverable error from model safe workers. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: For try jobs. Created 9 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "chrome/browser/sync/glue/browser_thread_model_worker.h" 5 #include "chrome/browser/sync/glue/browser_thread_model_worker.h"
6 6
7 #include "base/synchronization/waitable_event.h" 7 #include "base/synchronization/waitable_event.h"
8 #include "content/browser/browser_thread.h" 8 #include "content/browser/browser_thread.h"
9 9
10 using base::WaitableEvent; 10 using base::WaitableEvent;
11 11
12 namespace browser_sync { 12 namespace browser_sync {
13 13
14 BrowserThreadModelWorker::BrowserThreadModelWorker( 14 BrowserThreadModelWorker::BrowserThreadModelWorker(
15 BrowserThread::ID thread, ModelSafeGroup group) 15 BrowserThread::ID thread, ModelSafeGroup group)
16 : thread_(thread), group_(group) {} 16 : thread_(thread), group_(group) {}
17 17
18 BrowserThreadModelWorker::~BrowserThreadModelWorker() {} 18 BrowserThreadModelWorker::~BrowserThreadModelWorker() {}
19 19
20 void BrowserThreadModelWorker::DoWorkAndWaitUntilDone(Callback0::Type* work) { 20 UnrecoverableErrorInfo BrowserThreadModelWorker::DoWorkAndWaitUntilDone(
21 const WorkCallback& work) {
22 UnrecoverableErrorInfo error_info;
21 if (BrowserThread::CurrentlyOn(thread_)) { 23 if (BrowserThread::CurrentlyOn(thread_)) {
22 DLOG(WARNING) << "Already on thread " << thread_; 24 DLOG(WARNING) << "Already on thread " << thread_;
23 work->Run(); 25 return work.Run();
24 return;
25 } 26 }
26 WaitableEvent done(false, false); 27 WaitableEvent done(false, false);
27 if (!BrowserThread::PostTask( 28 if (!BrowserThread::PostTask(
28 thread_, 29 thread_,
29 FROM_HERE, 30 FROM_HERE,
30 NewRunnableMethod( 31 NewRunnableMethod(
31 this, 32 this,
32 &BrowserThreadModelWorker::CallDoWorkAndSignalTask, 33 &BrowserThreadModelWorker::CallDoWorkAndSignalTask,
33 work, 34 work,
34 &done))) { 35 &done,
36 &error_info))) {
35 NOTREACHED() << "Failed to post task to thread " << thread_; 37 NOTREACHED() << "Failed to post task to thread " << thread_;
36 return; 38 return error_info;
37 } 39 }
38 done.Wait(); 40 done.Wait();
41 return error_info;
39 } 42 }
40 43
41 void BrowserThreadModelWorker::CallDoWorkAndSignalTask( 44 void BrowserThreadModelWorker::CallDoWorkAndSignalTask(
42 Callback0::Type* work, WaitableEvent* done) { 45 const WorkCallback& work,
46 WaitableEvent* done,
47 UnrecoverableErrorInfo* error_info) {
43 DCHECK(BrowserThread::CurrentlyOn(thread_)); 48 DCHECK(BrowserThread::CurrentlyOn(thread_));
44 work->Run(); 49 *error_info = work.Run();
45 done->Signal(); 50 done->Signal();
46 } 51 }
47 52
48 ModelSafeGroup BrowserThreadModelWorker::GetModelSafeGroup() { 53 ModelSafeGroup BrowserThreadModelWorker::GetModelSafeGroup() {
49 return group_; 54 return group_;
50 } 55 }
51 56
52 DatabaseModelWorker::DatabaseModelWorker() 57 DatabaseModelWorker::DatabaseModelWorker()
53 : BrowserThreadModelWorker(BrowserThread::DB, GROUP_DB) {} 58 : BrowserThreadModelWorker(BrowserThread::DB, GROUP_DB) {}
54 59
55 DatabaseModelWorker::~DatabaseModelWorker() {} 60 DatabaseModelWorker::~DatabaseModelWorker() {}
56 61
57 void DatabaseModelWorker::CallDoWorkAndSignalTask( 62 void DatabaseModelWorker::CallDoWorkAndSignalTask(
58 Callback0::Type* work, WaitableEvent* done) { 63 const WorkCallback& work,
59 BrowserThreadModelWorker::CallDoWorkAndSignalTask(work, done); 64 WaitableEvent* done,
65 UnrecoverableErrorInfo* error_info) {
66 BrowserThreadModelWorker::CallDoWorkAndSignalTask(work, done, error_info);
60 } 67 }
61 68
62 FileModelWorker::FileModelWorker() 69 FileModelWorker::FileModelWorker()
63 : BrowserThreadModelWorker(BrowserThread::FILE, GROUP_FILE) {} 70 : BrowserThreadModelWorker(BrowserThread::FILE, GROUP_FILE) {}
64 71
65 FileModelWorker::~FileModelWorker() {} 72 FileModelWorker::~FileModelWorker() {}
66 73
67 void FileModelWorker::CallDoWorkAndSignalTask( 74 void FileModelWorker::CallDoWorkAndSignalTask(
68 Callback0::Type* work, WaitableEvent* done) { 75 const WorkCallback& work,
69 BrowserThreadModelWorker::CallDoWorkAndSignalTask(work, done); 76 WaitableEvent* done,
77 UnrecoverableErrorInfo* error_info) {
78 BrowserThreadModelWorker::CallDoWorkAndSignalTask(work, done, error_info);
70 } 79 }
71 80
72 } // namespace browser_sync 81 } // namespace browser_sync
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698