| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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/webdata/web_data_service.h" | 5 #include "chrome/browser/webdata/web_data_service.h" |
| 6 | 6 |
| 7 #include "base/message_loop.h" | 7 #include "base/message_loop.h" |
| 8 #include "base/stl_util-inl.h" | 8 #include "base/stl_util-inl.h" |
| 9 #include "base/task.h" | 9 #include "base/task.h" |
| 10 #include "base/threading/thread.h" | 10 #include "base/threading/thread.h" |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 66 | 66 |
| 67 bool WebDataService::IsRunning() const { | 67 bool WebDataService::IsRunning() const { |
| 68 return is_running_; | 68 return is_running_; |
| 69 } | 69 } |
| 70 | 70 |
| 71 void WebDataService::UnloadDatabase() { | 71 void WebDataService::UnloadDatabase() { |
| 72 ScheduleTask(NewRunnableMethod(this, &WebDataService::ShutdownDatabase)); | 72 ScheduleTask(NewRunnableMethod(this, &WebDataService::ShutdownDatabase)); |
| 73 } | 73 } |
| 74 | 74 |
| 75 void WebDataService::CancelRequest(Handle h) { | 75 void WebDataService::CancelRequest(Handle h) { |
| 76 AutoLock l(pending_lock_); | 76 base::AutoLock l(pending_lock_); |
| 77 RequestMap::iterator i = pending_requests_.find(h); | 77 RequestMap::iterator i = pending_requests_.find(h); |
| 78 if (i == pending_requests_.end()) { | 78 if (i == pending_requests_.end()) { |
| 79 NOTREACHED() << "Canceling a nonexistent web data service request"; | 79 NOTREACHED() << "Canceling a nonexistent web data service request"; |
| 80 return; | 80 return; |
| 81 } | 81 } |
| 82 i->second->Cancel(); | 82 i->second->Cancel(); |
| 83 } | 83 } |
| 84 | 84 |
| 85 bool WebDataService::IsDatabaseLoaded() { | 85 bool WebDataService::IsDatabaseLoaded() { |
| 86 return db_ != NULL; | 86 return db_ != NULL; |
| (...skipping 453 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 540 static_cast<const WDResult<std::vector<CreditCard*> >*>(result); | 540 static_cast<const WDResult<std::vector<CreditCard*> >*>(result); |
| 541 | 541 |
| 542 std::vector<CreditCard*> credit_cards = r->GetValue(); | 542 std::vector<CreditCard*> credit_cards = r->GetValue(); |
| 543 STLDeleteElements(&credit_cards); | 543 STLDeleteElements(&credit_cards); |
| 544 } | 544 } |
| 545 } | 545 } |
| 546 } | 546 } |
| 547 } | 547 } |
| 548 | 548 |
| 549 void WebDataService::RegisterRequest(WebDataRequest* request) { | 549 void WebDataService::RegisterRequest(WebDataRequest* request) { |
| 550 AutoLock l(pending_lock_); | 550 base::AutoLock l(pending_lock_); |
| 551 pending_requests_[request->GetHandle()] = request; | 551 pending_requests_[request->GetHandle()] = request; |
| 552 } | 552 } |
| 553 | 553 |
| 554 //////////////////////////////////////////////////////////////////////////////// | 554 //////////////////////////////////////////////////////////////////////////////// |
| 555 // | 555 // |
| 556 // The following methods are executed in Chrome_WebDataThread. | 556 // The following methods are executed in Chrome_WebDataThread. |
| 557 // | 557 // |
| 558 //////////////////////////////////////////////////////////////////////////////// | 558 //////////////////////////////////////////////////////////////////////////////// |
| 559 | 559 |
| 560 void WebDataService::DBInitFailed(sql::InitStatus init_status) { | 560 void WebDataService::DBInitFailed(sql::InitStatus init_status) { |
| (...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 630 } | 630 } |
| 631 | 631 |
| 632 void WebDataService::ScheduleCommit() { | 632 void WebDataService::ScheduleCommit() { |
| 633 if (should_commit_ == false) { | 633 if (should_commit_ == false) { |
| 634 should_commit_ = true; | 634 should_commit_ = true; |
| 635 ScheduleTask(NewRunnableMethod(this, &WebDataService::Commit)); | 635 ScheduleTask(NewRunnableMethod(this, &WebDataService::Commit)); |
| 636 } | 636 } |
| 637 } | 637 } |
| 638 | 638 |
| 639 int WebDataService::GetNextRequestHandle() { | 639 int WebDataService::GetNextRequestHandle() { |
| 640 AutoLock l(pending_lock_); | 640 base::AutoLock l(pending_lock_); |
| 641 return ++next_request_handle_; | 641 return ++next_request_handle_; |
| 642 } | 642 } |
| 643 | 643 |
| 644 //////////////////////////////////////////////////////////////////////////////// | 644 //////////////////////////////////////////////////////////////////////////////// |
| 645 // | 645 // |
| 646 // Keywords implementation. | 646 // Keywords implementation. |
| 647 // | 647 // |
| 648 //////////////////////////////////////////////////////////////////////////////// | 648 //////////////////////////////////////////////////////////////////////////////// |
| 649 | 649 |
| 650 void WebDataService::AddKeywordImpl(GenericRequest<TemplateURL>* request) { | 650 void WebDataService::AddKeywordImpl(GenericRequest<TemplateURL>* request) { |
| (...skipping 624 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1275 return result_; | 1275 return result_; |
| 1276 } | 1276 } |
| 1277 | 1277 |
| 1278 void WebDataService::WebDataRequest::RequestComplete() { | 1278 void WebDataService::WebDataRequest::RequestComplete() { |
| 1279 WebDataService* s = service_; | 1279 WebDataService* s = service_; |
| 1280 Task* t = NewRunnableMethod(s, | 1280 Task* t = NewRunnableMethod(s, |
| 1281 &WebDataService::RequestCompleted, | 1281 &WebDataService::RequestCompleted, |
| 1282 handle_); | 1282 handle_); |
| 1283 message_loop_->PostTask(FROM_HERE, t); | 1283 message_loop_->PostTask(FROM_HERE, t); |
| 1284 } | 1284 } |
| OLD | NEW |