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
|
// Copyright 2018 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "content/browser/service_worker/service_worker_ping_controller.h"
#include "content/browser/service_worker/service_worker_version.h"
namespace content {
namespace {
// Timeout for waiting for a response to a ping.
constexpr base::TimeDelta kPingTimeout = base::Seconds(30);
} // namespace
ServiceWorkerPingController::ServiceWorkerPingController(
ServiceWorkerVersion* version)
: version_(version) {}
ServiceWorkerPingController::~ServiceWorkerPingController() = default;
void ServiceWorkerPingController::Activate() {
ping_state_ = PingState::kPinging;
}
void ServiceWorkerPingController::Deactivate() {
ClearLastPingTime();
ping_state_ = PingState::kNotPinging;
}
void ServiceWorkerPingController::OnPongReceived() {
ClearLastPingTime();
}
bool ServiceWorkerPingController::IsActivated() const {
return ping_state_ == PingState::kPinging;
}
bool ServiceWorkerPingController::IsTimedOut() const {
return ping_state_ == PingState::kPingTimedOut;
}
void ServiceWorkerPingController::CheckPingStatus() {
if (version_->GetTickDuration(last_ping_time_) > kPingTimeout) {
ping_state_ = PingState::kPingTimedOut;
version_->OnPingTimeout();
return;
}
// Check if we want to send a next ping.
if (ping_state_ != PingState::kPinging || !last_ping_time_.is_null())
return;
version_->PingWorker();
version_->RestartTick(&last_ping_time_);
}
void ServiceWorkerPingController::SimulateTimeoutForTesting() {
version_->PingWorker();
ping_state_ = PingState::kPingTimedOut;
version_->OnPingTimeout();
}
void ServiceWorkerPingController::ClearLastPingTime() {
last_ping_time_ = base::TimeTicks();
}
} // namespace content
|
