1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
|
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROME_BROWSER_HISTORY_HISTORY_H_
#define CHROME_BROWSER_HISTORY_HISTORY_H_
#pragma once
#include <vector>
#include "base/basictypes.h"
#include "base/callback.h"
#include "base/file_path.h"
#include "base/ref_counted.h"
#include "base/scoped_ptr.h"
#include "base/string16.h"
#include "base/task.h"
#include "chrome/browser/cancelable_request.h"
#include "chrome/browser/favicon_service.h"
#include "chrome/browser/history/history_types.h"
#include "chrome/browser/search_engines/template_url_id.h"
#include "chrome/common/notification_registrar.h"
#include "chrome/common/page_transition_types.h"
#include "chrome/common/ref_counted_util.h"
class BookmarkService;
struct DownloadCreateInfo;
class FilePath;
class GURL;
class HistoryURLProvider;
struct HistoryURLProviderParams;
class InMemoryURLDatabase;
class MainPagesRequest;
class PageUsageData;
class PageUsageRequest;
class Profile;
class SkBitmap;
struct ThumbnailScore;
namespace base {
class Thread;
class Time;
}
namespace browser_sync {
class HistoryModelWorker;
class TypedUrlDataTypeController;
}
namespace history {
class InMemoryHistoryBackend;
class InMemoryURLIndex;
class HistoryAddPageArgs;
class HistoryBackend;
class HistoryDatabase;
struct HistoryDetails;
class HistoryQueryTest;
class URLDatabase;
} // namespace history
// HistoryDBTask can be used to process arbitrary work on the history backend
// thread. HistoryDBTask is scheduled using HistoryService::ScheduleDBTask.
// When HistoryBackend processes the task it invokes RunOnDBThread. Once the
// task completes and has not been canceled, DoneRunOnMainThread is invoked back
// on the main thread.
class HistoryDBTask : public base::RefCountedThreadSafe<HistoryDBTask> {
public:
// Invoked on the database thread. The return value indicates whether the
// task is done. A return value of true signals the task is done and
// RunOnDBThread should NOT be invoked again. A return value of false
// indicates the task is not done, and should be run again after other
// tasks are given a chance to be processed.
virtual bool RunOnDBThread(history::HistoryBackend* backend,
history::HistoryDatabase* db) = 0;
// Invoked on the main thread once RunOnDBThread has returned false. This is
// only invoked if the request was not canceled and returned true from
// RunOnDBThread.
virtual void DoneRunOnMainThread() = 0;
protected:
friend class base::RefCountedThreadSafe<HistoryDBTask>;
virtual ~HistoryDBTask() {}
};
// The history service records page titles, and visit times, as well as
// (eventually) information about autocomplete.
//
// This service is thread safe. Each request callback is invoked in the
// thread that made the request.
class HistoryService : public CancelableRequestProvider,
public NotificationObserver,
public base::RefCountedThreadSafe<HistoryService> {
public:
// Miscellaneous commonly-used types.
typedef std::vector<PageUsageData*> PageUsageDataList;
// ID (both star_id and group_id) of the bookmark bar.
// This entry always exists.
static const history::StarID kBookmarkBarID;
// Must call Init after construction.
explicit HistoryService(Profile* profile);
// The empty constructor is provided only for testing.
HistoryService();
// Initializes the history service, returning true on success. On false, do
// not call any other functions. The given directory will be used for storing
// the history files. The BookmarkService is used when deleting URLs to
// test if a URL is bookmarked; it may be NULL during testing.
bool Init(const FilePath& history_dir, BookmarkService* bookmark_service) {
return Init(history_dir, bookmark_service, false);
}
// Triggers the backend to load if it hasn't already, and then returns whether
// it's finished loading.
bool BackendLoaded();
// Returns true if the backend has finished loading.
bool backend_loaded() const { return backend_loaded_; }
// Unloads the backend without actually shutting down the history service.
// This can be used to temporarily reduce the browser process' memory
// footprint.
void UnloadBackend();
// Called on shutdown, this will tell the history backend to complete and
// will release pointers to it. No other functions should be called once
// cleanup has happened that may dispatch to the history thread (because it
// will be NULL).
//
// In practice, this will be called by the service manager (BrowserProcess)
// when it is being destroyed. Because that reference is being destroyed, it
// should be impossible for anybody else to call the service, even if it is
// still in memory (pending requests may be holding a reference to us).
void Cleanup();
// RenderProcessHost pointers are used to scope page IDs (see AddPage). These
// objects must tell us when they are being destroyed so that we can clear
// out any cached data associated with that scope.
//
// The given pointer will not be dereferenced, it is only used for
// identification purposes, hence it is a void*.
void NotifyRenderProcessHostDestruction(const void* host);
// Triggers the backend to load if it hasn't already, and then returns the
// in-memory URL database. The returned pointer MAY BE NULL if the in-memory
// database has not been loaded yet. This pointer is owned by the history
// system. Callers should not store or cache this value.
//
// TODO(brettw) this should return the InMemoryHistoryBackend.
history::URLDatabase* InMemoryDatabase();
// Return the quick history index.
history::InMemoryURLIndex* InMemoryIndex();
// Navigation ----------------------------------------------------------------
// Adds the given canonical URL to history with the current time as the visit
// time. Referrer may be the empty string.
//
// The supplied render process host is used to scope the given page ID. Page
// IDs are only unique inside a given render process, so we need that to
// differentiate them. This pointer should not be dereferenced by the history
// system. Since render view host pointers may be reused (if one gets deleted
// and a new one created at the same address), TabContents should notify
// us when they are being destroyed through NotifyTabContentsDestruction.
//
// The scope/ids can be NULL if there is no meaningful tracking information
// that can be performed on the given URL. The 'page_id' should be the ID of
// the current session history entry in the given process.
//
// 'redirects' is an array of redirect URLs leading to this page, with the
// page itself as the last item (so when there is no redirect, it will have
// one entry). If there are no redirects, this array may also be empty for
// the convenience of callers.
//
// 'did_replace_entry' is true when the navigation entry for this page has
// replaced the existing entry. A non-user initiated redirect causes such
// replacement.
//
// All "Add Page" functions will update the visited link database.
void AddPage(const GURL& url,
const void* id_scope,
int32 page_id,
const GURL& referrer,
PageTransition::Type transition,
const history::RedirectList& redirects,
history::VisitSource visit_source,
bool did_replace_entry);
// For adding pages to history with a specific time. This is for testing
// purposes. Call the previous one to use the current time.
void AddPage(const GURL& url,
base::Time time,
const void* id_scope,
int32 page_id,
const GURL& referrer,
PageTransition::Type transition,
const history::RedirectList& redirects,
history::VisitSource visit_source,
bool did_replace_entry);
// For adding pages to history where no tracking information can be done.
void AddPage(const GURL& url, history::VisitSource visit_source) {
AddPage(url, NULL, 0, GURL(), PageTransition::LINK,
history::RedirectList(), visit_source, false);
}
// All AddPage variants end up here.
void AddPage(const history::HistoryAddPageArgs& add_page_args);
// Sets the title for the given page. The page should be in history. If it
// is not, this operation is ignored. This call will not update the full
// text index. The last title set when the page is indexed will be the
// title in the full text index.
void SetPageTitle(const GURL& url, const string16& title);
// Indexing ------------------------------------------------------------------
// Notifies history of the body text of the given recently-visited URL.
// If the URL was not visited "recently enough," the history system may
// discard it.
void SetPageContents(const GURL& url, const string16& contents);
// Querying ------------------------------------------------------------------
// Callback class that a client can implement to iterate over URLs. The
// callbacks WILL BE CALLED ON THE BACKGROUND THREAD! Your implementation
// should handle this appropriately.
class URLEnumerator {
public:
virtual ~URLEnumerator() {}
// Indicates that a URL is available. There will be exactly one call for
// every URL in history.
virtual void OnURL(const GURL& url) = 0;
// Indicates we are done iterating over URLs. Once called, there will be no
// more callbacks made. This call is guaranteed to occur, even if there are
// no URLs. If all URLs were iterated, success will be true.
virtual void OnComplete(bool success) = 0;
};
// Enumerate all URLs in history. The given iterator will be owned by the
// caller, so the caller should ensure it exists until OnComplete is called.
// You should not generally use this since it will be slow to slurp all URLs
// in from the database. It is designed for rebuilding the visited link
// database from history.
void IterateURLs(URLEnumerator* iterator);
// Returns the information about the requested URL. If the URL is found,
// success will be true and the information will be in the URLRow parameter.
// On success, the visits, if requested, will be sorted by date. If they have
// not been requested, the pointer will be valid, but the vector will be
// empty.
//
// If success is false, neither the row nor the vector will be valid.
typedef Callback4<Handle,
bool, // Success flag, when false, nothing else is valid.
const history::URLRow*,
history::VisitVector*>::Type
QueryURLCallback;
// Queries the basic information about the URL in the history database. If
// the caller is interested in the visits (each time the URL is visited),
// set |want_visits| to true. If these are not needed, the function will be
// faster by setting this to false.
Handle QueryURL(const GURL& url,
bool want_visits,
CancelableRequestConsumerBase* consumer,
QueryURLCallback* callback);
// Provides the result of a query. See QueryResults in history_types.h.
// The common use will be to use QueryResults.Swap to suck the contents of
// the results out of the passed in parameter and take ownership of them.
typedef Callback2<Handle, history::QueryResults*>::Type
QueryHistoryCallback;
// Queries all history with the given options (see QueryOptions in
// history_types.h). If non-empty, the full-text database will be queried with
// the given |text_query|. If empty, all results matching the given options
// will be returned.
//
// This isn't totally hooked up yet, this will query the "new" full text
// database (see SetPageContents) which won't generally be set yet.
Handle QueryHistory(const string16& text_query,
const history::QueryOptions& options,
CancelableRequestConsumerBase* consumer,
QueryHistoryCallback* callback);
// Called when the results of QueryRedirectsFrom are available.
// The given vector will contain a list of all redirects, not counting
// the original page. If A redirects to B, the vector will contain only B,
// and A will be in 'source_url'.
//
// If there is no such URL in the database or the most recent visit has no
// redirect, the vector will be empty. If the history system failed for
// some reason, success will additionally be false. If the given page
// has redirected to multiple destinations, this will pick a random one.
typedef Callback4<Handle,
GURL, // from_url
bool, // success
history::RedirectList*>::Type
QueryRedirectsCallback;
// Schedules a query for the most recent redirect coming out of the given
// URL. See the RedirectQuerySource above, which is guaranteed to be called
// if the request is not canceled.
Handle QueryRedirectsFrom(const GURL& from_url,
CancelableRequestConsumerBase* consumer,
QueryRedirectsCallback* callback);
// Schedules a query to get the most recent redirects ending at the given
// URL.
Handle QueryRedirectsTo(const GURL& to_url,
CancelableRequestConsumerBase* consumer,
QueryRedirectsCallback* callback);
typedef Callback4<Handle,
bool, // Were we able to determine the # of visits?
int, // Number of visits.
base::Time>::Type // Time of first visit. Only first bool is
// true and int is > 0.
GetVisitCountToHostCallback;
// Requests the number of visits to all urls on the scheme/host/post
// identified by url. This is only valid for http and https urls.
Handle GetVisitCountToHost(const GURL& url,
CancelableRequestConsumerBase* consumer,
GetVisitCountToHostCallback* callback);
// Called when QueryTopURLsAndRedirects completes. The vector contains a list
// of the top |result_count| URLs. For each of these URLs, there is an entry
// in the map containing redirects from the URL. For example, if we have the
// redirect chain A -> B -> C and A is a top visited URL, then A will be in
// the vector and "A => {B -> C}" will be in the map.
typedef Callback4<Handle,
bool, // Did we get the top urls and redirects?
std::vector<GURL>*, // List of top URLs.
history::RedirectMap*>::Type // Redirects for top URLs.
QueryTopURLsAndRedirectsCallback;
// Request the top |result_count| most visited URLs and the chain of redirects
// leading to each of these URLs.
// TODO(Nik): remove this. Use QueryMostVisitedURLs instead.
Handle QueryTopURLsAndRedirects(int result_count,
CancelableRequestConsumerBase* consumer,
QueryTopURLsAndRedirectsCallback* callback);
typedef Callback2<Handle, history::MostVisitedURLList>::Type
QueryMostVisitedURLsCallback;
// Request the |result_count| most visited URLs and the chain of
// redirects leading to each of these URLs. |days_back| is the
// number of days of history to use. Used by TopSites.
Handle QueryMostVisitedURLs(int result_count, int days_back,
CancelableRequestConsumerBase* consumer,
QueryMostVisitedURLsCallback* callback);
// Thumbnails ----------------------------------------------------------------
// Implemented by consumers to get thumbnail data. Called when a request for
// the thumbnail data is complete. Once this callback is made, the request
// will be completed and no other calls will be made for that handle.
//
// This function will be called even on error conditions or if there is no
// thumbnail for that page. In these cases, the data pointer will be NULL.
typedef Callback2<Handle, scoped_refptr<RefCountedBytes> >::Type
ThumbnailDataCallback;
// Sets the thumbnail for a given URL. The URL must be in the history
// database or the request will be ignored.
void SetPageThumbnail(const GURL& url,
const SkBitmap& thumbnail,
const ThumbnailScore& score);
// Requests a page thumbnail. See ThumbnailDataCallback definition above.
Handle GetPageThumbnail(const GURL& page_url,
CancelableRequestConsumerBase* consumer,
ThumbnailDataCallback* callback);
// Database management operations --------------------------------------------
// Delete all the information related to a single url.
void DeleteURL(const GURL& url);
// Implemented by the caller of ExpireHistoryBetween, and
// is called when the history service has deleted the history.
typedef Callback0::Type ExpireHistoryCallback;
// Removes all visits in the selected time range (including the start time),
// updating the URLs accordingly. This deletes the associated data, including
// the full text index. This function also deletes the associated favicons,
// if they are no longer referenced. |callback| runs when the expiration is
// complete. You may use null Time values to do an unbounded delete in
// either direction.
// If |restrict_urls| is not empty, only visits to the URLs in this set are
// removed.
void ExpireHistoryBetween(const std::set<GURL>& restrict_urls,
base::Time begin_time, base::Time end_time,
CancelableRequestConsumerBase* consumer,
ExpireHistoryCallback* callback);
// Downloads -----------------------------------------------------------------
// Implemented by the caller of 'CreateDownload' below, and is called when the
// history service has created a new entry for a download in the history db.
typedef Callback2<DownloadCreateInfo, int64>::Type
DownloadCreateCallback;
// Begins a history request to create a new persistent entry for a download.
// 'info' contains all the download's creation state, and 'callback' runs
// when the history service request is complete.
Handle CreateDownload(const DownloadCreateInfo& info,
CancelableRequestConsumerBase* consumer,
DownloadCreateCallback* callback);
// Implemented by the caller of 'QueryDownloads' below, and is called when the
// history service has retrieved a list of all download state. The call
typedef Callback1<std::vector<DownloadCreateInfo>*>::Type
DownloadQueryCallback;
// Begins a history request to retrieve the state of all downloads in the
// history db. 'callback' runs when the history service request is complete,
// at which point 'info' contains an array of DownloadCreateInfo, one per
// download.
Handle QueryDownloads(CancelableRequestConsumerBase* consumer,
DownloadQueryCallback* callback);
// Begins a request to clean up entries that has been corrupted (because of
// the crash, for example).
void CleanUpInProgressEntries();
// Called to update the history service about the current state of a download.
// This is a 'fire and forget' query, so just pass the relevant state info to
// the database with no need for a callback.
void UpdateDownload(int64 received_bytes, int32 state, int64 db_handle);
// Called to update the history service about the path of a download.
// This is a 'fire and forget' query.
void UpdateDownloadPath(const FilePath& path, int64 db_handle);
// Permanently remove a download from the history system. This is a 'fire and
// forget' operation.
void RemoveDownload(int64 db_handle);
// Permanently removes all completed download from the history system within
// the specified range. This function does not delete downloads that are in
// progress or in the process of being cancelled. This is a 'fire and forget'
// operation. You can pass is_null times to get unbounded time in either or
// both directions.
void RemoveDownloadsBetween(base::Time remove_begin, base::Time remove_end);
// Visit Segments ------------------------------------------------------------
typedef Callback2<Handle, std::vector<PageUsageData*>*>::Type
SegmentQueryCallback;
// Query usage data for all visit segments since the provided time.
//
// The request is performed asynchronously and can be cancelled by using the
// returned handle.
//
// The vector provided to the callback and its contents is owned by the
// history system. It will be deeply deleted after the callback is invoked.
// If you want to preserve any PageUsageData instance, simply remove them
// from the vector.
//
// The vector contains a list of PageUsageData. Each PageUsageData ID is set
// to the segment ID. The URL and all the other information is set to the page
// representing the segment.
Handle QuerySegmentUsageSince(CancelableRequestConsumerBase* consumer,
const base::Time from_time,
int max_result_count,
SegmentQueryCallback* callback);
// Set the presentation index for the segment identified by |segment_id|.
void SetSegmentPresentationIndex(int64 segment_id, int index);
// Keyword search terms -----------------------------------------------------
// Sets the search terms for the specified url and keyword. url_id gives the
// id of the url, keyword_id the id of the keyword and term the search term.
void SetKeywordSearchTermsForURL(const GURL& url,
TemplateURLID keyword_id,
const string16& term);
// Deletes all search terms for the specified keyword.
void DeleteAllSearchTermsForKeyword(TemplateURLID keyword_id);
typedef Callback2<Handle, std::vector<history::KeywordSearchTermVisit>*>::Type
GetMostRecentKeywordSearchTermsCallback;
// Returns up to max_count of the most recent search terms starting with the
// specified text. The matching is case insensitive. The results are ordered
// in descending order up to |max_count| with the most recent search term
// first.
Handle GetMostRecentKeywordSearchTerms(
TemplateURLID keyword_id,
const string16& prefix,
int max_count,
CancelableRequestConsumerBase* consumer,
GetMostRecentKeywordSearchTermsCallback* callback);
// Bookmarks -----------------------------------------------------------------
// Notification that a URL is no longer bookmarked.
void URLsNoLongerBookmarked(const std::set<GURL>& urls);
// Generic Stuff -------------------------------------------------------------
typedef Callback0::Type HistoryDBTaskCallback;
// Schedules a HistoryDBTask for running on the history backend thread. See
// HistoryDBTask for details on what this does.
virtual Handle ScheduleDBTask(HistoryDBTask* task,
CancelableRequestConsumerBase* consumer);
// Returns true if top sites needs to be migrated out of history into its own
// db.
bool needs_top_sites_migration() const { return needs_top_sites_migration_; }
// Testing -------------------------------------------------------------------
// Designed for unit tests, this passes the given task on to the history
// backend to be called once the history backend has terminated. This allows
// callers to know when the history thread is complete and the database files
// can be deleted and the next test run. Otherwise, the history thread may
// still be running, causing problems in subsequent tests.
//
// There can be only one closing task, so this will override any previously
// set task. We will take ownership of the pointer and delete it when done.
// The task will be run on the calling thread (this function is threadsafe).
void SetOnBackendDestroyTask(Task* task);
// Used for unit testing and potentially importing to get known information
// into the database. This assumes the URL doesn't exist in the database
//
// Calling this function many times may be slow because each call will
// dispatch to the history thread and will be a separate database
// transaction. If this functionality is needed for importing many URLs, a
// version that takes an array should probably be added.
void AddPageWithDetails(const GURL& url,
const string16& title,
int visit_count,
int typed_count,
base::Time last_visit,
bool hidden,
history::VisitSource visit_source);
// The same as AddPageWithDetails() but takes a vector.
void AddPagesWithDetails(const std::vector<history::URLRow>& info,
history::VisitSource visit_source);
// Starts the TopSites migration in the HistoryThread. Called by the
// BackendDelegate.
void StartTopSitesMigration();
// Called by TopSites after the thumbnails were read and it is safe
// to delete the thumbnails DB.
void OnTopSitesReady();
// Returns true if this looks like the type of URL we want to add to the
// history. We filter out some URLs such as JavaScript.
static bool CanAddURL(const GURL& url);
protected:
~HistoryService();
// These are not currently used, hopefully we can do something in the future
// to ensure that the most important things happen first.
enum SchedulePriority {
PRIORITY_UI, // The highest priority (must respond to UI events).
PRIORITY_NORMAL, // Normal stuff like adding a page.
PRIORITY_LOW, // Low priority things like indexing or expiration.
};
private:
class BackendDelegate;
friend class base::RefCountedThreadSafe<HistoryService>;
friend class BackendDelegate;
friend class FaviconService;
friend class history::HistoryBackend;
friend class history::HistoryQueryTest;
friend class HistoryOperation;
friend class HistoryURLProvider;
friend class HistoryURLProviderTest;
template<typename Info, typename Callback> friend class DownloadRequest;
friend class PageUsageRequest;
friend class RedirectRequest;
friend class FavIconRequest;
friend class TestingProfile;
// Implementation of NotificationObserver.
virtual void Observe(NotificationType type,
const NotificationSource& source,
const NotificationDetails& details);
// Low-level Init(). Same as the public version, but adds a |no_db| parameter
// that is only set by unittests which causes the backend to not init its DB.
bool Init(const FilePath& history_dir,
BookmarkService* bookmark_service,
bool no_db);
// Called by the HistoryURLProvider class to schedule an autocomplete, it
// will be called back on the internal history thread with the history
// database so it can query. See history_autocomplete.cc for a diagram.
void ScheduleAutocomplete(HistoryURLProvider* provider,
HistoryURLProviderParams* params);
// Broadcasts the given notification. This is called by the backend so that
// the notification will be broadcast on the main thread.
//
// The |details_deleted| pointer will be sent as the "details" for the
// notification. The function takes ownership of the pointer and deletes it
// when the notification is sent (it is coming from another thread, so must
// be allocated on the heap).
void BroadcastNotifications(NotificationType type,
history::HistoryDetails* details_deleted);
// Initializes the backend.
void LoadBackendIfNecessary();
// Notification from the backend that it has finished loading. Sends
// notification (NOTIFY_HISTORY_LOADED) and sets backend_loaded_ to true.
void OnDBLoaded();
// FavIcon -------------------------------------------------------------------
// These favicon methods are exposed to the FaviconService. Instead of calling
// these methods directly you should call the respective method on the
// FaviconService.
// Used by the FaviconService to get a favicon from the history backend.
void GetFavicon(FaviconService::GetFaviconRequest* request,
const GURL& icon_url);
// Used by the FaviconService to update the favicon mappings on the history
// backend.
void UpdateFaviconMappingAndFetch(FaviconService::GetFaviconRequest* request,
const GURL& page_url,
const GURL& icon_url);
// Used by the FaviconService to get a favicon from the history backend.
void GetFaviconForURL(FaviconService::GetFaviconRequest* request,
const GURL& page_url);
// Used by the FaviconService to mark the favicon for the page as being out
// of date.
void SetFaviconOutOfDateForPage(const GURL& page_url);
// Used by the FaviconService for importing many favicons for many pages at
// once. The pages must exist, any favicon sets for unknown pages will be
// discarded. Existing favicons will not be overwritten.
void SetImportedFavicons(
const std::vector<history::ImportedFavIconUsage>& favicon_usage);
// Used by the FaviconService to set the favicon for a page on the history
// backend.
void SetFavicon(const GURL& page_url,
const GURL& icon_url,
const std::vector<unsigned char>& image_data);
// Sets the in-memory URL database. This is called by the backend once the
// database is loaded to make it available.
void SetInMemoryBackend(history::InMemoryHistoryBackend* mem_backend);
// Called by our BackendDelegate when there is a problem reading the database.
// |message_id| is the relevant message in the string table to display.
void NotifyProfileError(int message_id);
// Call to schedule a given task for running on the history thread with the
// specified priority. The task will have ownership taken.
void ScheduleTask(SchedulePriority priority, Task* task);
// Schedule ------------------------------------------------------------------
//
// Functions for scheduling operations on the history thread that have a
// handle and may be cancelable. For fire-and-forget operations, see
// ScheduleAndForget below.
template<typename BackendFunc, class RequestType>
Handle Schedule(SchedulePriority priority,
BackendFunc func, // Function to call on the HistoryBackend.
CancelableRequestConsumerBase* consumer,
RequestType* request) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
if (consumer)
AddRequest(request, consumer);
ScheduleTask(priority,
NewRunnableMethod(history_backend_.get(), func,
scoped_refptr<RequestType>(request)));
return request->handle();
}
template<typename BackendFunc, class RequestType, typename ArgA>
Handle Schedule(SchedulePriority priority,
BackendFunc func, // Function to call on the HistoryBackend.
CancelableRequestConsumerBase* consumer,
RequestType* request,
const ArgA& a) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
if (consumer)
AddRequest(request, consumer);
ScheduleTask(priority,
NewRunnableMethod(history_backend_.get(), func,
scoped_refptr<RequestType>(request),
a));
return request->handle();
}
template<typename BackendFunc,
class RequestType, // Descendant of CancelableRequstBase.
typename ArgA,
typename ArgB>
Handle Schedule(SchedulePriority priority,
BackendFunc func, // Function to call on the HistoryBackend.
CancelableRequestConsumerBase* consumer,
RequestType* request,
const ArgA& a,
const ArgB& b) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
if (consumer)
AddRequest(request, consumer);
ScheduleTask(priority,
NewRunnableMethod(history_backend_.get(), func,
scoped_refptr<RequestType>(request),
a, b));
return request->handle();
}
template<typename BackendFunc,
class RequestType, // Descendant of CancelableRequstBase.
typename ArgA,
typename ArgB,
typename ArgC>
Handle Schedule(SchedulePriority priority,
BackendFunc func, // Function to call on the HistoryBackend.
CancelableRequestConsumerBase* consumer,
RequestType* request,
const ArgA& a,
const ArgB& b,
const ArgC& c) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
if (consumer)
AddRequest(request, consumer);
ScheduleTask(priority,
NewRunnableMethod(history_backend_.get(), func,
scoped_refptr<RequestType>(request),
a, b, c));
return request->handle();
}
// ScheduleAndForget ---------------------------------------------------------
//
// Functions for scheduling operations on the history thread that do not need
// any callbacks and are not cancelable.
template<typename BackendFunc>
void ScheduleAndForget(SchedulePriority priority,
BackendFunc func) { // Function to call on backend.
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
ScheduleTask(priority, NewRunnableMethod(history_backend_.get(), func));
}
template<typename BackendFunc, typename ArgA>
void ScheduleAndForget(SchedulePriority priority,
BackendFunc func, // Function to call on backend.
const ArgA& a) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
ScheduleTask(priority, NewRunnableMethod(history_backend_.get(), func, a));
}
template<typename BackendFunc, typename ArgA, typename ArgB>
void ScheduleAndForget(SchedulePriority priority,
BackendFunc func, // Function to call on backend.
const ArgA& a,
const ArgB& b) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
ScheduleTask(priority, NewRunnableMethod(history_backend_.get(), func,
a, b));
}
template<typename BackendFunc, typename ArgA, typename ArgB, typename ArgC>
void ScheduleAndForget(SchedulePriority priority,
BackendFunc func, // Function to call on backend.
const ArgA& a,
const ArgB& b,
const ArgC& c) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
ScheduleTask(priority, NewRunnableMethod(history_backend_.get(), func,
a, b, c));
}
template<typename BackendFunc,
typename ArgA,
typename ArgB,
typename ArgC,
typename ArgD>
void ScheduleAndForget(SchedulePriority priority,
BackendFunc func, // Function to call on backend.
const ArgA& a,
const ArgB& b,
const ArgC& c,
const ArgD& d) {
DCHECK(thread_) << "History service being called after cleanup";
LoadBackendIfNecessary();
ScheduleTask(priority, NewRunnableMethod(history_backend_.get(), func,
a, b, c, d));
}
NotificationRegistrar registrar_;
// Some void primitives require some internal processing in the main thread
// when done. We use this internal consumer for this purpose.
CancelableRequestConsumer internal_consumer_;
// The thread used by the history service to run complicated operations.
// |thread_| is NULL once |Cleanup| is NULL.
base::Thread* thread_;
// This class has most of the implementation and runs on the 'thread_'.
// You MUST communicate with this class ONLY through the thread_'s
// message_loop().
//
// This pointer will be NULL once Cleanup() has been called, meaning no
// more calls should be made to the history thread.
scoped_refptr<history::HistoryBackend> history_backend_;
// A cache of the user-typed URLs kept in memory that is used by the
// autocomplete system. This will be NULL until the database has been created
// on the background thread.
scoped_ptr<history::InMemoryHistoryBackend> in_memory_backend_;
// The profile, may be null when testing.
Profile* profile_;
// Has the backend finished loading? The backend is loaded once Init has
// completed.
bool backend_loaded_;
// Cached values from Init(), used whenever we need to reload the backend.
FilePath history_dir_;
BookmarkService* bookmark_service_;
bool no_db_;
// True if needs top site migration.
bool needs_top_sites_migration_;
DISALLOW_COPY_AND_ASSIGN(HistoryService);
};
#endif // CHROME_BROWSER_HISTORY_HISTORY_H_
|