| OLD | NEW |
| 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 "net/base/network_change_notifier.h" | 5 #include "net/base/network_change_notifier.h" |
| 6 #include "net/base/network_change_notifier_factory.h" | 6 #include "net/base/network_change_notifier_factory.h" |
| 7 #include "build/build_config.h" | 7 #include "build/build_config.h" |
| 8 #if defined(OS_WIN) | 8 #if defined(OS_WIN) |
| 9 #include "net/base/network_change_notifier_win.h" | 9 #include "net/base/network_change_notifier_win.h" |
| 10 #elif defined(OS_LINUX) && !defined(OS_CHROMEOS) | 10 #elif defined(OS_LINUX) && !defined(OS_CHROMEOS) |
| (...skipping 10 matching lines...) Expand all Loading... |
| 21 // in ways that would require us to place locks around access to this object. | 21 // in ways that would require us to place locks around access to this object. |
| 22 // (The prohibition on global non-POD objects makes it tricky to do such a thing | 22 // (The prohibition on global non-POD objects makes it tricky to do such a thing |
| 23 // anyway.) | 23 // anyway.) |
| 24 NetworkChangeNotifier* g_network_change_notifier = NULL; | 24 NetworkChangeNotifier* g_network_change_notifier = NULL; |
| 25 | 25 |
| 26 // Class factory singleton. | 26 // Class factory singleton. |
| 27 NetworkChangeNotifierFactory* g_network_change_notifier_factory = NULL; | 27 NetworkChangeNotifierFactory* g_network_change_notifier_factory = NULL; |
| 28 | 28 |
| 29 class MockNetworkChangeNotifier : public NetworkChangeNotifier { | 29 class MockNetworkChangeNotifier : public NetworkChangeNotifier { |
| 30 public: | 30 public: |
| 31 virtual bool IsCurrentlyOffline() const { return false; } | 31 virtual ConnectionType GetCurrentConnectionType() const { |
| 32 return CONNECTION_UNKNOWN; |
| 33 } |
| 32 }; | 34 }; |
| 33 | 35 |
| 34 } // namespace | 36 } // namespace |
| 35 | 37 |
| 36 NetworkChangeNotifier::~NetworkChangeNotifier() { | 38 NetworkChangeNotifier::~NetworkChangeNotifier() { |
| 37 DCHECK_EQ(this, g_network_change_notifier); | 39 DCHECK_EQ(this, g_network_change_notifier); |
| 38 g_network_change_notifier = NULL; | 40 g_network_change_notifier = NULL; |
| 39 } | 41 } |
| 40 | 42 |
| 41 // static | 43 // static |
| (...skipping 26 matching lines...) Expand all Loading... |
| 68 return NetworkChangeNotifierLinux::Create(); | 70 return NetworkChangeNotifierLinux::Create(); |
| 69 #elif defined(OS_MACOSX) | 71 #elif defined(OS_MACOSX) |
| 70 return new NetworkChangeNotifierMac(); | 72 return new NetworkChangeNotifierMac(); |
| 71 #else | 73 #else |
| 72 NOTIMPLEMENTED(); | 74 NOTIMPLEMENTED(); |
| 73 return NULL; | 75 return NULL; |
| 74 #endif | 76 #endif |
| 75 } | 77 } |
| 76 | 78 |
| 77 // static | 79 // static |
| 78 bool NetworkChangeNotifier::IsOffline() { | 80 NetworkChangeNotifier::ConnectionType |
| 79 return g_network_change_notifier && | 81 NetworkChangeNotifier::GetConnectionType() { |
| 80 g_network_change_notifier->IsCurrentlyOffline(); | 82 return g_network_change_notifier ? |
| 83 g_network_change_notifier->GetCurrentConnectionType() : |
| 84 CONNECTION_UNKNOWN; |
| 81 } | 85 } |
| 82 | 86 |
| 83 // static | 87 // static |
| 84 bool NetworkChangeNotifier::IsWatchingDNS() { | 88 bool NetworkChangeNotifier::IsWatchingDNS() { |
| 85 if (!g_network_change_notifier) | 89 if (!g_network_change_notifier) |
| 86 return false; | 90 return false; |
| 87 base::AutoLock(g_network_change_notifier->watching_dns_lock_); | 91 base::AutoLock(g_network_change_notifier->watching_dns_lock_); |
| 88 return g_network_change_notifier->watching_dns_; | 92 return g_network_change_notifier->watching_dns_; |
| 89 } | 93 } |
| 90 | 94 |
| 91 // static | 95 // static |
| 92 NetworkChangeNotifier* NetworkChangeNotifier::CreateMock() { | 96 NetworkChangeNotifier* NetworkChangeNotifier::CreateMock() { |
| 93 return new MockNetworkChangeNotifier(); | 97 return new MockNetworkChangeNotifier(); |
| 94 } | 98 } |
| 95 | 99 |
| 96 void NetworkChangeNotifier::AddIPAddressObserver(IPAddressObserver* observer) { | 100 void NetworkChangeNotifier::AddIPAddressObserver(IPAddressObserver* observer) { |
| 97 if (g_network_change_notifier) | 101 if (g_network_change_notifier) |
| 98 g_network_change_notifier->ip_address_observer_list_->AddObserver(observer); | 102 g_network_change_notifier->ip_address_observer_list_->AddObserver(observer); |
| 99 } | 103 } |
| 100 | 104 |
| 101 void NetworkChangeNotifier::AddOnlineStateObserver( | 105 void NetworkChangeNotifier::AddConnectionTypeObserver( |
| 102 OnlineStateObserver* observer) { | 106 ConnectionTypeObserver* observer) { |
| 103 if (g_network_change_notifier) { | 107 if (g_network_change_notifier) { |
| 104 g_network_change_notifier->online_state_observer_list_->AddObserver( | 108 g_network_change_notifier->connection_type_observer_list_->AddObserver( |
| 105 observer); | 109 observer); |
| 106 } | 110 } |
| 107 } | 111 } |
| 108 | 112 |
| 109 void NetworkChangeNotifier::AddDNSObserver(DNSObserver* observer) { | 113 void NetworkChangeNotifier::AddDNSObserver(DNSObserver* observer) { |
| 110 if (g_network_change_notifier) { | 114 if (g_network_change_notifier) { |
| 111 g_network_change_notifier->resolver_state_observer_list_->AddObserver( | 115 g_network_change_notifier->resolver_state_observer_list_->AddObserver( |
| 112 observer); | 116 observer); |
| 113 } | 117 } |
| 114 } | 118 } |
| 115 | 119 |
| 116 void NetworkChangeNotifier::RemoveIPAddressObserver( | 120 void NetworkChangeNotifier::RemoveIPAddressObserver( |
| 117 IPAddressObserver* observer) { | 121 IPAddressObserver* observer) { |
| 118 if (g_network_change_notifier) { | 122 if (g_network_change_notifier) { |
| 119 g_network_change_notifier->ip_address_observer_list_->RemoveObserver( | 123 g_network_change_notifier->ip_address_observer_list_->RemoveObserver( |
| 120 observer); | 124 observer); |
| 121 } | 125 } |
| 122 } | 126 } |
| 123 | 127 |
| 124 void NetworkChangeNotifier::RemoveOnlineStateObserver( | 128 void NetworkChangeNotifier::RemoveConnectionTypeObserver( |
| 125 OnlineStateObserver* observer) { | 129 ConnectionTypeObserver* observer) { |
| 126 if (g_network_change_notifier) { | 130 if (g_network_change_notifier) { |
| 127 g_network_change_notifier->online_state_observer_list_->RemoveObserver( | 131 g_network_change_notifier->connection_type_observer_list_->RemoveObserver( |
| 128 observer); | 132 observer); |
| 129 } | 133 } |
| 130 } | 134 } |
| 131 | 135 |
| 132 void NetworkChangeNotifier::RemoveDNSObserver(DNSObserver* observer) { | 136 void NetworkChangeNotifier::RemoveDNSObserver(DNSObserver* observer) { |
| 133 if (g_network_change_notifier) { | 137 if (g_network_change_notifier) { |
| 134 g_network_change_notifier->resolver_state_observer_list_->RemoveObserver( | 138 g_network_change_notifier->resolver_state_observer_list_->RemoveObserver( |
| 135 observer); | 139 observer); |
| 136 } | 140 } |
| 137 } | 141 } |
| 138 | 142 |
| 139 NetworkChangeNotifier::NetworkChangeNotifier() | 143 NetworkChangeNotifier::NetworkChangeNotifier() |
| 140 : ip_address_observer_list_( | 144 : ip_address_observer_list_( |
| 141 new ObserverListThreadSafe<IPAddressObserver>( | 145 new ObserverListThreadSafe<IPAddressObserver>( |
| 142 ObserverListBase<IPAddressObserver>::NOTIFY_EXISTING_ONLY)), | 146 ObserverListBase<IPAddressObserver>::NOTIFY_EXISTING_ONLY)), |
| 143 online_state_observer_list_( | 147 connection_type_observer_list_( |
| 144 new ObserverListThreadSafe<OnlineStateObserver>( | 148 new ObserverListThreadSafe<ConnectionTypeObserver>( |
| 145 ObserverListBase<OnlineStateObserver>::NOTIFY_EXISTING_ONLY)), | 149 ObserverListBase<ConnectionTypeObserver>::NOTIFY_EXISTING_ONLY)), |
| 146 resolver_state_observer_list_( | 150 resolver_state_observer_list_( |
| 147 new ObserverListThreadSafe<DNSObserver>( | 151 new ObserverListThreadSafe<DNSObserver>( |
| 148 ObserverListBase<DNSObserver>::NOTIFY_EXISTING_ONLY)), | 152 ObserverListBase<DNSObserver>::NOTIFY_EXISTING_ONLY)), |
| 149 watching_dns_(false) { | 153 watching_dns_(false) { |
| 150 DCHECK(!g_network_change_notifier); | 154 DCHECK(!g_network_change_notifier); |
| 151 g_network_change_notifier = this; | 155 g_network_change_notifier = this; |
| 152 } | 156 } |
| 153 | 157 |
| 154 // static | 158 // static |
| 155 void NetworkChangeNotifier::NotifyObserversOfIPAddressChange() { | 159 void NetworkChangeNotifier::NotifyObserversOfIPAddressChange() { |
| (...skipping 17 matching lines...) Expand all Loading... |
| 173 if (!g_network_change_notifier->watching_dns_) | 177 if (!g_network_change_notifier->watching_dns_) |
| 174 detail |= NetworkChangeNotifier::CHANGE_DNS_WATCH_FAILED; | 178 detail |= NetworkChangeNotifier::CHANGE_DNS_WATCH_FAILED; |
| 175 } | 179 } |
| 176 DCHECK(!(detail & NetworkChangeNotifier::CHANGE_DNS_WATCH_FAILED) || | 180 DCHECK(!(detail & NetworkChangeNotifier::CHANGE_DNS_WATCH_FAILED) || |
| 177 !(detail & NetworkChangeNotifier::CHANGE_DNS_WATCH_STARTED)); | 181 !(detail & NetworkChangeNotifier::CHANGE_DNS_WATCH_STARTED)); |
| 178 g_network_change_notifier->resolver_state_observer_list_->Notify( | 182 g_network_change_notifier->resolver_state_observer_list_->Notify( |
| 179 &DNSObserver::OnDNSChanged, detail); | 183 &DNSObserver::OnDNSChanged, detail); |
| 180 } | 184 } |
| 181 } | 185 } |
| 182 | 186 |
| 183 // static | 187 void NetworkChangeNotifier::NotifyObserversOfConnectionTypeChange() { |
| 184 void NetworkChangeNotifier::NotifyObserversOfOnlineStateChange() { | |
| 185 if (g_network_change_notifier) { | 188 if (g_network_change_notifier) { |
| 186 g_network_change_notifier->online_state_observer_list_->Notify( | 189 g_network_change_notifier->connection_type_observer_list_->Notify( |
| 187 &OnlineStateObserver::OnOnlineStateChanged, !IsOffline()); | 190 &ConnectionTypeObserver::OnConnectionTypeChanged, |
| 191 GetConnectionType()); |
| 188 } | 192 } |
| 189 } | 193 } |
| 190 | 194 |
| 191 NetworkChangeNotifier::DisableForTest::DisableForTest() | 195 NetworkChangeNotifier::DisableForTest::DisableForTest() |
| 192 : network_change_notifier_(g_network_change_notifier) { | 196 : network_change_notifier_(g_network_change_notifier) { |
| 193 DCHECK(g_network_change_notifier); | 197 DCHECK(g_network_change_notifier); |
| 194 g_network_change_notifier = NULL; | 198 g_network_change_notifier = NULL; |
| 195 } | 199 } |
| 196 | 200 |
| 197 NetworkChangeNotifier::DisableForTest::~DisableForTest() { | 201 NetworkChangeNotifier::DisableForTest::~DisableForTest() { |
| 198 DCHECK(!g_network_change_notifier); | 202 DCHECK(!g_network_change_notifier); |
| 199 g_network_change_notifier = network_change_notifier_; | 203 g_network_change_notifier = network_change_notifier_; |
| 200 } | 204 } |
| 201 | 205 |
| 202 } // namespace net | 206 } // namespace net |
| OLD | NEW |