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

Side by Side Diff: content/renderer/p2p/ipc_network_manager.cc

Issue 536133003: MergeNetworkList can't group address under the same interface (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Change prefix from size_t to unsigned int per @wfh's feedback comment Created 6 years, 3 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
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "content/renderer/p2p/ipc_network_manager.h" 5 #include "content/renderer/p2p/ipc_network_manager.h"
6 6 #include <string>
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/command_line.h" 8 #include "base/command_line.h"
9 #include "base/metrics/histogram.h" 9 #include "base/metrics/histogram.h"
10 #include "base/sys_byteorder.h" 10 #include "base/sys_byteorder.h"
11 #include "content/public/common/content_switches.h" 11 #include "content/public/common/content_switches.h"
12 #include "net/base/net_util.h" 12 #include "net/base/net_util.h"
13 13
14 namespace content { 14 namespace content {
15 15
16 namespace { 16 namespace {
(...skipping 11 matching lines...) Expand all
28 case net::NetworkChangeNotifier::CONNECTION_3G: 28 case net::NetworkChangeNotifier::CONNECTION_3G:
29 case net::NetworkChangeNotifier::CONNECTION_4G: 29 case net::NetworkChangeNotifier::CONNECTION_4G:
30 return rtc::ADAPTER_TYPE_CELLULAR; 30 return rtc::ADAPTER_TYPE_CELLULAR;
31 default: 31 default:
32 return rtc::ADAPTER_TYPE_UNKNOWN; 32 return rtc::ADAPTER_TYPE_UNKNOWN;
33 } 33 }
34 } 34 }
35 35
36 } // namespace 36 } // namespace
37 37
38 IpcNetworkManager::IpcNetworkManager(P2PSocketDispatcher* socket_dispatcher) 38 IpcNetworkManager::IpcNetworkManager(NetworkListManager* network_list_manager)
39 : socket_dispatcher_(socket_dispatcher), 39 : network_list_manager_(network_list_manager),
40 start_count_(0), 40 start_count_(0),
41 network_list_received_(false), 41 network_list_received_(false),
42 weak_factory_(this) { 42 weak_factory_(this) {
43 socket_dispatcher_->AddNetworkListObserver(this); 43 network_list_manager_->AddNetworkListObserver(this);
44 } 44 }
45 45
46 IpcNetworkManager::~IpcNetworkManager() { 46 IpcNetworkManager::~IpcNetworkManager() {
47 DCHECK(!start_count_); 47 DCHECK(!start_count_);
48 socket_dispatcher_->RemoveNetworkListObserver(this); 48 network_list_manager_->RemoveNetworkListObserver(this);
49 } 49 }
50 50
51 void IpcNetworkManager::StartUpdating() { 51 void IpcNetworkManager::StartUpdating() {
52 if (network_list_received_) { 52 if (network_list_received_) {
53 // Post a task to avoid reentrancy. 53 // Post a task to avoid reentrancy.
54 base::MessageLoop::current()->PostTask( 54 base::MessageLoop::current()->PostTask(
55 FROM_HERE, 55 FROM_HERE,
56 base::Bind(&IpcNetworkManager::SendNetworksChangedSignal, 56 base::Bind(&IpcNetworkManager::SendNetworksChangedSignal,
57 weak_factory_.GetWeakPtr())); 57 weak_factory_.GetWeakPtr()));
58 } 58 }
59 ++start_count_; 59 ++start_count_;
60 } 60 }
61 61
62 void IpcNetworkManager::StopUpdating() { 62 void IpcNetworkManager::StopUpdating() {
63 DCHECK_GT(start_count_, 0); 63 DCHECK_GT(start_count_, 0);
64 --start_count_; 64 --start_count_;
65 } 65 }
66 66
67 void IpcNetworkManager::OnNetworkListChanged( 67 void IpcNetworkManager::OnNetworkListChanged(
68 const net::NetworkInterfaceList& list) { 68 const net::NetworkInterfaceList& list) {
69 69
70 // Update flag if network list received for the first time. 70 // Update flag if network list received for the first time.
71 if (!network_list_received_) 71 if (!network_list_received_)
72 network_list_received_ = true; 72 network_list_received_ = true;
73 73
74 // Note: 32 and 64 are the arbitrary(kind of) prefix length used to
75 // differentiate IPv4 and IPv6 addresses.
76 // rtc::Network uses these prefix_length to compare network 74 // rtc::Network uses these prefix_length to compare network
77 // interfaces discovered. 75 // interfaces discovered.
78 std::vector<rtc::Network*> networks; 76 std::vector<rtc::Network*> networks;
79 int ipv4_interfaces = 0; 77 int ipv4_interfaces = 0;
80 int ipv6_interfaces = 0; 78 int ipv6_interfaces = 0;
81 for (net::NetworkInterfaceList::const_iterator it = list.begin(); 79 for (net::NetworkInterfaceList::const_iterator it = list.begin();
82 it != list.end(); it++) { 80 it != list.end(); it++) {
83 if (it->address.size() == net::kIPv4AddressSize) { 81 if (it->address.size() == net::kIPv4AddressSize) {
84 uint32 address; 82 uint32 address;
85 memcpy(&address, &it->address[0], sizeof(uint32)); 83 memcpy(&address, &it->address[0], sizeof(uint32));
86 address = rtc::NetworkToHost32(address); 84 address = rtc::NetworkToHost32(address);
87 rtc::Network* network = new rtc::Network( 85 rtc::IPAddress prefix =
88 it->name, it->name, rtc::IPAddress(address), 32, 86 rtc::TruncateIP(rtc::IPAddress(address), it->network_prefix);
89 ConvertConnectionTypeToAdapterType(it->type)); 87 rtc::Network* network =
88 new rtc::Network(it->name,
89 it->name,
90 prefix,
91 it->network_prefix,
92 ConvertConnectionTypeToAdapterType(it->type));
90 network->AddIP(rtc::IPAddress(address)); 93 network->AddIP(rtc::IPAddress(address));
91 networks.push_back(network); 94 networks.push_back(network);
92 ++ipv4_interfaces; 95 ++ipv4_interfaces;
93 } else if (it->address.size() == net::kIPv6AddressSize) { 96 } else if (it->address.size() == net::kIPv6AddressSize) {
94 in6_addr address; 97 in6_addr address;
95 memcpy(&address, &it->address[0], sizeof(in6_addr)); 98 memcpy(&address, &it->address[0], sizeof(in6_addr));
96 rtc::IPAddress ip6_addr(address); 99 rtc::IPAddress ip6_addr(address);
97 if (!rtc::IPIsPrivate(ip6_addr)) { 100 if (!rtc::IPIsPrivate(ip6_addr)) {
98 rtc::Network* network = new rtc::Network( 101 rtc::IPAddress prefix =
99 it->name, it->name, ip6_addr, 64, 102 rtc::TruncateIP(rtc::IPAddress(ip6_addr), it->network_prefix);
100 ConvertConnectionTypeToAdapterType(it->type)); 103 rtc::Network* network =
104 new rtc::Network(it->name,
105 it->name,
106 prefix,
107 it->network_prefix,
108 ConvertConnectionTypeToAdapterType(it->type));
101 network->AddIP(ip6_addr); 109 network->AddIP(ip6_addr);
102 networks.push_back(network); 110 networks.push_back(network);
103 ++ipv6_interfaces; 111 ++ipv6_interfaces;
104 } 112 }
105 } 113 }
106 } 114 }
107 115
108 116
109 // Send interface counts to UMA. 117 // Send interface counts to UMA.
110 UMA_HISTOGRAM_COUNTS_100("WebRTC.PeerConnection.IPv4Interfaces", 118 UMA_HISTOGRAM_COUNTS_100("WebRTC.PeerConnection.IPv4Interfaces",
(...skipping 22 matching lines...) Expand all
133 MergeNetworkList(networks, &changed); 141 MergeNetworkList(networks, &changed);
134 if (changed) 142 if (changed)
135 SignalNetworksChanged(); 143 SignalNetworksChanged();
136 } 144 }
137 145
138 void IpcNetworkManager::SendNetworksChangedSignal() { 146 void IpcNetworkManager::SendNetworksChangedSignal() {
139 SignalNetworksChanged(); 147 SignalNetworksChanged();
140 } 148 }
141 149
142 } // namespace content 150 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698