Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(777)

Side by Side Diff: chrome/browser/media/router/discovery/discovery_network_monitor.cc

Issue 2750453002: Add DiscoveryNetworkMonitor implementation (Closed)
Patch Set: Respond to imcheng's comments Created 3 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 // Copyright (c) 2017 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "chrome/browser/media/router/discovery/discovery_network_monitor.h"
6
7 #include <unordered_set>
8
9 #include "base/lazy_instance.h"
10 #include "base/logging.h"
11 #include "base/sha1.h"
12 #include "base/strings/string_number_conversions.h"
13 #include "base/strings/string_util.h"
14 #include "chrome/browser/media/router/discovery/discovery_network_list.h"
15 #include "net/base/network_interfaces.h"
16
17 namespace {
18
19 using content::BrowserThread;
20
21 std::string ComputeNetworkId(
22 const std::vector<DiscoveryNetworkInfo>& network_info_list) {
23 DCHECK_CURRENTLY_ON(BrowserThread::IO);
24
25 if (network_info_list.size() == 0) {
mark a. foltz 2017/06/05 21:28:43 I slightly prefer omitting the { } for one-line if
btolsch 2017/06/05 22:38:33 Acknowledged.
26 return DiscoveryNetworkMonitor::kNetworkIdDisconnected;
27 }
28 bool has_nonempty_network_id = false;
mark a. foltz 2017/06/05 21:28:43 This could be one liner with std::find_if, and sli
btolsch 2017/06/05 22:38:33 Done.
29 for (const auto& network_info : network_info_list) {
30 has_nonempty_network_id =
31 has_nonempty_network_id || network_info.network_id.size() > 0;
32 }
33 if (!has_nonempty_network_id) {
34 return DiscoveryNetworkMonitor::kNetworkIdUnknown;
35 }
36
37 std::string combined_ids;
38 for (const auto& network_info : network_info_list) {
39 combined_ids = combined_ids + "!" + network_info.network_id;
40 }
41
42 std::string hash = base::SHA1HashString(combined_ids);
43 return base::ToLowerASCII(base::HexEncode(hash.data(), hash.length()));
44 }
45
46 std::vector<DiscoveryNetworkInfo> GetNetworkInfo() {
47 DCHECK_CURRENTLY_ON(BrowserThread::IO);
48 return GetDiscoveryNetworkInfoList();
49 }
50
51 base::LazyInstance<DiscoveryNetworkMonitor>::Leaky g_discovery_monitor;
52
53 } // namespace
54
55 // static
56 constexpr char DiscoveryNetworkMonitor::kNetworkIdDisconnected[];
imcheng 2017/05/31 21:19:55 Are these necessary since you've already defined t
btolsch 2017/06/05 22:38:33 Yes. In short, any odr-use still requires a defin
57 // static
58 constexpr char DiscoveryNetworkMonitor::kNetworkIdUnknown[];
59
60 // static
61 DiscoveryNetworkMonitor* DiscoveryNetworkMonitor::GetInstance() {
62 DiscoveryNetworkMonitor* monitor = g_discovery_monitor.Pointer();
63 if (!monitor->network_info_function_) {
64 monitor->network_info_function_ = &GetNetworkInfo;
65 }
66 return monitor;
67 }
68
69 void DiscoveryNetworkMonitor::RebindNetworkChangeObserverForTest() {
70 net::NetworkChangeNotifier::AddNetworkChangeObserver(this);
71 }
72
73 void DiscoveryNetworkMonitor::SetNetworkInfoFunctionForTest(
74 NetworkInfoFunction strategy) {
75 network_info_function_ = strategy;
76 }
77
78 void DiscoveryNetworkMonitor::AddObserver(Observer* const observer) {
79 observers_->AddObserver(observer);
80 }
81
82 void DiscoveryNetworkMonitor::RemoveObserver(Observer* const observer) {
83 observers_->RemoveObserver(observer);
84 }
85
86 void DiscoveryNetworkMonitor::Refresh(NetworkRefreshCompleteCallback callback) {
87 BrowserThread::PostTaskAndReply(
88 BrowserThread::IO, FROM_HERE,
89 base::BindOnce(&DiscoveryNetworkMonitor::UpdateNetworkInfo,
90 base::Unretained(this)),
91 std::move(callback));
92 }
93
94 const std::string& DiscoveryNetworkMonitor::GetNetworkId() const {
95 DCHECK_CURRENTLY_ON(BrowserThread::IO);
96 return network_id_;
97 }
98
99 DiscoveryNetworkMonitor::DiscoveryNetworkMonitor()
100 : network_id_(kNetworkIdDisconnected),
101 observers_(new base::ObserverListThreadSafe<Observer>(
102 base::ObserverListThreadSafe<
103 Observer>::NotificationType::NOTIFY_EXISTING_ONLY)) {
imcheng 2017/05/31 21:19:55 Can we initialize network_info_function_ to &GetNe
btolsch 2017/06/05 22:38:33 Done.
104 net::NetworkChangeNotifier::AddNetworkChangeObserver(this);
105 }
106
107 DiscoveryNetworkMonitor::~DiscoveryNetworkMonitor() {
108 net::NetworkChangeNotifier::RemoveNetworkChangeObserver(this);
109 }
110
111 void DiscoveryNetworkMonitor::OnNetworkChanged(
112 net::NetworkChangeNotifier::ConnectionType) {
113 BrowserThread::PostTask(
114 BrowserThread::IO, FROM_HERE,
115 base::Bind(&DiscoveryNetworkMonitor::UpdateNetworkInfo,
116 base::Unretained(this)));
117 }
118
119 void DiscoveryNetworkMonitor::UpdateNetworkInfo() {
120 DCHECK_CURRENTLY_ON(BrowserThread::IO);
121
122 auto network_info_list = network_info_function_();
123 auto network_id = ComputeNetworkId(network_info_list);
124
125 network_id_.swap(network_id);
126
127 if (network_id_ != network_id) {
128 observers_->Notify(FROM_HERE, &Observer::OnNetworksChanged,
129 base::ConstRef(*this));
130 }
131 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698