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
|
// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/extensions/api/identity/identity_mint_queue.h"
#include "base/check_op.h"
#include "base/containers/contains.h"
#include "base/trace_event/trace_event.h"
namespace extensions {
IdentityMintRequestQueue::IdentityMintRequestQueue() = default;
IdentityMintRequestQueue::~IdentityMintRequestQueue() {
for (RequestQueueMap::const_iterator
it = interactive_request_queue_map_.begin();
it != interactive_request_queue_map_.end();
++it) {
DCHECK_EQ(it->second.size(), 0lu);
}
for (RequestQueueMap::const_iterator
it = noninteractive_request_queue_map_.begin();
it != noninteractive_request_queue_map_.end();
++it) {
DCHECK_EQ(it->second.size(), 0lu);
}
}
void IdentityMintRequestQueue::RequestStart(
IdentityMintRequestQueue::MintType type,
const ExtensionTokenKey& key,
IdentityMintRequestQueue::Request* request) {
TRACE_EVENT_NESTABLE_ASYNC_BEGIN1("identity", "IdentityMintRequestQueue",
request, "type", type);
RequestQueue& request_queue = GetRequestQueueMap(type)[key];
request_queue.push_back(request);
// If this is the first request, start it now. RequestComplete will start
// all other requests.
if (request_queue.size() == 1)
RunRequest(type, request_queue);
}
void IdentityMintRequestQueue::RequestComplete(
IdentityMintRequestQueue::MintType type,
const ExtensionTokenKey& key,
IdentityMintRequestQueue::Request* request) {
TRACE_EVENT_NESTABLE_ASYNC_END1("identity", "IdentityMintRequestQueue",
request, "completed", "RequestComplete");
RequestQueue& request_queue = GetRequestQueueMap(type)[key];
CHECK_EQ(request_queue.front(), request);
request_queue.pop_front();
if (!request_queue.empty())
RunRequest(type, request_queue);
}
void IdentityMintRequestQueue::RequestCancel(
const ExtensionTokenKey& key,
IdentityMintRequestQueue::Request* request) {
TRACE_EVENT_NESTABLE_ASYNC_END1("identity", "IdentityMintRequestQueue",
request, "completed", "RequestCancel");
GetRequestQueueMap(MINT_TYPE_INTERACTIVE)[key].remove(request);
GetRequestQueueMap(MINT_TYPE_NONINTERACTIVE)[key].remove(request);
}
bool IdentityMintRequestQueue::empty(IdentityMintRequestQueue::MintType type,
const ExtensionTokenKey& key) {
RequestQueueMap& request_queue_map = GetRequestQueueMap(type);
return !base::Contains(request_queue_map, key) ||
(request_queue_map.find(key))->second.empty();
}
IdentityMintRequestQueue::RequestQueueMap&
IdentityMintRequestQueue::GetRequestQueueMap(
IdentityMintRequestQueue::MintType type) {
return (type == MINT_TYPE_INTERACTIVE) ? interactive_request_queue_map_
: noninteractive_request_queue_map_;
}
void IdentityMintRequestQueue::RunRequest(
IdentityMintRequestQueue::MintType type,
RequestQueue& request_queue) {
TRACE_EVENT_NESTABLE_ASYNC_INSTANT0("identity", "RunRequest",
request_queue.front());
request_queue.front()->StartMintToken(type);
}
} // namespace extensions
|
