File: affiliation_service.cc

package info (click to toggle)
chromium-browser 57.0.2987.98-1~deb8u1
  • links: PTS, VCS
  • area: main
  • in suites: jessie
  • size: 2,637,852 kB
  • ctags: 2,544,394
  • sloc: cpp: 12,815,961; ansic: 3,676,222; python: 1,147,112; asm: 526,608; java: 523,212; xml: 286,794; perl: 92,654; sh: 86,408; objc: 73,271; makefile: 27,698; cs: 18,487; yacc: 13,031; tcl: 12,957; pascal: 4,875; ml: 4,716; lex: 3,904; sql: 3,862; ruby: 1,982; lisp: 1,508; php: 1,368; exp: 404; awk: 325; csh: 117; jsp: 39; sed: 37
file content (109 lines) | stat: -rw-r--r-- 3,932 bytes parent folder | download
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
// Copyright 2015 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.

#include "components/password_manager/core/browser/affiliation_service.h"

#include "base/bind.h"
#include "base/bind_helpers.h"
#include "base/files/file_path.h"
#include "base/location.h"
#include "base/memory/ptr_util.h"
#include "base/single_thread_task_runner.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/time/default_clock.h"
#include "base/time/default_tick_clock.h"
#include "components/password_manager/core/browser/affiliation_backend.h"
#include "net/url_request/url_request_context_getter.h"

namespace password_manager {

AffiliationService::AffiliationService(
    scoped_refptr<base::SingleThreadTaskRunner> backend_task_runner)
    : backend_(nullptr),
      backend_task_runner_(backend_task_runner),
      weak_ptr_factory_(this) {
}

AffiliationService::~AffiliationService() {
  DCHECK(thread_checker_.CalledOnValidThread());
  if (backend_) {
    backend_task_runner_->DeleteSoon(FROM_HERE, backend_);
    backend_ = nullptr;
  }
}

void AffiliationService::Initialize(
    net::URLRequestContextGetter* request_context_getter,
    const base::FilePath& db_path) {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(!backend_);
  backend_ =
      new AffiliationBackend(request_context_getter, backend_task_runner_,
                             base::WrapUnique(new base::DefaultClock),
                             base::WrapUnique(new base::DefaultTickClock));

  std::unique_ptr<base::TickClock> tick_clock(new base::DefaultTickClock);
  backend_task_runner_->PostTask(
      FROM_HERE, base::Bind(&AffiliationBackend::Initialize,
                            base::Unretained(backend_), db_path));
}

void AffiliationService::GetAffiliations(
    const FacetURI& facet_uri,
    StrategyOnCacheMiss cache_miss_strategy,
    const ResultCallback& result_callback) {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(backend_);
  backend_task_runner_->PostTask(
      FROM_HERE,
      base::Bind(&AffiliationBackend::GetAffiliations,
                 base::Unretained(backend_), facet_uri, cache_miss_strategy,
                 result_callback, base::ThreadTaskRunnerHandle::Get()));
}

void AffiliationService::Prefetch(const FacetURI& facet_uri,
                                  const base::Time& keep_fresh_until) {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(backend_);
  backend_task_runner_->PostTask(
      FROM_HERE,
      base::Bind(&AffiliationBackend::Prefetch, base::Unretained(backend_),
                 facet_uri, keep_fresh_until));
}

void AffiliationService::CancelPrefetch(const FacetURI& facet_uri,
                                        const base::Time& keep_fresh_until) {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(backend_);
  backend_task_runner_->PostTask(
      FROM_HERE,
      base::Bind(&AffiliationBackend::CancelPrefetch,
                 base::Unretained(backend_), facet_uri, keep_fresh_until));
}

void AffiliationService::TrimCache() {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(backend_);
  backend_task_runner_->PostTask(
      FROM_HERE,
      base::Bind(&AffiliationBackend::TrimCache, base::Unretained(backend_)));
}

void AffiliationService::TrimCacheForFacet(const FacetURI& facet_uri) {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(backend_);
  backend_task_runner_->PostTask(
      FROM_HERE, base::Bind(&AffiliationBackend::TrimCacheForFacet,
                            base::Unretained(backend_), facet_uri));
}

// static
void AffiliationService::DeleteCache(
    const base::FilePath& db_path,
    base::SingleThreadTaskRunner* backend_task_runner) {
  backend_task_runner->PostTask(
      FROM_HERE, base::Bind(&AffiliationBackend::DeleteCache, db_path));
}

}  // namespace password_manager