OLD | NEW |
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/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.h" | 8 #include "base/stl_util.h" |
9 #include "base/task.h" | 9 #include "base/task.h" |
10 #include "base/threading/thread.h" | 10 #include "base/threading/thread.h" |
(...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
214 request)); | 214 request)); |
215 return request->GetHandle(); | 215 return request->GetHandle(); |
216 } | 216 } |
217 | 217 |
218 ////////////////////////////////////////////////////////////////////////////// | 218 ////////////////////////////////////////////////////////////////////////////// |
219 // | 219 // |
220 // Web Intents. | 220 // Web Intents. |
221 // | 221 // |
222 ////////////////////////////////////////////////////////////////////////////// | 222 ////////////////////////////////////////////////////////////////////////////// |
223 | 223 |
224 void WebDataService::AddWebIntent(const WebIntentData& intent) { | 224 void WebDataService::AddWebIntent(const WebIntentServiceData& service) { |
225 GenericRequest<WebIntentData>* request = new GenericRequest<WebIntentData>( | 225 GenericRequest<WebIntentServiceData>* request = |
226 this, GetNextRequestHandle(), NULL, intent); | 226 new GenericRequest<WebIntentServiceData>( |
| 227 this, GetNextRequestHandle(), NULL, service); |
227 RegisterRequest(request); | 228 RegisterRequest(request); |
228 ScheduleTask(NewRunnableMethod(this, &WebDataService::AddWebIntentImpl, | 229 ScheduleTask(NewRunnableMethod(this, &WebDataService::AddWebIntentImpl, |
229 request)); | 230 request)); |
230 } | 231 } |
231 | 232 |
232 void WebDataService::RemoveWebIntent(const WebIntentData& intent) { | 233 void WebDataService::RemoveWebIntent(const WebIntentServiceData& service) { |
233 GenericRequest<WebIntentData>* request = new GenericRequest<WebIntentData>( | 234 GenericRequest<WebIntentServiceData>* request = |
234 this, GetNextRequestHandle(), NULL, intent); | 235 new GenericRequest<WebIntentServiceData>( |
| 236 this, GetNextRequestHandle(), NULL, service); |
235 RegisterRequest(request); | 237 RegisterRequest(request); |
236 ScheduleTask(NewRunnableMethod(this, &WebDataService::RemoveWebIntentImpl, | 238 ScheduleTask(NewRunnableMethod(this, &WebDataService::RemoveWebIntentImpl, |
237 request)); | 239 request)); |
238 } | 240 } |
239 | 241 |
240 WebDataService::Handle WebDataService::GetWebIntents(const string16& action, | 242 WebDataService::Handle WebDataService::GetWebIntents(const string16& action, |
241 WebDataServiceConsumer* consumer) { | 243 WebDataServiceConsumer* consumer) { |
242 DCHECK(consumer); | 244 DCHECK(consumer); |
243 GenericRequest<string16>* request = new GenericRequest<string16>( | 245 GenericRequest<string16>* request = new GenericRequest<string16>( |
244 this, GetNextRequestHandle(), consumer, action); | 246 this, GetNextRequestHandle(), consumer, action); |
(...skipping 589 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
834 request->RequestComplete(); | 836 request->RequestComplete(); |
835 } | 837 } |
836 | 838 |
837 //////////////////////////////////////////////////////////////////////////////// | 839 //////////////////////////////////////////////////////////////////////////////// |
838 // | 840 // |
839 // Web Intents implementation. | 841 // Web Intents implementation. |
840 // | 842 // |
841 //////////////////////////////////////////////////////////////////////////////// | 843 //////////////////////////////////////////////////////////////////////////////// |
842 | 844 |
843 void WebDataService::RemoveWebIntentImpl( | 845 void WebDataService::RemoveWebIntentImpl( |
844 GenericRequest<WebIntentData>* request) { | 846 GenericRequest<WebIntentServiceData>* request) { |
845 InitializeDatabaseIfNecessary(); | 847 InitializeDatabaseIfNecessary(); |
846 if (db_ && !request->IsCancelled(NULL)) { | 848 if (db_ && !request->IsCancelled(NULL)) { |
847 const WebIntentData& intent = request->arg(); | 849 const WebIntentServiceData& service = request->arg(); |
848 db_->GetWebIntentsTable()->RemoveWebIntent(intent); | 850 db_->GetWebIntentsTable()->RemoveWebIntent(service); |
849 ScheduleCommit(); | 851 ScheduleCommit(); |
850 } | 852 } |
851 request->RequestComplete(); | 853 request->RequestComplete(); |
852 } | 854 } |
853 | 855 |
854 void WebDataService::AddWebIntentImpl(GenericRequest<WebIntentData>* request) { | 856 void WebDataService::AddWebIntentImpl( |
| 857 GenericRequest<WebIntentServiceData>* request) { |
855 InitializeDatabaseIfNecessary(); | 858 InitializeDatabaseIfNecessary(); |
856 if (db_ && !request->IsCancelled(NULL)) { | 859 if (db_ && !request->IsCancelled(NULL)) { |
857 const WebIntentData& intent = request->arg(); | 860 const WebIntentServiceData& service = request->arg(); |
858 db_->GetWebIntentsTable()->SetWebIntent(intent); | 861 db_->GetWebIntentsTable()->SetWebIntent(service); |
859 ScheduleCommit(); | 862 ScheduleCommit(); |
860 } | 863 } |
861 request->RequestComplete(); | 864 request->RequestComplete(); |
862 } | 865 } |
863 | 866 |
864 | 867 |
865 void WebDataService::GetWebIntentsImpl(GenericRequest<string16>* request) { | 868 void WebDataService::GetWebIntentsImpl(GenericRequest<string16>* request) { |
866 InitializeDatabaseIfNecessary(); | 869 InitializeDatabaseIfNecessary(); |
867 if (db_ && !request->IsCancelled(NULL)) { | 870 if (db_ && !request->IsCancelled(NULL)) { |
868 std::vector<WebIntentData> result; | 871 std::vector<WebIntentServiceData> result; |
869 db_->GetWebIntentsTable()->GetWebIntents(request->arg(), &result); | 872 db_->GetWebIntentsTable()->GetWebIntents(request->arg(), &result); |
870 request->SetResult( | 873 request->SetResult( |
871 new WDResult<std::vector<WebIntentData> >(WEB_INTENTS_RESULT, result)); | 874 new WDResult<std::vector<WebIntentServiceData> >( |
| 875 WEB_INTENTS_RESULT, result)); |
872 } | 876 } |
873 request->RequestComplete(); | 877 request->RequestComplete(); |
874 } | 878 } |
875 | 879 |
876 void WebDataService::GetAllWebIntentsImpl( | 880 void WebDataService::GetAllWebIntentsImpl( |
877 GenericRequest<std::string>* request) { | 881 GenericRequest<std::string>* request) { |
878 InitializeDatabaseIfNecessary(); | 882 InitializeDatabaseIfNecessary(); |
879 if (db_ && !request->IsCancelled(NULL)) { | 883 if (db_ && !request->IsCancelled(NULL)) { |
880 std::vector<WebIntentData> result; | 884 std::vector<WebIntentServiceData> result; |
881 db_->GetWebIntentsTable()->GetAllWebIntents(&result); | 885 db_->GetWebIntentsTable()->GetAllWebIntents(&result); |
882 request->SetResult( | 886 request->SetResult( |
883 new WDResult<std::vector<WebIntentData> >(WEB_INTENTS_RESULT, result)); | 887 new WDResult<std::vector<WebIntentServiceData> >( |
| 888 WEB_INTENTS_RESULT, result)); |
884 } | 889 } |
885 request->RequestComplete(); | 890 request->RequestComplete(); |
886 } | 891 } |
887 | 892 |
888 //////////////////////////////////////////////////////////////////////////////// | 893 //////////////////////////////////////////////////////////////////////////////// |
889 // | 894 // |
890 // Token Service implementation. | 895 // Token Service implementation. |
891 // | 896 // |
892 //////////////////////////////////////////////////////////////////////////////// | 897 //////////////////////////////////////////////////////////////////////////////// |
893 | 898 |
(...skipping 540 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1434 return result_; | 1439 return result_; |
1435 } | 1440 } |
1436 | 1441 |
1437 void WebDataService::WebDataRequest::RequestComplete() { | 1442 void WebDataService::WebDataRequest::RequestComplete() { |
1438 WebDataService* s = service_; | 1443 WebDataService* s = service_; |
1439 Task* t = NewRunnableMethod(s, | 1444 Task* t = NewRunnableMethod(s, |
1440 &WebDataService::RequestCompleted, | 1445 &WebDataService::RequestCompleted, |
1441 handle_); | 1446 handle_); |
1442 message_loop_->PostTask(FROM_HERE, t); | 1447 message_loop_->PostTask(FROM_HERE, t); |
1443 } | 1448 } |
OLD | NEW |