| Index: components/webdata/common/web_database_service.cc
|
| ===================================================================
|
| --- components/webdata/common/web_database_service.cc (revision 242728)
|
| +++ components/webdata/common/web_database_service.cc (working copy)
|
| @@ -43,9 +43,9 @@
|
| const scoped_refptr<base::MessageLoopProxy>& db_thread)
|
| : base::RefCountedDeleteOnMessageLoop<WebDatabaseService>(ui_thread),
|
| path_(path),
|
| - weak_ptr_factory_(this),
|
| db_loaded_(false),
|
| - db_thread_(db_thread) {
|
| + db_thread_(db_thread),
|
| + weak_ptr_factory_(this) {
|
| // WebDatabaseService should be instantiated on UI thread.
|
| DCHECK(ui_thread->BelongsToCurrentThread());
|
| // WebDatabaseService requires DB thread if instantiated.
|
| @@ -56,7 +56,7 @@
|
| }
|
|
|
| void WebDatabaseService::AddTable(scoped_ptr<WebDatabaseTable> table) {
|
| - if (!wds_backend_.get()) {
|
| + if (!wds_backend_) {
|
| wds_backend_ = new WebDataServiceBackend(
|
| path_, new BackendDelegate(weak_ptr_factory_.GetWeakPtr()),
|
| db_thread_);
|
| @@ -65,8 +65,7 @@
|
| }
|
|
|
| void WebDatabaseService::LoadDatabase() {
|
| - DCHECK(wds_backend_.get());
|
| -
|
| + DCHECK(wds_backend_);
|
| db_thread_->PostTask(
|
| FROM_HERE,
|
| Bind(&WebDataServiceBackend::InitDatabase, wds_backend_));
|
| @@ -74,19 +73,19 @@
|
|
|
| void WebDatabaseService::UnloadDatabase() {
|
| db_loaded_ = false;
|
| - if (!wds_backend_.get())
|
| + if (!wds_backend_)
|
| return;
|
| db_thread_->PostTask(FROM_HERE,
|
| - Bind(&WebDataServiceBackend::ShutdownDatabase,
|
| - wds_backend_, true));
|
| + Bind(&WebDataServiceBackend::ShutdownDatabase,
|
| + wds_backend_, true));
|
| }
|
|
|
| void WebDatabaseService::ShutdownDatabase() {
|
| db_loaded_ = false;
|
| - weak_ptr_factory_.InvalidateWeakPtrs();
|
| loaded_callbacks_.clear();
|
| error_callbacks_.clear();
|
| - if (!wds_backend_.get())
|
| + weak_ptr_factory_.InvalidateWeakPtrs();
|
| + if (!wds_backend_)
|
| return;
|
| db_thread_->PostTask(FROM_HERE,
|
| Bind(&WebDataServiceBackend::ShutdownDatabase,
|
| @@ -95,9 +94,7 @@
|
|
|
| WebDatabase* WebDatabaseService::GetDatabaseOnDB() const {
|
| DCHECK(db_thread_->BelongsToCurrentThread());
|
| - if (!wds_backend_.get())
|
| - return NULL;
|
| - return wds_backend_->database();
|
| + return wds_backend_ ? wds_backend_->database() : NULL;
|
| }
|
|
|
| scoped_refptr<WebDataServiceBackend> WebDatabaseService::GetBackend() const {
|
| @@ -107,17 +104,12 @@
|
| void WebDatabaseService::ScheduleDBTask(
|
| const tracked_objects::Location& from_here,
|
| const WriteTask& task) {
|
| - if (!wds_backend_.get()) {
|
| - NOTREACHED() << "Task scheduled after Shutdown()";
|
| - return;
|
| - }
|
| -
|
| + DCHECK(wds_backend_);
|
| scoped_ptr<WebDataRequest> request(
|
| new WebDataRequest(NULL, wds_backend_->request_manager().get()));
|
| -
|
| db_thread_->PostTask(from_here,
|
| - Bind(&WebDataServiceBackend::DBWriteTaskWrapper, wds_backend_,
|
| - task, base::Passed(&request)));
|
| + Bind(&WebDataServiceBackend::DBWriteTaskWrapper,
|
| + wds_backend_, task, base::Passed(&request)));
|
| }
|
|
|
| WebDataServiceBase::Handle WebDatabaseService::ScheduleDBTaskWithResult(
|
| @@ -125,26 +117,18 @@
|
| const ReadTask& task,
|
| WebDataServiceConsumer* consumer) {
|
| DCHECK(consumer);
|
| - WebDataServiceBase::Handle handle = 0;
|
| -
|
| - if (!wds_backend_.get()) {
|
| - NOTREACHED() << "Task scheduled after Shutdown()";
|
| - return handle;
|
| - }
|
| -
|
| + DCHECK(wds_backend_);
|
| scoped_ptr<WebDataRequest> request(
|
| new WebDataRequest(consumer, wds_backend_->request_manager().get()));
|
| - handle = request->GetHandle();
|
| -
|
| + WebDataServiceBase::Handle handle = request->GetHandle();
|
| db_thread_->PostTask(from_here,
|
| - Bind(&WebDataServiceBackend::DBReadTaskWrapper, wds_backend_,
|
| - task, base::Passed(&request)));
|
| -
|
| + Bind(&WebDataServiceBackend::DBReadTaskWrapper,
|
| + wds_backend_, task, base::Passed(&request)));
|
| return handle;
|
| }
|
|
|
| void WebDatabaseService::CancelRequest(WebDataServiceBase::Handle h) {
|
| - if (!wds_backend_.get())
|
| + if (!wds_backend_)
|
| return;
|
| wds_backend_->request_manager()->CancelRequest(h);
|
| }
|
|
|