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 2017 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 "net/nqe/event_creator.h"
#include <memory>
#include <utility>
#include "base/bind.h"
#include "base/strings/string_number_conversions.h"
#include "base/values.h"
#include "net/log/net_log_capture_mode.h"
#include "net/log/net_log_with_source.h"
namespace net {
namespace nqe {
namespace internal {
namespace {
std::unique_ptr<base::Value> EffectiveConnectionTypeChangedNetLogCallback(
base::TimeDelta http_rtt,
base::TimeDelta transport_rtt,
int32_t downstream_throughput_kbps,
EffectiveConnectionType effective_connection_type,
NetLogCaptureMode capture_mode) {
std::unique_ptr<base::DictionaryValue> dict(new base::DictionaryValue());
dict->SetInteger("http_rtt_ms", http_rtt.InMilliseconds());
dict->SetInteger("transport_rtt_ms", transport_rtt.InMilliseconds());
dict->SetInteger("downstream_throughput_kbps", downstream_throughput_kbps);
dict->SetString("effective_connection_type",
GetNameForEffectiveConnectionType(effective_connection_type));
return std::move(dict);
}
} // namespace
EventCreator::EventCreator(NetLogWithSource net_log)
: net_log_(net_log),
past_effective_connection_type_(EFFECTIVE_CONNECTION_TYPE_UNKNOWN) {}
EventCreator::~EventCreator() {
DCHECK(thread_checker_.CalledOnValidThread());
}
void EventCreator::MaybeAddEffectiveConnectionTypeChangedEventToNetLog(
EffectiveConnectionType effective_connection_type,
const NetworkQuality& network_quality) {
DCHECK(thread_checker_.CalledOnValidThread());
// Check if any of the network quality metrics changed meaningfully.
bool effective_connection_type_changed =
past_effective_connection_type_ != effective_connection_type;
bool http_rtt_changed = (past_network_quality_.http_rtt() == InvalidRTT()) !=
(network_quality.http_rtt() == InvalidRTT());
bool transport_rtt_changed =
(past_network_quality_.transport_rtt() == InvalidRTT()) !=
(network_quality.transport_rtt() == InvalidRTT());
bool kbps_changed =
(past_network_quality_.downstream_throughput_kbps() ==
INVALID_RTT_THROUGHPUT) !=
(network_quality.downstream_throughput_kbps() == INVALID_RTT_THROUGHPUT);
if (!effective_connection_type_changed && !http_rtt_changed &&
!transport_rtt_changed && !kbps_changed) {
// Return since none of the metrics changed meaningfully.
return;
}
past_effective_connection_type_ = effective_connection_type;
past_network_quality_ = network_quality;
net_log_.AddEvent(
NetLogEventType::NETWORK_QUALITY_CHANGED,
base::Bind(&EffectiveConnectionTypeChangedNetLogCallback,
network_quality.http_rtt(), network_quality.transport_rtt(),
network_quality.downstream_throughput_kbps(),
effective_connection_type));
}
} // namespace internal
} // namespace nqe
} // namespace net
|
