blob: c305c93240fd5b9e37b3b1bd8d488a1d12be751f (
plain)
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
|
// 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 "extensions/browser/serial_extension_host_queue.h"
#include "base/bind.h"
#include "base/message_loop/message_loop.h"
#include "base/strings/string_number_conversions.h"
#include "base/time/time.h"
#include "components/variations/variations_associated_data.h"
#include "extensions/browser/deferred_start_render_host.h"
namespace extensions {
namespace {
// Gets the number of milliseconds to delay between loading ExtensionHosts. By
// default this is 0, but it can be overridden by field trials.
int GetDelayMs() {
// A sanity check for the maximum delay, to guard against a bad field trial
// config being pushed that delays loading too much (e.g. using wrong units).
static const int kMaxDelayMs = 30 * 1000;
static int delay_ms = -1;
if (delay_ms == -1) {
std::string delay_ms_param =
variations::GetVariationParamValue("ExtensionSpeed", "SerialEHQDelay");
if (delay_ms_param.empty()) {
delay_ms = 0;
} else if (!base::StringToInt(delay_ms_param, &delay_ms)) {
LOG(ERROR) << "Could not parse SerialEHQDelay: " << delay_ms_param;
delay_ms = 0;
} else if (delay_ms < 0 || delay_ms > kMaxDelayMs) {
LOG(ERROR) << "SerialEHQDelay out of range: " << delay_ms;
delay_ms = 0;
}
}
return delay_ms;
}
} // namespace
SerialExtensionHostQueue::SerialExtensionHostQueue()
: pending_create_(false), ptr_factory_(this) {
}
SerialExtensionHostQueue::~SerialExtensionHostQueue() {
}
void SerialExtensionHostQueue::Add(DeferredStartRenderHost* host) {
queue_.push_back(host);
PostTask();
}
void SerialExtensionHostQueue::Remove(DeferredStartRenderHost* host) {
std::list<DeferredStartRenderHost*>::iterator it =
std::find(queue_.begin(), queue_.end(), host);
if (it != queue_.end())
queue_.erase(it);
}
void SerialExtensionHostQueue::PostTask() {
if (!pending_create_) {
base::MessageLoop::current()->PostDelayedTask(
FROM_HERE, base::Bind(&SerialExtensionHostQueue::ProcessOneHost,
ptr_factory_.GetWeakPtr()),
base::TimeDelta::FromMilliseconds(GetDelayMs()));
pending_create_ = true;
}
}
void SerialExtensionHostQueue::ProcessOneHost() {
pending_create_ = false;
if (queue_.empty())
return; // can happen on shutdown
queue_.front()->CreateRenderViewNow();
queue_.pop_front();
if (!queue_.empty())
PostTask();
}
} // namespace extensions
|
